disconnect client when network fails

Author: 256dpi

src/MQTTClient.cpp

@@ -103,6 +103,12 @@ void MQTTClient::unsubscribe(const char * topic) {
 }
 
 void MQTTClient::loop() {
+  if(!this->network.connected() && this->client->isConnected()) {
+    // the following call will not send a packet but reset the instance
+    // to allow proper reconnection
+    this->client->disconnect();
+  }
+
   this->client->yield();
 }
 

src/Network.cpp

@@ -30,6 +30,10 @@ int Network::write(unsigned char* buffer, int len, int timeout) {
   client->setTimeout(timeout);
   return client->write((uint8_t*)buffer, len);
 }
+
+boolean Network::connected() {
+  return client->connected();
+}
 
 int Network::disconnect() {
   client->stop();

src/Network.h

@@ -8,5 +8,6 @@ class Network {
     int connect(char* hostname, int port);
     int read(unsigned char* buffer, int len, int timeout);
     int write(unsigned char* buffer, int len, int timeout);
+    boolean connected();
     int disconnect();
 };