Fix reconnect error

Author: ilcato

arduino-iot-client-mqtt/arduino-iot-client-mqtt.js

@@ -73,6 +73,7 @@ class ArduinoClientMqtt {
         port: options.port || arduinoCloudPort,
         ssl,
         token: options.token,
+        onOffline: options.onOffline,
         onDisconnect: options.onDisconnect,
         onConnected: options.onConnected,
         useCloudProtocolV2: options.useCloudProtocolV2 || false,
@@ -186,10 +187,15 @@ class ArduinoClientMqtt {
           }
        }
       });
-
+      if (typeof this.opts.onOffline === 'function') {
+        client.on("offline", () => {
+          this.opts.onOffline();
+        });
+      }
       if (typeof this.opts.onDisconnect === 'function') {
-        client.on("offline", this.opts.onDisconnect);
-        client.on("disconnect", this.opts.onDisconnect);
+        client.on("disconnect", () => {
+          this.opts.onDisconnect();
+        });
       }
     });
   }

utils/arduino-connection-manager.js

@@ -75,7 +75,7 @@ async function getClientMqtt(connectionConfig, RED) {
               }
             });
 
-            await reconnectMqtt(connectionConfig.credentials.clientid);
+//            await reconnectMqtt(connectionConfig.credentials.clientid);
 
           },
           onConnected: () =>{
@@ -119,12 +119,19 @@ async function getClientMqtt(connectionConfig, RED) {
             RED.nodes.eachNode((n)=>{
               if(n.type === "property in"){
                 const node = RED.nodes.getNode(n.id);
-                node.status({ fill: "red", shape: "dot", text: "Connection Error" });
+                node.status({ fill: "red", shape: "dot", text: "Disconnected" });
               }
             });
-
             await reconnectMqtt(connectionConfig.credentials.clientid);
-
+          },
+          onOffline: async () => {
+            console.log(`connection lost for ${connectionConfig.credentials.clientid}`);
+            RED.nodes.eachNode((n)=>{
+              if(n.type === "property in"){
+                const node = RED.nodes.getNode(n.id);
+                node.status({ fill: "red", shape: "dot", text: "Offline" });
+              }
+            });
           },
           onConnected: () =>{
             RED.nodes.eachNode((n)=>{