diff --git a/src/app/services/socket/rocket-chat-client.service.ts b/src/app/services/socket/rocket-chat-client.service.ts index 4b0a1f021..efee7c950 100644 --- a/src/app/services/socket/rocket-chat-client.service.ts +++ b/src/app/services/socket/rocket-chat-client.service.ts @@ -83,7 +83,7 @@ class _RocketChatClientService { logout(){} - send(roomId, message, option) { + send(roomId, message) { const requestId = uuidv4() var request = { @@ -91,18 +91,23 @@ class _RocketChatClientService { method: "sendMessage", id: requestId, params: [{ - _id: "message-id" || uuidv4(), - rid: "room-id" || roomId, - msg: "Hello World!" || message + _id: uuidv4(), + rid: roomId, + msg: message }] } - // this.ws.send(request, requestId); + this.ws.send(request, requestId); - return 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(message) + } + }}) + }); } - subtribe() {} joinRoom(){} deleteMessage() {} createRoom() {}