From d4470e0b80b1f36e4b686b172644f45e5ca98221 Mon Sep 17 00:00:00 2001
From: Peter Maquiran <peter.maquiran@equilibrium.local>
Date: Mon, 10 Jan 2022 12:59:25 +0100
Subject: [PATCH] add method streamNotifyRoom

---
 .../socket/rocket-chat-client.service.ts      | 30 +++++++++++++++++++
 1 file changed, 30 insertions(+)

diff --git a/src/app/services/socket/rocket-chat-client.service.ts b/src/app/services/socket/rocket-chat-client.service.ts
index d25205eb1..bc404caa1 100644
--- a/src/app/services/socket/rocket-chat-client.service.ts
+++ b/src/app/services/socket/rocket-chat-client.service.ts
@@ -167,6 +167,7 @@ class _RocketChatClientService {
     if(conditions == false) { return new Promise((resolve, reject) => { reject('no error')}); }
 
     const requestId =  uuidv4()
+    
     var subscribeRequest = {
       "msg": "sub",
       "id": requestId,
@@ -189,6 +190,35 @@ class _RocketChatClientService {
 
   }
 
+  streamNotifyRoom(roomId : string) {
+    const conditions = this.attemptRequestQueue({roomId},{methodName: 'subscribe'})
+    if(conditions == false) { return new Promise((resolve, reject) => { reject('no error')}); }
+    
+    const requestId =  uuidv4()
+
+    let streamNotifyObj = {
+      "msg": "method",
+      "method": "stream-notify-room", 
+      "id": requestId,
+      "params": [
+        `null/typing`,
+        "paulo.pinto",
+        true
+      ]
+    };
+
+    this.ws.send(streamNotifyObj, requestId)
+
+    return new Promise((resolve, reject) => {
+      this.ws.registerCallback({type:'Onmessage', requestId, runOnces: true, funx:(message)=>{
+        if(message.id == requestId || message.result.id == requestId) { // same request send
+          resolve('')
+        }
+      }})
+    });
+
+  }
+
   private disconnect = () => {
 
   }