diff --git a/scripts/run-queue-worker.ts b/scripts/run-queue-worker.ts index 207889a..552ab9c 100644 --- a/scripts/run-queue-worker.ts +++ b/scripts/run-queue-worker.ts @@ -32,6 +32,7 @@ async function main() { const { startEmailWorker, stopEmailWorker } = await import('../src/lib/queue/workers/email-worker') const { startPdfWorker, stopPdfWorker } = await import('../src/lib/queue/workers/pdf-worker') const { startRetentionWorker, stopRetentionWorker } = await import('../src/lib/queue/workers/retention-worker') + const { startYouTubeUploadWorker, stopYouTubeUploadWorker } = await import('../src/lib/queue/workers/youtube-upload-worker') const { scheduleRetentionJobs } = await import('../src/lib/queue/jobs/retention-job') const { retentionSchedule } = await import('../src/lib/retention/retention-config') @@ -40,6 +41,7 @@ async function main() { const ENABLE_PDF_WORKER = process.env.QUEUE_ENABLE_PDF !== 'false' const ENABLE_RETENTION_WORKER = process.env.QUEUE_ENABLE_RETENTION !== 'false' const ENABLE_RETENTION_SCHEDULER = process.env.QUEUE_ENABLE_RETENTION_SCHEDULER !== 'false' + const ENABLE_YOUTUBE_UPLOAD_WORKER = process.env.QUEUE_ENABLE_YOUTUBE_UPLOAD !== 'false' console.log('='.repeat(50)) console.log('[QueueRunner] Starting queue workers...') @@ -49,6 +51,7 @@ async function main() { console.log(`[QueueRunner] PDF Worker: ${ENABLE_PDF_WORKER ? 'enabled' : 'disabled'}`) console.log(`[QueueRunner] Retention Worker: ${ENABLE_RETENTION_WORKER ? 'enabled' : 'disabled'}`) console.log(`[QueueRunner] Retention Scheduler: ${ENABLE_RETENTION_SCHEDULER ? 'enabled' : 'disabled'}`) + console.log(`[QueueRunner] YouTube Upload Worker: ${ENABLE_YOUTUBE_UPLOAD_WORKER ? 'enabled' : 'disabled'}`) console.log('='.repeat(50)) // Workers starten @@ -71,6 +74,10 @@ async function main() { } } + if (ENABLE_YOUTUBE_UPLOAD_WORKER) { + startYouTubeUploadWorker() + } + // Graceful Shutdown async function shutdown(signal: string) { console.log(`\n[QueueRunner] Received ${signal}, shutting down gracefully...`) @@ -87,6 +94,9 @@ async function main() { if (ENABLE_RETENTION_WORKER) { stopPromises.push(stopRetentionWorker()) } + if (ENABLE_YOUTUBE_UPLOAD_WORKER) { + stopPromises.push(stopYouTubeUploadWorker()) + } await Promise.all(stopPromises) console.log('[QueueRunner] All workers stopped')