fix(connection): Retry establishing a connection when Node-RED starts…

… up offline; fixes #265
csuermann · Oct 25, 2024 · d55e79c · d55e79c
1 parent dda4fd0
commit d55e79c
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/MqttClient.js b/MqttClient.js
@@ -54,7 +54,11 @@ class MqttClient extends EventEmitter {
   }
 
   async end() {
-    return this.client.endAsync()
+    try {
+      return this.client.endAsync()
+    } catch (err) {
+      return false
+    }
   }
 
   async publish(topic, json) {

diff --git a/connection.js b/connection.js
@@ -726,10 +726,13 @@ module.exports = function (RED) {
           return
         }
       } catch (e) {
-        this.errorCode =
-          'version check failed. Ensure internet connectivity and restart the flow'
+        this.errorCode = 'Connection failed'
         this.isError = true
         this.refreshChildrenNodeStatus()
+
+        //retry again in 30s:
+        setTimeout(() => this.connectAndSubscribe(), 30_000)
+
         return this.logger(`version check failed! ${e.message}`, null, 'error')
       }