add method streamNotifyRoom

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 = () => {
 
   }