diff --git a/lib/redis.ts b/lib/redis.ts index 99366763..9bd659d2 100644 --- a/lib/redis.ts +++ b/lib/redis.ts @@ -9,17 +9,21 @@ let redisClient: Redis | null = null; */ export function getRedisClient(): Redis { if (!redisClient) { - // Let IoRedis read from environment variables automatically - // It will read REDIS_URL, REDIS_HOST, REDIS_PORT, REDIS_PASSWORD, etc. - redisClient = new Redis({ - retryStrategy: (times) => { - // Exponential backoff with cap + // Set Redis connection parameters from environment variables only + const redisOptions = { + host: process.env.REDIS_HOST, + port: process.env.REDIS_PORT ? parseInt(process.env.REDIS_PORT) : undefined, + password: process.env.REDIS_PASSWORD, + retryStrategy: (times: number) => { const delay = Math.min(times * 100, 5000); return delay; }, maxRetriesPerRequest: 5, enableOfflineQueue: true - }); + }; + + console.log('Connecting to Redis using environment variables'); + redisClient = new Redis(redisOptions); redisClient.on('error', (err) => { console.error('Redis connection error:', err);