update

Author: 256dpi

src/YunMQTTClient.cpp

@@ -34,7 +34,9 @@ boolean YunMQTTClient::connect(const char * clientId, const char * username, con
 
   // wait for answer
   String ret = this->process.readStringUntil('\n');
-  return ret.equals("ca");
+  this->alive = ret.equals("ca");
+
+  return this->connected();
 }
 
 void YunMQTTClient::publish(String topic) {
@@ -98,8 +100,7 @@ void YunMQTTClient::loop() {
 }
 
 boolean YunMQTTClient::connected() {
-  //TODO: fix!
-  return true;
+  return this->alive;
 }
 
 void YunMQTTClient::disconnect() {

src/YunMQTTClient.h

@@ -11,6 +11,7 @@ class YunMQTTClient {
   Process process;
   const char * hostname;
   int port;
+  boolean alive = false;
 public:
   YunMQTTClient(const char * hostname, int port);
   boolean connect(const char * clientId);

yun/client.py

@@ -67,3 +67,5 @@ def do_disconnect(client):
 
 while True:
     parse_command(c, sys.stdin.readline()[0:-1])
+
+# TODO: better error handling