test

apps/data-service/src/providers/proxy.tasks.ts

@@ -115,7 +115,16 @@ async function initializeSharedResources() {
       ttl: PROXY_CONFIG.CACHE_TTL,
       enableMetrics: true
     });
-    await cache.waitForReady();
+    
+    try {
+      // Use longer timeout for cache connection
+      await cache.waitForReady(30000); // 30 seconds
+      logger.info('Cache connection established');
+    } catch (error) {
+      logger.error('Cache connection failed, continuing with degraded functionality:', error);
+      // Don't throw - allow the service to continue with cache fallbacks
+    }
+    
     httpClient = new HttpClient({ timeout: 10000 }, logger);
     concurrencyLimit = pLimit(PROXY_CONFIG.CONCURRENCY_LIMIT);
     logger.info('Proxy tasks initialized');

apps/data-service/src/utils/batch-processor.ts

@@ -324,7 +324,7 @@ export class BatchProcessor {
             operation: `process-${jobNamePrefix}-batch`,
             payload: {
               // Optimized: only store reference and metadata
-              payloadKey: payloadKey,
+              payloadKey: this.keyPrefix + payloadKey,
               batchIndex,
               total: totalBatches,
               itemCount: batchItems.length,

libs/cache/src/connection-manager.ts

@@ -67,7 +67,7 @@ export class RedisConnectionManager {
       commandTimeout: dragonflyConfig.DRAGONFLY_COMMAND_TIMEOUT,
       keepAlive: dragonflyConfig.DRAGONFLY_ENABLE_KEEPALIVE ? dragonflyConfig.DRAGONFLY_KEEPALIVE_INTERVAL * 1000 : 0,
       connectionName: name,
-      lazyConnect: true,
+      lazyConnect: false, // Connect immediately instead of waiting for first command
       ...(dragonflyConfig.DRAGONFLY_TLS && {
         tls: {
           cert: dragonflyConfig.DRAGONFLY_TLS_CERT_FILE || undefined,

libs/cache/src/redis-cache.ts

@@ -46,31 +46,32 @@ export class RedisCache implements CacheProvider {
   }
 
   private setupEventHandlers(): void {
-    this.redis.on('connect', () => {
-      this.logger.info('Redis cache connected');
-    });
+    // this.redis.on('connect', () => {
+    //   this.logger.info('Redis cache connected');
+    // });
 
-    this.redis.on('ready', () => {
-      this.isConnected = true;
-      this.logger.info('Redis cache ready');
-    });
+    // this.redis.on('ready', () => {
+    //   this.isConnected = true;
+    //   this.logger.info('Redis cache ready');
+    // });
 
-    this.redis.on('error', (error: any) => {
-      this.isConnected = false;
-      this.logger.error('Redis cache connection error', { error: error.message });
-    });
+    // this.redis.on('error', (error: any) => {
+    //   this.isConnected = false;
+    //   this.logger.error('Redis cache connection error', { error: error.message });
+    // });
 
-    this.redis.on('close', () => {
-      this.isConnected = false;
-      this.logger.warn('Redis cache connection closed');
-    });
+    // this.redis.on('close', () => {
+    //   this.isConnected = false;
+    //   this.logger.warn('Redis cache connection closed');
+    // });
 
-    this.redis.on('reconnecting', () => {
-      this.logger.info('Redis cache reconnecting...');
-    });
+    // this.redis.on('reconnecting', () => {
+    //   this.logger.info('Redis cache reconnecting...');
+    // });
   }
 
   private getKey(key: string): string {
+    console.log(`Using key prefix: ${this.keyPrefix}`);
     return `${this.keyPrefix}${key}`;
   }