diff --git a/api/src/chat/controllers/message.controller.ts b/api/src/chat/controllers/message.controller.ts index dda5430d..9429ae23 100644 --- a/api/src/chat/controllers/message.controller.ts +++ b/api/src/chat/controllers/message.controller.ts @@ -168,7 +168,7 @@ export class MessageController extends BaseController< read: false, delivery: false, }; - this.eventEmitter.emit('hook:chatbot:sent', sentMessage); + this.eventEmitter.emit('hook:chatbot:sent', sentMessage, event); return { success: true, }; diff --git a/api/src/chat/services/chat.service.ts b/api/src/chat/services/chat.service.ts index ec7b69e6..313682d5 100644 --- a/api/src/chat/services/chat.service.ts +++ b/api/src/chat/services/chat.service.ts @@ -83,7 +83,10 @@ export class ChatService { * @param sentMessage - The message that has been sent */ @OnEvent('hook:chatbot:sent') - async handleSentMessage(sentMessage: MessageCreateDto) { + async handleSentMessage( + sentMessage: MessageCreateDto, + _event: EventWrapper, + ) { if (sentMessage.mid) { try { const message = await this.messageService.findOneOrCreate( @@ -231,7 +234,7 @@ export class ChatService { read: false, }; - this.eventEmitter.emit('hook:chatbot:sent', sentMessage); + this.eventEmitter.emit('hook:chatbot:sent', sentMessage, event); this.eventEmitter.emit('hook:stats:entry', 'echo', 'Echo'); } catch (err) { this.logger.error('Unable to log echo message', err, event);