changes to src/client.ts

src/client.ts

@@ -16,16 +16,34 @@ const client = new Client({
     ]
 })
 
-export const redis = createClient({
+// Create Redis client
+const redis = createClient({
   url: `redis://${Keys.redisHost}:${Keys.redisPort}`,
   socket: {
-    reconnectStrategy: (retries) => Math.min(retries * 100, 3000),
+    reconnectStrategy: (retries) => Math.min(retries * 100, 3000), // Retry every 100ms, max 3s
   },
 });
 
+// Log connection events
 redis.on('error', (err) => console.log(`Redis error: ${err}`));
 redis.on('connect', () => console.log('Redis connected'));
-redis.connect().catch((err) => console.log(`Redis connection failed: ${err}`));
+redis.on('ready', () => console.log('Redis ready'));
+
+// Connect only if not already connected
+async function ensureConnected() {
+  if (!redis.isOpen) {
+    try {
+      await redis.connect();
+    } catch (err) {
+      console.log(`Redis connection failed: ${err}`);
+    }
+  }
+}
+
+// Call ensureConnected on import
+ensureConnected().catch((err) => console.log(`Initial Redis connection failed: ${err}`));
+
+export { redis };
 
 // Initialize Ollama connection
 export const ollama = new Ollama({