fix

Author: skadefro

OpenFlow/src/WebSocketServer.ts

@@ -60,26 +60,26 @@ export class WebSocketServer {
     })
     public static update_message_queue_count(cli: WebSocketServerClient) {
         if (!Config.prometheus_measure_queued_messages) return;
-        const result: any = {};
+        // const result: any = {};
         const keys = Object.keys(cli.messageQueue);
-        keys.forEach(key => {
-            try {
-                const qmsg = cli.messageQueue[key];
-                var o = qmsg.message;
-                if (typeof o === "string") o = JSON.parse(o);
-                const msg: Message = o;
-                if (result[msg.command] == null) result[msg.command] = 0;
-                result[msg.command]++;
-            } catch (error) {
-                WebSocketServer._logger.error(error);
-            }
-        });
-        const keys2 = Object.keys(result);
+        // keys.forEach(key => {
+        //     try {
+        //         const qmsg = cli.messageQueue[key];
+        //         var o = qmsg.message;
+        //         if (typeof o === "string") o = JSON.parse(o);
+        //         const msg: Message = o;
+        //         if (result[msg.command] == null) result[msg.command] = 0;
+        //         result[msg.command]++;
+        //     } catch (error) {
+        //         WebSocketServer._logger.error(error);
+        //     }
+        // });
+        // const keys2 = Object.keys(result);
         WebSocketServer.message_queue_count.reset();
         WebSocketServer.message_queue_count.labels(cli.id).set(keys.length);
-        keys2.forEach(key => {
-            WebSocketServer.message_queue_count.labels(cli.id, key).set(result[key]);
-        });
+        // keys2.forEach(key => {
+        //     WebSocketServer.message_queue_count.labels(cli.id, key).set(result[key]);
+        // });
     }
     public static update_mongodb_watch_count(cli: WebSocketServerClient) {
         if (!Config.prometheus_measure__mongodb_watch) return;

OpenFlowNodeRED/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openiap/nodered",
-  "version": "1.1.173",
+  "version": "1.1.174",
   "description": "Simple wrapper around NodeRed, RabbitMQ and MongoDB to support a more scaleable NodeRed implementation.\r Also the \"backend\" for [OpenRPA](https://github.com/skadefro/OpenRPA)",
   "main": "index.js",
   "scripts": {

VERSION

@@ -1 +1 @@
-1.1.173
+1.1.174

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openiap/openflow",
-  "version": "1.1.173",
+  "version": "1.1.174",
   "description": "Simple wrapper around NodeRed, RabbitMQ and MongoDB to support a more scaleable NodeRed implementation.\r Also the \"backend\" for [OpenRPA](https://github.com/skadefro/OpenRPA)",
   "main": "index.js",
   "scripts": {