hotfix QueueMessage for new robot

Author: skadefro

OpenFlow/src/Messages/QueueMessage.ts

@@ -2,13 +2,13 @@ import { Base } from "../base";
 
 export class QueueMessage implements IReplyMessage {
     public error: string;
-    public jwt:any;
+    public jwt: any;
 
-    public correlationId:string;
-    public replyto:string;
-    public queuename:string;
+    public correlationId: string;
+    public replyto: string;
+    public queuename: string;
     public data: any;
-    static assign(o:any):QueueMessage {
+    static assign(o: any): QueueMessage {
         if (typeof o === "string" || o instanceof String) {
             return Object.assign(new QueueMessage(), JSON.parse(o.toString()));
         }

OpenFlow/src/WebSocketClient.ts

@@ -269,6 +269,11 @@ export class WebSocketClient {
     async Queue(data: string, replyTo: string, correlationId: string, queuename: string): Promise<any[]> {
         var d: any = JSON.parse(data);
         var q: QueueMessage = new QueueMessage();
+        if (this.clientversion == "1.0.80" || this.clientversion == "1.0.81" || this.clientversion == "1.0.82" || this.clientversion == "1.0.83" || this.clientversion == "1.0.84" || this.clientversion == "1.0.85") {
+            q.data = d.payload;
+        } else {
+            q.data = d;
+        }
         q.data = d.payload; q.replyto = replyTo;
         q.error = d.error;
         q.correlationId = correlationId; q.queuename = queuename;

VERSION

@@ -1 +1 @@
-0.0.477
+0.0.478