add get room

src/app/services/socket/rocket-chat-client.service.ts

@@ -61,7 +61,8 @@ class _RocketChatClientService {
 
     return new Promise((resolve, reject) => {
       this.ws.registerCallback({type:'Onmessage', requestId, runOnces: true, funx:(message)=>{
-        if(message.result.id == requestId) { // same request send
+        // console.log(message.result.id, requestId)
+        if(message.id == requestId) { // same request send
           if(message.result) {
             if(message.result.token) {
               this.isLogin = true
@@ -116,13 +117,22 @@ class _RocketChatClientService {
       "params": [ { "$date": 1480377601 } ]
     }
     this.ws.send(request, requestId)
+
+    return new Promise((resolve, reject) => {
+      this.ws.registerCallback({type:'Onmessage', requestId, runOnces: true, funx:(message)=>{
+        if(message.result.id == requestId) { // same request send
+          resolve(message)
+        }
+      }})
+    });
   }
 
 
   subscribe() {
+    const requestId =  uuidv4()
     var subscribeRequest = {
       "msg": "sub",
-      "id": "unique-id",
+      "id": requestId,
       "name": "stream-notify-room",
       "params":[
       "room-id/event",
@@ -130,7 +140,16 @@ class _RocketChatClientService {
       ]
     }
 
-   //this.ws.send(subscribeRequest);
+   this.ws.send(subscribeRequest);
+   
+    return new Promise((resolve, reject) => {
+      this.ws.registerCallback({type:'Onmessage', requestId, runOnces: true, funx:(message)=>{
+        if(message.result.id == requestId) { // same request send
+          resolve(message)
+        }
+      }})
+    });
+
   }
 
   private disconnect = () => {
@@ -185,7 +204,7 @@ class _RocketChatClientService {
         console.log('save msgQueue')
         this.wsMsgQueue.push({message, requestId})
       } else {
-        // console.log('send rocket chat', message)
+        console.log('send rocket chat', message)
         let messageStr = JSON.stringify(message)
         this.socket.send(messageStr)
       }