listenToConversationMessageWS addMessage

Author: odeimaiz

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

@@ -159,6 +159,7 @@ qx.Class.define("osparc.data.model.Conversation", {
     },
 
     __listenToConversationMessageWS: function() {
+      const socket = osparc.wrapper.WebSocket.getInstance();
       [
         this.self().CHANNELS.CONVERSATION_MESSAGE_CREATED,
         this.self().CHANNELS.CONVERSATION_MESSAGE_UPDATED,
@@ -169,21 +170,22 @@ qx.Class.define("osparc.data.model.Conversation", {
             const conversationId = message["conversationId"];
             if (conversationId === this.getConversationId()) {
               switch (eventName) {
-                case osparc.data.model.Conversation.CHANNELS.CONVERSATION_MESSAGE_CREATED:
+                case this.self().CHANNELS.CONVERSATION_MESSAGE_CREATED:
                   this.addMessage(message);
                   break;
-                case osparc.data.model.Conversation.CHANNELS.CONVERSATION_MESSAGE_UPDATED:
+                case this.self().CHANNELS.CONVERSATION_MESSAGE_UPDATED:
                   this.updateMessage(message);
                   break;
-                case osparc.data.model.Conversation.CHANNELS.CONVERSATION_MESSAGE_DELETED:
+                case this.self().CHANNELS.CONVERSATION_MESSAGE_DELETED:
                   this.deleteMessage(message);
                   break;
               }
             }
           }
         };
         socket.on(eventName, eventHandler, this);
-        this.__wsHandlers.push({ eventName, handler: eventHandler });
+        // OM do I need this?
+        // this.__wsHandlers.push({ eventName, handler: eventHandler });
       });
     },
 

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

@@ -141,9 +141,24 @@ qx.Class.define("osparc.support.Conversation", {
       });
     },
 
-    __applyConversation: function() {
+    __applyConversation: function(conversation) {
       this.__reloadMessages(true);
 
+      if (conversation) {
+        conversation.addListener("messageAdded", e => {
+          const data = e.getData();
+          this.addMessage(data);
+        });
+        conversation.addListener("messageUpdated", e => {
+          const data = e.getData();
+          console.log("Message updated:", data);
+        });
+        conversation.addListener("messageDeleted", e => {
+          const data = e.getData();
+          console.log("Message deleted:", data);
+        });
+      }
+
       this.__populateShareProjectCheckbox();
     },