From e6ef78a08a50f65ff9ff27489f59468b94c2fbcd Mon Sep 17 00:00:00 2001
From: Martin Porwoll <martin.porwoll@complexcaresolutions.de>
Date: Sat, 14 Feb 2026 13:33:52 +0000
Subject: [PATCH] feat(youtube): register upload worker in queue startup

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
---
 scripts/run-queue-worker.ts | 10 ++++++++++
 1 file changed, 10 insertions(+)

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')