diff --git a/api/src/analytics/repositories/bot-stats.repository.ts b/api/src/analytics/repositories/bot-stats.repository.ts index d63d5257..4c6f7c86 100644 --- a/api/src/analytics/repositories/bot-stats.repository.ts +++ b/api/src/analytics/repositories/bot-stats.repository.ts @@ -7,6 +7,7 @@ */ import { Injectable } from '@nestjs/common'; +import { EventEmitter2 } from '@nestjs/event-emitter'; import { InjectModel } from '@nestjs/mongoose'; import { Model } from 'mongoose'; @@ -16,8 +17,11 @@ import { BotStats, BotStatsType } from '../schemas/bot-stats.schema'; @Injectable() export class BotStatsRepository extends BaseRepository { - constructor(@InjectModel(BotStats.name) readonly model: Model) { - super(model, BotStats); + constructor( + readonly eventEmitter: EventEmitter2, + @InjectModel(BotStats.name) readonly model: Model, + ) { + super(eventEmitter, model, BotStats); } /** diff --git a/api/src/attachment/repositories/attachment.repository.ts b/api/src/attachment/repositories/attachment.repository.ts index ccb7a92f..a686cd43 100644 --- a/api/src/attachment/repositories/attachment.repository.ts +++ b/api/src/attachment/repositories/attachment.repository.ts @@ -18,10 +18,9 @@ import { Attachment } from '../schemas/attachment.schema'; @Injectable() export class AttachmentRepository extends BaseRepository { constructor( - @InjectModel(Attachment.name) readonly model: Model, readonly eventEmitter: EventEmitter2, + @InjectModel(Attachment.name) readonly model: Model, ) { - super(model, Attachment); - super.setEventEmitter(eventEmitter); + super(eventEmitter, model, Attachment); } } diff --git a/api/src/chat/repositories/block.repository.ts b/api/src/chat/repositories/block.repository.ts index 3acf85f4..5d1440db 100644 --- a/api/src/chat/repositories/block.repository.ts +++ b/api/src/chat/repositories/block.repository.ts @@ -7,6 +7,7 @@ */ import { Injectable, Optional } from '@nestjs/common'; +import { EventEmitter2 } from '@nestjs/event-emitter'; import { InjectModel } from '@nestjs/mongoose'; import { Document, @@ -36,10 +37,11 @@ export class BlockRepository extends BaseRepository< BlockFull > { constructor( + readonly eventEmitter: EventEmitter2, @InjectModel(Block.name) readonly model: Model, @Optional() private readonly logger?: LoggerService, ) { - super(model, Block, BLOCK_POPULATE, BlockFull); + super(eventEmitter, model, Block, BLOCK_POPULATE, BlockFull); } /** diff --git a/api/src/chat/repositories/category.repository.ts b/api/src/chat/repositories/category.repository.ts index b8a93662..74e134e0 100644 --- a/api/src/chat/repositories/category.repository.ts +++ b/api/src/chat/repositories/category.repository.ts @@ -7,6 +7,7 @@ */ import { ForbiddenException, Injectable, Optional } from '@nestjs/common'; +import { EventEmitter2 } from '@nestjs/event-emitter'; import { InjectModel } from '@nestjs/mongoose'; import { Document, Model, Query, TFilterQuery } from 'mongoose'; @@ -20,10 +21,11 @@ export class CategoryRepository extends BaseRepository { private readonly blockService: BlockService; constructor( + readonly eventEmitter: EventEmitter2, @InjectModel(Category.name) readonly model: Model, @Optional() blockService?: BlockService, ) { - super(model, Category); + super(eventEmitter, model, Category); this.blockService = blockService; } diff --git a/api/src/chat/repositories/context-var.repository.ts b/api/src/chat/repositories/context-var.repository.ts index ad37578d..57f920c8 100644 --- a/api/src/chat/repositories/context-var.repository.ts +++ b/api/src/chat/repositories/context-var.repository.ts @@ -7,6 +7,7 @@ */ import { Injectable } from '@nestjs/common'; +import { EventEmitter2 } from '@nestjs/event-emitter'; import { InjectModel } from '@nestjs/mongoose'; import { Model } from 'mongoose'; @@ -16,7 +17,10 @@ import { ContextVar } from '../schemas/context-var.schema'; @Injectable() export class ContextVarRepository extends BaseRepository { - constructor(@InjectModel(ContextVar.name) readonly model: Model) { - super(model, ContextVar); + constructor( + readonly eventEmitter: EventEmitter2, + @InjectModel(ContextVar.name) readonly model: Model, + ) { + super(eventEmitter, model, ContextVar); } } diff --git a/api/src/chat/repositories/conversation.repository.ts b/api/src/chat/repositories/conversation.repository.ts index aea3117a..fdbcb401 100644 --- a/api/src/chat/repositories/conversation.repository.ts +++ b/api/src/chat/repositories/conversation.repository.ts @@ -27,11 +27,16 @@ export class ConversationRepository extends BaseRepository< ConversationFull > { constructor( - @InjectModel(Conversation.name) readonly model: Model, readonly eventEmitter: EventEmitter2, + @InjectModel(Conversation.name) readonly model: Model, ) { - super(model, Conversation, CONVERSATION_POPULATE, ConversationFull); - super.setEventEmitter(eventEmitter); + super( + eventEmitter, + model, + Conversation, + CONVERSATION_POPULATE, + ConversationFull, + ); } /** diff --git a/api/src/chat/repositories/label.repository.ts b/api/src/chat/repositories/label.repository.ts index ede9f4ff..6bcf0624 100644 --- a/api/src/chat/repositories/label.repository.ts +++ b/api/src/chat/repositories/label.repository.ts @@ -28,10 +28,10 @@ export class LabelRepository extends BaseRepository< LabelFull > { constructor( + readonly eventEmitter: EventEmitter2, @InjectModel(Label.name) readonly model: Model