mqtt fix in esp8266 code

3 files changed, 12 insertions, 7 deletions

diff --git a/platformio/common/libs/mqtt/homekit/mqtt/module.h b/platformio/common/libs/mqtt/homekit/mqtt/module.h
index e4a01f8..abf7d94 100644
--- a/platformio/common/libs/mqtt/homekit/mqtt/module.h
+++ b/platformio/common/libs/mqtt/homekit/mqtt/module.h
@@ -39,6 +39,10 @@ public:
         initialized = true;
     }
 
+	inline void unsetInitialized() {
+        initialized = false;
+    }
+
 	inline short getTickInterval() {
 		return tickInterval;
 	}
diff --git a/platformio/common/libs/mqtt/homekit/mqtt/mqtt.cpp b/platformio/common/libs/mqtt/homekit/mqtt/mqtt.cpp
index 16f4675..0e58833 100644
--- a/platformio/common/libs/mqtt/homekit/mqtt/mqtt.cpp
+++ b/platformio/common/libs/mqtt/homekit/mqtt/mqtt.cpp
@@ -53,11 +53,12 @@ Mqtt::Mqtt() {
             if (module->receiveOnDisconnect) {
                 module->handleOnDisconnect(reason);
             }
+            module->unsetInitialized();
         }
 
-		reconnectTimer.once(2, [&]() {
-			reconnect();
-		});
+        reconnectTimer.once(2, [&]() {
+            reconnect();
+        });
     });
 
     client.onSubscribe([&](uint16_t packetId, const SubscribeReturncode* returncodes, size_t len) {
@@ -126,8 +127,8 @@ void Mqtt::disconnect() {
 void Mqtt::loop() {
     client.loop();
     for (auto& module: modules) {
-		if (module->getTickInterval() != 0)
-			module->tick(*this);
+        if (module->getTickInterval() != 0)
+            module->tick(*this);
     }
 }
 
@@ -157,7 +158,7 @@ void Mqtt::addModule(MqttModule* module) {
 
 void Mqtt::subscribeModule(String& topic, MqttModule* module, uint8_t qos) {
     moduleSubscriptions[topic] = module;
-	subscribe(topic, qos);
+    subscribe(topic, qos);
 }
 
 }
diff --git a/platformio/common/libs/mqtt/library.json b/platformio/common/libs/mqtt/library.json
index d1ad420..2712fb8 100644
--- a/platformio/common/libs/mqtt/library.json
+++ b/platformio/common/libs/mqtt/library.json
@@ -1,6 +1,6 @@
 {
   "name": "homekit_mqtt",
-  "version": "1.0.9",
+  "version": "1.0.10",
   "build": {
     "flags": "-I../../include"
   }