maaz519/tower
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: pass full REDIS_URL to streamRedis so password is included

Browse Source
This commit is contained in:
Maaz Ahamed
2026-06-20 13:30:48 +05:30
parent 530f81416a
commit c851bd9678
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/worker/src/main.ts
+1 -2
View File
@@ -53,8 +53,7 @@ async function bootstrap() {
const pool = new WhatsAppSessionPool(); const pool = new WhatsAppSessionPool();
// Dedicated Redis client for XADD stream writes (separate from BullMQ connections) // Dedicated Redis client for XADD stream writes (separate from BullMQ connections)
const { hostname, port } = new URL(env.REDIS_URL); const streamRedis = new Redis(env.REDIS_URL, { maxRetriesPerRequest: null, lazyConnect: true });
const streamRedis = new Redis({ host: hostname, port: parseInt(port || '6379', 10), maxRetriesPerRequest: null, lazyConnect: true });
await streamRedis.connect().catch((err) => logger.warn({ err }, 'Stream Redis connect failed — stream publish will be degraded')); 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); const ingestWorker = createIngestWorker(env.REDIS_URL, prisma, pool, forwardQueue, indexQueue, streamRedis);