From 1dade29c50ae6eb89985ce484df1c03a68f64b53 Mon Sep 17 00:00:00 2001 From: Peter Maquiran Date: Mon, 10 Jan 2022 11:40:34 +0100 Subject: [PATCH] add send method --- .../socket/rocket-chat-client.service.ts | 19 ++++++++++++------- 1 file changed, 12 insertions(+), 7 deletions(-) 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() {}