perf: 使用 emitter 请求发消息

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);