From b51688fce4c8c25f55907e3e7e56053ade8c6340 Mon Sep 17 00:00:00 2001 From: hexastack Date: Thu, 30 Jan 2025 07:29:07 +0100 Subject: [PATCH] fix: hook chatbot sent event --- api/src/chat/controllers/message.controller.ts | 2 +- api/src/chat/services/chat.service.ts | 7 +++++-- 2 files changed, 6 insertions(+), 3 deletions(-) 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);