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