Spaces:
Running
Running
| ; | |
| 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 |