Spaces:
Running
Running
File size: 3,437 Bytes
9f29339 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 | "use strict";
var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
return c > 3 && r && Object.defineProperty(target, key, r), r;
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.QueueModule = void 0;
const common_1 = require("@nestjs/common");
const bullmq_1 = require("@nestjs/bullmq");
const outreach_processor_1 = require("./outreach.processor");
const content_processor_1 = require("./content.processor");
const post_interview_processor_1 = require("./post-interview.processor");
const notification_processor_1 = require("./notification.processor");
const clip_scoring_processor_1 = require("./clip-scoring.processor");
const clip_scoring_listener_1 = require("./clip-scoring.listener");
const workers_1 = require("./workers");
const verification_processor_1 = require("./verification.processor");
const workspace_verification_module_1 = require("../verification/workspace-verification.module");
const prisma_module_1 = require("../prisma/prisma.module");
const ai_module_1 = require("../ai/ai.module");
const export_module_1 = require("../common/export/export.module");
const websocket_module_1 = require("../websocket/websocket.module");
const email_module_1 = require("../email/email.module");
const notifications_module_1 = require("../notifications/notifications.module");
let QueueModule = class QueueModule {
};
exports.QueueModule = QueueModule;
exports.QueueModule = QueueModule = __decorate([
(0, common_1.Module)({
imports: [
prisma_module_1.PrismaModule,
ai_module_1.AIModule,
export_module_1.ExportModule,
websocket_module_1.WebsocketModule,
email_module_1.EmailModule,
notifications_module_1.NotificationsModule,
bullmq_1.BullModule.registerQueue({ name: "outreach" }, { name: "content" }, { name: "notifications" }, { name: "analytics" }, { name: "network" }, { name: "post-interview" }, { name: "clip-scoring" }, { name: workers_1.QUEUE_NAMES.EMAIL }, { name: workers_1.QUEUE_NAMES.REMINDER }, { name: workers_1.QUEUE_NAMES.ASSET_PROCESSING }, { name: workers_1.QUEUE_NAMES.OUTREACH_AUTOMATION }, { name: "verification" }, { name: "admin-supervision" }),
workspace_verification_module_1.WorkspaceVerificationModule,
],
providers: [
outreach_processor_1.OutreachProcessor,
content_processor_1.ContentProcessor,
post_interview_processor_1.PostInterviewProcessor,
notification_processor_1.NotificationProcessor,
clip_scoring_processor_1.ClipScoringProcessor,
clip_scoring_listener_1.ClipScoringListener,
workers_1.EmailWorker,
workers_1.ReminderWorker,
workers_1.AssetProcessingWorker,
workers_1.OutreachAutomationWorker,
verification_processor_1.VerificationProcessor,
],
exports: [bullmq_1.BullModule],
})
], QueueModule);
//# sourceMappingURL=queue.module.js.map |