import { WorkerHost } from "@nestjs/bullmq"; import { Job } from "bullmq"; import { ClsService } from "nestjs-cls"; import { CreditValidatorInterface } from "../../../common/tokens"; import { AppLoggingService } from "../../../core/logging/services/logging.service"; import { WebSocketService } from "../../../core/websocket/services/websocket.service"; import { CommunityRepository } from "../../../foundations/community/repositories/community.repository"; import { CommunitySummariserService } from "../services/community.summariser.service"; interface CommunitySummariserJobData { communityId: string; companyId: string; } export declare class CommunitySummariserProcessor extends WorkerHost { private readonly summariserService; private readonly cls; private readonly logger; private readonly communityRepository; private readonly webSocketService; /** See ChunkProcessor: seam, not CompanyService — CompanyModule would mount `companies/*` here. */ private readonly creditValidator?; constructor(summariserService: CommunitySummariserService, cls: ClsService, logger: AppLoggingService, communityRepository: CommunityRepository, webSocketService: WebSocketService, /** See ChunkProcessor: seam, not CompanyService — CompanyModule would mount `companies/*` here. */ creditValidator?: CreditValidatorInterface); onActive(job: Job): void; onError(job: Job): void; onCompleted(job: Job): void; process(job: Job): Promise; } export {}; //# sourceMappingURL=community.summariser.processor.d.ts.map