fix(redis): bypass ioredis minor version type mismatch and refactor scheduler

apps/api/src/services/queue.ts

@@ -12,7 +12,7 @@ const connection = process.env.REDIS_URL
         maxRetriesPerRequest: null
     });
 
-export const whatsappQueue = new Queue('whatsapp-queue', { connection });
+export const whatsappQueue = new Queue('whatsapp-queue', { connection: connection as any });
 
 export async function scheduleMessage(userId: string, text: string, delayMs: number = 0) {
     await whatsappQueue.add('send-message', {

apps/whatsapp-worker/src/index.ts

@@ -185,7 +185,7 @@ const worker = new Worker('whatsapp-queue', async (job: Job) => {
         console.error(`Job ${job.id} failed:`, error);
         throw error;
     }
-}, { connection });
+}, { connection: connection as any });
 
 console.log('WhatsApp Worker started...');
 

apps/whatsapp-worker/src/scheduler.ts

@@ -3,12 +3,20 @@ import { Queue } from 'bullmq';
 import { PrismaClient } from '@prisma/client';
 
 const prisma = new PrismaClient();
-const connection = {
-    host: process.env.REDIS_HOST || 'localhost',
-    port: parseInt(process.env.REDIS_PORT || '6379'),
-};
+import Redis from 'ioredis';
+
+const connection = process.env.REDIS_URL
+    ? new Redis(process.env.REDIS_URL, { maxRetriesPerRequest: null })
+    : new Redis({
+        host: process.env.REDIS_HOST || 'localhost',
+        port: parseInt(process.env.REDIS_PORT || '6379'),
+        username: process.env.REDIS_USERNAME || 'default',
+        password: process.env.REDIS_PASSWORD || undefined,
+        tls: process.env.REDIS_TLS === 'true' ? {} : undefined,
+        maxRetriesPerRequest: null
+    });
 
-const whatsappQueue = new Queue('whatsapp-queue', { connection });
+const whatsappQueue = new Queue('whatsapp-queue', { connection: connection as any });
 
 export function startDailyScheduler() {
     // Runs at 08:00 AM every day