Updating

terafin · May 30, 2023 · 66fc926 · 66fc926
1 parent 0522fce
commit 66fc926
Show file tree

Hide file tree

Showing 2 changed files with 1,571 additions and 998 deletions.
diff --git a/mqtt-rules.js b/mqtt-rules.js
@@ -138,24 +138,26 @@ const disconnectionEvent = function() {
 const connectionProcessor = function() {
     logging.info(' * Processing bulk connection setup start')
 
-    // need to capture everything that comes in, and process it as such
-    const changedTopics = Object.keys(collectedMQTTTChanges)
-
-    if ( !_.isNil(changedTopics) ) {
-        changedTopics.forEach(topic => {
-            const message = collectedMQTTTChanges[topic]
-
-            global.generateContext(topic, message, function(outTopic, outMessage, context) {
-                if (_.isNil(outTopic) || _.isNil(outMessage)) {
-                    logging.error(' *** NOT Processing rules for: ' + topic)
-                    logging.error('                     outTopic: ' + outTopic)
-                    logging.error('                   outMessage: ' + outMessage)
-                } else {
-                    context['firstRun'] = true
-                    global.changeProcessor(null, context, outTopic, outMessage)
-                }
+    if ( !_.isNil(collectedMQTTTChanges) ) {
+        // need to capture everything that comes in, and process it as such
+        const changedTopics = Object.keys(collectedMQTTTChanges)
+
+        if ( !_.isNil(changedTopics) ) {
+            changedTopics.forEach(topic => {
+                const message = collectedMQTTTChanges[topic]
+
+                global.generateContext(topic, message, function(outTopic, outMessage, context) {
+                    if (_.isNil(outTopic) || _.isNil(outMessage)) {
+                        logging.error(' *** NOT Processing rules for: ' + topic)
+                        logging.error('                     outTopic: ' + outTopic)
+                        logging.error('                   outMessage: ' + outMessage)
+                    } else {
+                        context['firstRun'] = true
+                        global.changeProcessor(null, context, outTopic, outMessage)
+                    }
+                })
             })
-        })
+        }
     }
     stopCollectingMQTTChanges()
     logging.info(' => Done!')