Trigger ci/cd

Author: codeMaverick7770

server/utils/redisClient.js

@@ -2,31 +2,55 @@ import { createClient } from 'redis';
 import dotenv from 'dotenv';
 dotenv.config();
 
+const REDIS_URL = process.env.REDIS_URL || 'redis://localhost:6379';
+
 const redisClient = createClient({
-  url: process.env.REDIS_URL || 'redis://127.0.0.1:6379',
+  url: REDIS_URL,
   socket: {
-    reconnectStrategy: retries => Math.min(retries * 50, 2000),
+    reconnectStrategy: retries => {
+      console.warn(`🔁 Redis reconnect attempt #${retries}`);
+      return Math.min(retries * 100, 3000); // retry with backoff
+    },
   },
 });
 
-redisClient.on('error', err => console.error('❌ Redis Client Error:', err));
-redisClient.on('connect', () => console.log('✅ Redis connected'));
-redisClient.on('reconnecting', () => console.log('♻️ Redis reconnecting...'));
+redisClient.on('error', err => {
+  console.error('❌ Redis Client Error:', err.message);
+});
+
+redisClient.on('connect', () => {
+  console.log('✅ Redis connected');
+});
+
+redisClient.on('ready', () => {
+  console.log('🟢 Redis ready');
+});
+
+redisClient.on('reconnecting', () => {
+  console.log('🔄 Redis reconnecting...');
+});
 
 const connectWithRetry = async (retries = 5) => {
-  while (retries) {
+  while (retries > 0) {
     try {
       await redisClient.connect();
-      console.log('✅ Connected to Redis');
+      console.log('🚀 Redis connection established');
       return redisClient;
     } catch (err) {
-      console.error('⏳ Redis connection failed, retrying in 3s...');
+      console.error(`⏳ Redis connection failed: ${err.message}`);
       retries--;
       await new Promise(res => setTimeout(res, 3000));
     }
   }
-  throw new Error('❌ Could not connect to Redis after retries');
+  throw new Error('❌ Redis not reachable after multiple attempts');
 };
 
 await connectWithRetry();
+
+process.on('SIGINT', async () => {
+  await redisClient.quit();
+  console.log('👋 Redis client closed');
+  process.exit(0);
+});
+
 export default redisClient;