test: redis clustering

packages/server/src/redis/chart-redis.repository.ts

@@ -13,19 +13,20 @@ export class ChartRedisRepository {
 
   async getChartDate(keys: string[]): Promise<any[]> {
     try {
-      const promises = keys.map((key) => this.chartRedis.get(key));
-      const results = await Promise.all(promises);
-      return results.map((data) => (data ? JSON.parse(data) : null)).filter((data) => data !== null);
+      const results = await Promise.all(keys.map((key) => this.getSimpleChartData(key)));
+      return results.filter((data) => data !== false);
     } catch (error) {
       console.error('DB Searching Error:', error);
       throw error;
     }
   }
-
+  
   async getSimpleChartData(key) {
     const data = await this.chartRedis.get(key);
     if (!data) {
       return false;
-    } else return JSON.parse(data);
+    } else {
+      return JSON.parse(data);
+    }
   }
 }

packages/server/src/redis/redis.module.ts

@@ -38,11 +38,22 @@ import { ChartRedisRepository } from './chart-redis.repository';
       provide: 'CHART_REDIS_CLIENT',
       useFactory: () => {
         const config = getRedisConfig();
-        const client = new Redis({ ...config, db: 3 });
+        const client = new Redis.Cluster([
+          { host: 'node1-host', port: 6379 },
+          { host: 'node2-host', port: 6379 },
+          { host: 'node3-host', port: 6379 },
+          // Add more nodes as needed
+        ], {
+          scaleReads: 'all',
+          redisOptions: {
+            password: config.password,
+            db: 3
+          }
+        });
         const logger = new Logger('CHART_REDIS_CLIENT');
-        client.on('connect', () => logger.log('Chart용 Redis 연결 성공'));
+        client.on('connect', () => logger.log('Chart용 Redis 클러스터 연결 성공'));
         client.on('error', (error) =>
-          logger.error('Chart용 Redis 연결 실패:', error),
+          logger.error('Chart용 Redis 클러스터 연결 실패:', error),
         );
         return client;
       },