UniqAI/hexabot
1
0
Fork 0
mirror of https://github.com/hexastack/hexabot synced 2025-02-23 21:04:15 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: update chat.service onSubscriberCreate, onSubscriberUpdate methods

Browse Source
This commit is contained in:
yassinedorbozgithub 2025-01-15 08:28:22 +01:00
parent 227630d6c6
commit 7f6b481988
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -296,7 +296,9 @@ export class ChatService {
@OnEvent('hook:subscriber:postCreate') @OnEvent('hook:subscriber:postCreate')
async onSubscriberCreate({ _id }: SubscriberDocument) { async onSubscriberCreate({ _id }: SubscriberDocument) {
const subscriber = await this.subscriberService.findOne(_id); const subscriber = await this.subscriberService.findOne(_id);
if (subscriber) this.websocketGateway.broadcastSubscriberNew(subscriber); if (subscriber) {
this.websocketGateway.broadcastSubscriberNew(subscriber);
}
} }
/** /**
@ -307,6 +309,8 @@ export class ChatService {
@OnEvent('hook:subscriber:postUpdate') @OnEvent('hook:subscriber:postUpdate')
async onSubscriberUpdate({ _id }: SubscriberDocument) { async onSubscriberUpdate({ _id }: SubscriberDocument) {
const subscriber = await this.subscriberService.findOne(_id); const subscriber = await this.subscriberService.findOne(_id);
if (subscriber) this.websocketGateway.broadcastSubscriberUpdate(subscriber); if (subscriber) {
this.websocketGateway.broadcastSubscriberUpdate(subscriber);
}
} }
} }