update webchat channel

hellotext · Jan 13, 2025 · 11eb877 · 11eb877
1 parent 67bf283
commit 11eb877
Show file tree

Hide file tree

Showing 3 changed files with 37 additions and 5 deletions.
diff --git a/dist/hellotext.js b/dist/hellotext.js
diff --git a/lib/channels/webchat_channel.js b/lib/channels/webchat_channel.js
@@ -47,6 +47,20 @@ var WebchatChannel = /*#__PURE__*/function (_ApplicationChannel) {
         identifier: params
       });
     }
+  }, {
+    key: "unsubscribe",
+    value: function unsubscribe() {
+      var params = {
+        channel: "WebchatChannel",
+        id: this.id,
+        session: this.session,
+        conversation: this.conversation
+      };
+      this.send({
+        command: 'unsubscribe',
+        identifier: params
+      });
+    }
   }, {
     key: "onMessage",
     value: function onMessage(callback) {
@@ -85,8 +99,11 @@ var WebchatChannel = /*#__PURE__*/function (_ApplicationChannel) {
   }, {
     key: "updateSubscriptionWith",
     value: function updateSubscriptionWith(conversation) {
-      this.conversation = conversation;
-      this.subscribe();
+      this.unsubscribe();
+      setTimeout(() => {
+        this.conversation = conversation;
+        this.subscribe();
+      }, 1000);
     }
   }]);
   return WebchatChannel;

diff --git a/src/channels/webchat_channel.js b/src/channels/webchat_channel.js
@@ -22,6 +22,17 @@ class WebchatChannel extends ApplicationChannel {
     this.send( { command: 'subscribe',  identifier: params })
   }
 
+  unsubscribe() {
+    const params = {
+      channel: "WebchatChannel",
+      id: this.id,
+      session: this.session,
+      conversation: this.conversation,
+    }
+
+    this.send({ command: 'unsubscribe', identifier: params })
+  }
+
   onMessage(callback) {
     super.onMessage((message) => {
       if(message.type !== 'message') return
@@ -54,8 +65,12 @@ class WebchatChannel extends ApplicationChannel {
   }
 
   updateSubscriptionWith(conversation) {
-    this.conversation = conversation
-    this.subscribe()
+    this.unsubscribe()
+
+    setTimeout(() => {
+      this.conversation = conversation
+      this.subscribe()
+    }, 1000)
   }
 }