From 48332edaa2829dc05237bad3f320c1d0c14087c8 Mon Sep 17 00:00:00 2001 From: Claude Code Date: Sat, 4 Apr 2026 23:57:42 -0700 Subject: [PATCH] =?UTF-8?q?refactor(redis):=20=E2=99=BB=EF=B8=8F=20Restruc?= =?UTF-8?q?ture=20RedisPublisherService=20and=20RedisSessionService=20for?= =?UTF-8?q?=20cleaner=20organization=20and=20improved=20maintainability?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Lilith Autocommit --- services/processor/src/redis/redis-publisher.service.ts | 2 ++ services/processor/src/redis/redis-session.service.ts | 2 ++ 2 files changed, 4 insertions(+) diff --git a/services/processor/src/redis/redis-publisher.service.ts b/services/processor/src/redis/redis-publisher.service.ts index 0c037eb..94f9c19 100644 --- a/services/processor/src/redis/redis-publisher.service.ts +++ b/services/processor/src/redis/redis-publisher.service.ts @@ -30,10 +30,12 @@ export class RedisPublisherService implements OnModuleInit, OnModuleDestroy { async onModuleInit() { const host = this.config.get('REDIS_HOST', 'localhost'); const port = this.config.get('REDIS_PORT', 6379); + const password = this.config.get('REDIS_PASSWORD'); this.publisher = new Redis({ host, port, + ...(password ? { password } : {}), retryStrategy: (times) => { const delay = Math.min(times * 50, 2000); return delay; diff --git a/services/processor/src/redis/redis-session.service.ts b/services/processor/src/redis/redis-session.service.ts index 123f2d5..fa57f97 100644 --- a/services/processor/src/redis/redis-session.service.ts +++ b/services/processor/src/redis/redis-session.service.ts @@ -38,10 +38,12 @@ export class RedisSessionService implements OnModuleInit, OnModuleDestroy { async onModuleInit() { const host = this.config.get('REDIS_HOST', 'localhost'); const port = this.config.get('REDIS_PORT', 6379); + const password = this.config.get('REDIS_PASSWORD'); this.redis = new Redis({ host, port, + ...(password ? { password } : {}), retryStrategy: (times) => { const delay = Math.min(times * 50, 2000); return delay;