fix reconnectMqtt

Author: fabik111

arduino-cloud.js

@@ -209,6 +209,7 @@ module.exports = function (RED) {
         this.pollTimeoutPoll = setTimeout(() => { this.poll(connectionConfig, pollTime) }, pollTime * 1000);
       } catch (err) {
         console.log(err);
+        this.pollTimeoutPoll = setTimeout(() => { this.poll(connectionConfig, pollTime) }, pollTime * 1000);
         this.status({ fill: "red", shape: "dot", text: "Error getting value" });
       }
     }

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

@@ -214,6 +214,11 @@ class ArduinoClientMqtt {
       return resolve();
     });
   }
+
+  async reconnect() {
+    await this.connection.reconnect();
+  };
+
   async updateToken(token) {
     // This infinite loop will exit once the reconnection is successful -
     // and will pause between each reconnection tentative, every 5 secs.

utils/arduino-connection-manager.js

@@ -68,8 +68,9 @@ async function getClientMqtt(connectionConfig) {
           host: arduinoCloudHost,
           token: tokenInfo.token,
           onDisconnect: () => {
-            reconnectMqtt(connectionConfig.credentials.clientid);
             console.log(`connection lost for ${connectionConfig.credentials.clientid}`);
+            reconnectMqtt(connectionConfig.credentials.clientid);
+
           },
           useCloudProtocolV2: true
         };
@@ -97,8 +98,9 @@ async function getClientMqtt(connectionConfig) {
           host: "wss.iot.oniudra.cc",
           token: connections[user].token,
           onDisconnect: () => {
-            reconnectMqtt(connectionConfig.credentials.clientid);
             console.log(`connection lost for ${connectionConfig.credentials.clientid}`);
+            reconnectMqtt(connectionConfig.credentials.clientid);
+
           },
           useCloudProtocolV2: true
         };
@@ -238,17 +240,7 @@ async function deleteClientHttp(clientId) {
 async function reconnectMqtt(clientId) {
   var user = findUser(clientId);
   if (user !== -1) {
-    await connections[user].clientMqtt.disconnect();
-    const ArduinoCloudOptions = {
-      host: "wss.iot.oniudra.cc",
-      token: connections[user].token,
-      onDisconnect: () => {
-        reconnectMqtt(connectionConfig.credentials.clientid);
-        console.log(`connection lost for ${connectionConfig.credentials.clientid}`);
-      },
-      useCloudProtocolV2: true
-    };
-    await connections[user].clientMqtt.connect(ArduinoCloudOptions);
+    await connections[user].clientMqtt.reconnect();
   }
 }