listen to socket

Author: odeimaiz

services/static-webserver/client/source/class/osparc/data/model/Conversation.js

@@ -41,6 +41,8 @@ qx.Class.define("osparc.data.model.Conversation", {
 
     this.__messages = [];
     this.__fetchLastMessage();
+
+    this.__listenToConversationMessageWS();
   },
 
   statics: {
@@ -132,6 +134,12 @@ qx.Class.define("osparc.data.model.Conversation", {
     },
   },
 
+  events: {
+    "messageAdded": "qx.event.type.Data",
+    "messageUpdated": "qx.event.type.Data",
+    "messageDeleted": "qx.event.type.Data",
+  },
+
   members: {
     __fetchLastMessagePromise: null,
     __nextRequestParams: null,
@@ -150,6 +158,35 @@ qx.Class.define("osparc.data.model.Conversation", {
       }
     },
 
+    __listenToConversationMessageWS: function() {
+      [
+        this.self().CHANNELS.CONVERSATION_MESSAGE_CREATED,
+        this.self().CHANNELS.CONVERSATION_MESSAGE_UPDATED,
+        this.self().CHANNELS.CONVERSATION_MESSAGE_DELETED,
+      ].forEach(eventName => {
+        const eventHandler = message => {
+          if (message) {
+            const conversationId = message["conversationId"];
+            if (conversationId === this.getConversationId()) {
+              switch (eventName) {
+                case osparc.data.model.Conversation.CHANNELS.CONVERSATION_MESSAGE_CREATED:
+                  this.addMessage(message);
+                  break;
+                case osparc.data.model.Conversation.CHANNELS.CONVERSATION_MESSAGE_UPDATED:
+                  this.updateMessage(message);
+                  break;
+                case osparc.data.model.Conversation.CHANNELS.CONVERSATION_MESSAGE_DELETED:
+                  this.deleteMessage(message);
+                  break;
+              }
+            }
+          }
+        };
+        socket.on(eventName, eventHandler, this);
+        this.__wsHandlers.push({ eventName, handler: eventHandler });
+      });
+    },
+
     __fetchLastMessage: function() {
       if (this.__fetchLastMessagePromise) {
         return this.__fetchLastMessagePromise;
@@ -212,13 +249,34 @@ qx.Class.define("osparc.data.model.Conversation", {
         const found = this.__messages.find(msg => msg["messageId"] === message["messageId"]);
         if (!found) {
           this.__messages.push(message);
+          this.fireDataEvent("messageAdded", message);
         }
         // latest first
         this.__messages.sort((a, b) => new Date(b.created) - new Date(a.created));
         this.setLastMessage(this.__messages[0]);
       }
     },
 
+    updateMessage: function(message) {
+      if (message) {
+        const found = this.__messages.find(msg => msg["messageId"] === message["messageId"]);
+        if (found) {
+          Object.assign(found, message);
+          this.fireDataEvent("messageUpdated", found);
+        }
+      }
+    },
+
+    deleteMessage: function(message) {
+      if (message) {
+        const found = this.__messages.find(msg => msg["messageId"] === message["messageId"]);
+        if (found) {
+          this.__messages.remove(found);
+          this.fireDataEvent("messageDeleted", found);
+        }
+      }
+    },
+
     getContextProjectId: function() {
       if (this.getExtraContext() && "projectId" in this.getExtraContext()) {
         return this.getExtraContext()["projectId"];