From c851bd9678951a146d4bbef88048e73932286cb6 Mon Sep 17 00:00:00 2001 From: maaz519 Date: Sat, 20 Jun 2026 13:30:48 +0530 Subject: [PATCH] fix: pass full REDIS_URL to streamRedis so password is included --- apps/worker/src/main.ts | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/apps/worker/src/main.ts b/apps/worker/src/main.ts index ec0c21d..11812c2 100644 --- a/apps/worker/src/main.ts +++ b/apps/worker/src/main.ts @@ -53,8 +53,7 @@ async function bootstrap() { const pool = new WhatsAppSessionPool(); // Dedicated Redis client for XADD stream writes (separate from BullMQ connections) - const { hostname, port } = new URL(env.REDIS_URL); - const streamRedis = new Redis({ host: hostname, port: parseInt(port || '6379', 10), maxRetriesPerRequest: null, lazyConnect: true }); + const streamRedis = new Redis(env.REDIS_URL, { maxRetriesPerRequest: null, lazyConnect: true }); await streamRedis.connect().catch((err) => logger.warn({ err }, 'Stream Redis connect failed — stream publish will be degraded')); const ingestWorker = createIngestWorker(env.REDIS_URL, prisma, pool, forwardQueue, indexQueue, streamRedis);