UniqAI/hexabot
1
0
Fork 0
mirror of https://github.com/hexastack/hexabot synced 2025-06-26 18:27:28 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #649 from Hexastack/fix/hook-chatbot-sent-event

Browse Source 
fix: hook chatbot sent event
This commit is contained in:
Med Marrouchi 2025-04-04 08:36:13 +01:00 committed by GitHub
commit 7977d9d445
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
api/src/chat/controllers/message.controller.ts
View File

@ -164,7 +164,7 @@ export class MessageController extends BaseController<
read: false, read: false,
delivery: false, delivery: false,
}; };
this.eventEmitter.emit('hook:chatbot:sent', sentMessage); this.eventEmitter.emit('hook:chatbot:sent', sentMessage, event);
return { return {
success: true, success: true,
}; };

7
api/src/chat/services/chat.service.ts
View File

@ -96,7 +96,10 @@ export class ChatService {
* @param sentMessage - The message that has been sent * @param sentMessage - The message that has been sent
*/ */
@OnEvent('hook:chatbot:sent') @OnEvent('hook:chatbot:sent')
async handleSentMessage(sentMessage: MessageCreateDto) { async handleSentMessage(
sentMessage: MessageCreateDto,
_event: EventWrapper<any, any>,
) {
if (sentMessage.mid) { if (sentMessage.mid) {
try { try {
const message = await this.messageService.findOneOrCreate( const message = await this.messageService.findOneOrCreate(
@ -244,7 +247,7 @@ export class ChatService {
read: false, 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'); this.eventEmitter.emit('hook:stats:entry', 'echo', 'Echo');
} catch (err) { } catch (err) {
this.logger.error('Unable to log echo message', err, event); this.logger.error('Unable to log echo message', err, event);