Fix dynamic package size

Author: skadefro

OpenFlow/src/Messages/Message.ts

@@ -780,11 +780,13 @@ export class Message {
             } else if (msg.rawAssertion !== null && msg.rawAssertion !== undefined) {
                 type = "samltoken";
                 user = await LoginProvider.validateToken(msg.rawAssertion);
+                // refresh, for roles and stuff
                 if (user !== null && user != undefined) { tuser = TokenUser.From(user); }
                 msg.rawAssertion = "";
             } else {
                 user = await Auth.ValidateByPassword(msg.username, msg.password);
                 tuser = null;
+                // refresh, for roles and stuff
                 if (user != null) tuser = TokenUser.From(user);
                 if (user == null) {
                     tuser = new TokenUser();
@@ -811,6 +813,16 @@ export class Message {
                 }
 
                 msg.user = tuser;
+                if (msg.impersonate == "-1" || msg.impersonate == "false") {
+                    user.impersonating = undefined;
+                } else if (!NoderedUtil.IsNullEmpty(user.impersonating) && NoderedUtil.IsNullEmpty(msg.impersonate)) {
+                    const items = await Config.db.query({ _id: user.impersonating }, null, 1, 0, null, "users", msg.jwt);
+                    if (items.length == 0) {
+                        msg.impersonate = null;
+                    } else {
+                        msg.impersonate = user.impersonating;
+                    }
+                }
                 if (msg.impersonate !== undefined && msg.impersonate !== null && msg.impersonate !== "" && tuser._id != msg.impersonate) {
                     const items = await Config.db.query({ _id: msg.impersonate }, null, 1, 0, null, "users", msg.jwt);
                     if (items.length == 0) {

OpenFlow/src/WebSocketServerClient.ts

@@ -315,7 +315,7 @@ export class WebSocketServerClient {
         });
     }
     private _Send(message: Message, cb: QueuedMessageCallback): void {
-        const messages: string[] = this.chunkString(message.data, 500);
+        const messages: string[] = this.chunkString(message.data, Config.websocket_package_size);
         if (NoderedUtil.IsNullUndefinded(messages) || messages.length === 0) {
             const singlemessage: SocketMessage = SocketMessage.frommessage(message, "", 1, 0);
             if (NoderedUtil.IsNullEmpty(message.replyto)) {

OpenFlowNodeRED/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openiap/nodered",
-  "version": "1.1.144",
+  "version": "1.1.145",
   "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.144
+1.1.145

package.json

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