add typing

src/app/services/chat/ws-chat.service.ts

@@ -231,8 +231,74 @@ export class WsChatService {
   deleteMessage() {}
   createRoom() {}
 
+  sendStreamNotifyRoom(roomId : string, username, event: 'typing', param: any) {
+
+    const requestId =  uuidv4()
+
+    let message = {
+      msg: "method",
+      method: "stream-notify-room",
+      id: requestId,
+      params: [
+        `${roomId}/${event}`,
+        username,
+        param
+      ]
+    };
+
+    this.ws.send({message, requestId})
+
+    return new Promise((resolve, reject) => {
+      this.ws.registerCallback({type:'Onmessage', funx:(message)=>{
+        if(message.id == requestId || deepFind(message,'result.id') == requestId) { // same request send
+          resolve('')
+          return true
+        }
+      }})
+    });
+
+  }
 
 
+  subStreamNotifyRoom(roomId : string , event: 'typing' | 'deleteMessage', param: any) {
+
+    const requestId =  uuidv4()
+
+    let message = {
+      msg: "sub",
+      id: requestId,
+      name: "stream-notify-room",
+      params:[
+        `${roomId}/${event}`,
+        param
+      ]
+    }
+
+
+    this.ws.send({message, requestId})
+
+    return new Promise((resolve, reject) => {
+      this.ws.registerCallback({type:'Onmessage', funx:(message)=>{
+        if(message.id == requestId ) { // same request send
+          resolve('')
+          return true
+        }
+      }})
+    });
+
+  }
+
+  receiveStreamNotifyRoom(funx: Function) {
+
+    this.ws.registerCallback({
+      type:'Onmessage',
+      funx:(message)=> {
+        if(message.collection == "stream-notify-room" && message.msg == 'changed') {
+          funx(message)
+        }
+    }})
+  }
+  
   loadHistory(roomId, limit: number = 50) {
 
     const requestId =  uuidv4()