UniqAI/hexabot
1
0
Fork 0
mirror of https://github.com/hexastack/hexabot synced 2025-01-22 18:45:57 +00:00
Code Issues Actions 13 Packages Projects Releases Wiki Activity

fix: adapt chat Module to strict null checks

Browse Source
This commit is contained in:
yassinedorbozgithub 2025-01-13 19:14:41 +01:00
parent 9b8a605bf8
commit 11ef58d048
2 changed files with 17 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
api/src/chat/schemas/types/channel.ts
View File

@ -8,10 +8,8 @@
import { ChannelName } from '@/channel/types';
export type SubscriberChannelData<
C extends ChannelName = null,
// K extends keyof SubscriberChannelDict[C] = keyof SubscriberChannelDict[C],
> = C extends null
export type SubscriberChannelData<C extends ChannelName = 'unknown-channel'> =
C extends 'unknown-channel'
? { name: ChannelName }
: {
name: C;

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

@ -117,6 +117,12 @@ export class ChatService {
try {
const msg = await this.messageService.create(received);
const populatedMsg = await this.messageService.findOneAndPopulate(msg.id);
if (!populatedMsg) {
this.logger.warn('Unable to find populated message.', event);
throw new Error(`Unable to find Message by ID ${msg.id} not found`);
}
this.websocketGateway.broadcastMessageReceived(populatedMsg, subscriber);
this.eventEmitter.emit('hook:stats:entry', 'incoming', 'Incoming');
this.eventEmitter.emit(
@ -288,7 +294,7 @@ export class ChatService {
@OnEvent('hook:subscriber:postCreate')
async onSubscriberCreate({ _id }: SubscriberDocument) {
const subscriber = await this.subscriberService.findOne(_id);
this.websocketGateway.broadcastSubscriberNew(subscriber);
if (subscriber) this.websocketGateway.broadcastSubscriberNew(subscriber);
}
/**
@ -299,6 +305,6 @@ export class ChatService {
@OnEvent('hook:subscriber:postUpdate')
async onSubscriberUpdate({ _id }: SubscriberDocument) {
const subscriber = await this.subscriberService.findOne(_id);
this.websocketGateway.broadcastSubscriberUpdate(subscriber);
if (subscriber) this.websocketGateway.broadcastSubscriberUpdate(subscriber);
}
}