From 44de2aeaa9dfd1568bae8abff72a02173dda6498 Mon Sep 17 00:00:00 2001
From: pradeepkumar <kongupradeep@live.com>
Date: Tue, 7 Apr 2026 11:48:27 +0530
Subject: [PATCH] fix

---
 src/common/adapters/redis-io.adapter.ts | 10 ++++++++--
 src/common/redis/redis.provider.ts      | 11 ++++++++---
 2 files changed, 16 insertions(+), 5 deletions(-)

diff --git a/src/common/adapters/redis-io.adapter.ts b/src/common/adapters/redis-io.adapter.ts
index d0564a1..1ffb8d5 100644
--- a/src/common/adapters/redis-io.adapter.ts
+++ b/src/common/adapters/redis-io.adapter.ts
@@ -21,9 +21,15 @@ export class RedisIoAdapter extends IoAdapter {
     const port = this.configService.get<number>('redis.port', 6379);
     const password = this.configService.get<string>('redis.password') || undefined;
     const db = this.configService.get<number>('redis.db', 0);
+    const useTls = process.env.REDIS_TLS === 'true';
 
-    const pubClient = new Redis({ host, port, password, db });
-    const subClient = new Redis({ host, port, password, db });
+    const opts: any = { host, port, password, db };
+    if (useTls) {
+      opts.tls = { rejectUnauthorized: false };
+    }
+
+    const pubClient = new Redis(opts);
+    const subClient = new Redis(opts);
 
     pubClient.on('error', (err) => this.logger.error(`Redis pub error: ${err.message}`));
     subClient.on('error', (err) => this.logger.error(`Redis sub error: ${err.message}`));
diff --git a/src/common/redis/redis.provider.ts b/src/common/redis/redis.provider.ts
index a5e834f..9d982ca 100644
--- a/src/common/redis/redis.provider.ts
+++ b/src/common/redis/redis.provider.ts
@@ -6,16 +6,21 @@ export const REDIS_CLIENT = 'REDIS_CLIENT';
 export const redisProvider = {
   provide: REDIS_CLIENT,
   useFactory: (configService: ConfigService) => {
-    const client = new Redis({
+    const useTls = process.env.REDIS_TLS === 'true';
+    const opts: any = {
       host: configService.get<string>('redis.host', 'localhost'),
       port: configService.get<number>('redis.port', 6379),
       password: configService.get<string>('redis.password') || undefined,
       db: configService.get<number>('redis.db', 0),
       retryStrategy: (times: number) => {
-        if (times > 10) return null; // Stop retrying after 10 attempts
+        if (times > 10) return null;
         return Math.min(times * 200, 2000);
       },
-    });
+    };
+    if (useTls) {
+      opts.tls = { rejectUnauthorized: false };
+    }
+    const client = new Redis(opts);
 
     client.on('connect', () => {
       console.log('[Redis] Client connected');