Address Node RED 3.1 changes (#62)

NRCHKB · Sep 12, 2023 · ddf94a0 · ddf94a0
1 parent 185391c
commit ddf94a0
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "node-red-contrib-unifi-os",
-    "version": "0.9.0",
+    "version": "0.9.1",
     "description": "Nodes to access UniFi data using endpoints and websockets",
     "main": "build/nodes/unifi.js",
     "scripts": {

diff --git a/src/nodes/Protect.ts b/src/nodes/Protect.ts
@@ -166,6 +166,14 @@ module.exports = (RED: NodeAPI) => {
             }, parseInt(self.config.delayedSnapshotTime))
         }
 
+        // Awaiter (Node RED 3.1 evaluateJSONataExpression )
+        let _AwaiterResolver: (value?: unknown) => void
+        const Awaiter = () => {
+            return new Promise((Resolve) => {
+                _AwaiterResolver = Resolve
+            })
+        }
+
         // Register our interest in Protect Updates.
         const handleUpdate = async (data: any) => {
             /*  This is to mirror the output pin assigmnets
@@ -337,15 +345,24 @@ module.exports = (RED: NodeAPI) => {
                     }
                 }
 
+                let Waiter
+
                 if (identifiedEvent.metadata.valueExpression) {
+                    Waiter = Awaiter()
                     const EXP = RED.util.prepareJSONataExpression(
                         identifiedEvent.metadata.valueExpression,
                         self
                     )
-                    UserPL.payload.value = RED.util.evaluateJSONataExpression(
+                    RED.util.evaluateJSONataExpression(
                         EXP,
-                        data
+                        data,
+                        (_err, res) => {
+                            UserPL.payload.value = res
+                            _AwaiterResolver()
+                        }
                     )
+
+                    await Promise.all([Waiter])
                 }
 
                 if (self.config.snapshotMode === 'None') {