decrypt watch messages

Author: skadefro

OpenFlow/src/WebSocketServerClient.ts

@@ -9,6 +9,7 @@ import { WebSocketServer } from "./WebSocketServer";
 import { Span } from "@opentelemetry/api";
 import { Logger } from "./Logger";
 import { WebServer } from "./WebServer";
+import { DatabaseConnection } from "./DatabaseConnection";
 interface IHashTable<T> {
     [key: string]: T;
 }
@@ -501,7 +502,7 @@ export class WebSocketServerClient {
                     const msg: SocketMessage = SocketMessage.fromcommand("watchevent");
                     const q = new WatchEventMessage();
                     q.id = stream.id;
-                    q.result = next;
+                    q.result = Config.db.decryptentity(next);
                     msg.data = JSON.stringify(q);
                     me._socketObject.send(msg.tojson());
                 } catch (error) {

OpenFlowNodeRED/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openiap/nodered",
-  "version": "1.2.74",
+  "version": "1.2.75",
   "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.2.74
+1.2.75

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openiap/openflow",
-  "version": "1.2.74",
+  "version": "1.2.75",
   "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": {