From 92e84e4ad00ea010627be92e1f5d63fb7dd8c3bf Mon Sep 17 00:00:00 2001 From: Jimmy Date: Tue, 31 Dec 2024 15:05:38 +0800 Subject: [PATCH] =?UTF-8?q?perf:=20=E4=BD=BF=E7=94=A8=20emitter=20?= =?UTF-8?q?=E8=AF=B7=E6=B1=82=E5=8F=91=E6=B6=88=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- wai-server/api/messages/message.controller.js | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/wai-server/api/messages/message.controller.js b/wai-server/api/messages/message.controller.js index 00414e3..0869e2a 100644 --- a/wai-server/api/messages/message.controller.js +++ b/wai-server/api/messages/message.controller.js @@ -5,6 +5,7 @@ const { sessionStore } = require('../../core'); const { objectMapper, pick } = require('../../utils/commons.util'); const { createOutboundMessage } = require('../../services/outbound_messages.service'); +const waEmitter = require('../../core/emitter'); function sleep(ms) { return new Promise(resolve => setTimeout(resolve, ms)); } @@ -39,7 +40,8 @@ exports.sendText = async ctx => { await createOutboundMessage({ ...toUpsert }); // return 'Message sent successfully'; // { wsToSend, ret: 'Message sent successfully' }; // }); - wsToSend.sendTextMessage(to, content, actionId); + //wsToSend.sendTextMessage(to, content, actionId); + waEmitter.emit('request.' + from + '.send.message', {to, content, externalId: actionId}); return 'Message sent successfully'; // { wsToSend, ret: 'Message sent successfully' }; } catch (error) { console.error('Error sending message:', error);