fix: cron module import & 메서드 호출 x 변경

Author: mintaek22

DBManager/src/active-user/active-user.service.ts

@@ -10,13 +10,12 @@ export class ActiveUserService implements OnModuleInit {
   onModuleInit() {
     this.countUp();
     this.countDown();
-    this.applyToRedis();
   }
 
   private countUp() {
     const channel = '__keyspace@1__:APPEND';
-    this.redisService.subscribeActiveUser(channel, async (sid) => {
-      const pod = await this.redisService.hgetSession(sid, 'pod');
+    this.redisService.subscribeActiveUser(channel, async (sessionId) => {
+      const pod = await this.redisService.hgetSession(sessionId, 'pod');
 
       const currentCount = this.activeUserVariation.get(pod) ?? 0;
       this.activeUserVariation.set(pod, currentCount + 1);
@@ -25,16 +24,16 @@ export class ActiveUserService implements OnModuleInit {
 
   private countDown() {
     const channel = '__keyspace@1__:EXPIRE';
-    this.redisService.subscribeActiveUser(channel, async (sid) => {
-      const pod = await this.redisService.hgetSession(sid, 'pod');
+    this.redisService.subscribeActiveUser(channel, async (sessionId) => {
+      const pod = await this.redisService.hgetSession(sessionId, 'pod');
 
       const currentCount = this.activeUserVariation.get(pod) ?? 0;
       this.activeUserVariation.set(pod, currentCount - 1);
     });
   }
 
   @Cron(CronExpression.EVERY_MINUTE)
-  private async applyToRedis() {
+  async applyToRedis() {
     for (const [pod, variation] of this.activeUserVariation.entries()) {
       const count = await this.redisService.hgetPod(pod, 'activeUser');
       const newCount = (count ? parseInt(count, 10) : 0) + variation;

DBManager/src/app.module.ts

@@ -2,12 +2,14 @@ import { Module } from '@nestjs/common';
 import { AppController } from './app.controller';
 import { KubernetesService } from './K8S/KubernetesService';
 import { ConfigModule } from '@nestjs/config';
+import { ScheduleModule } from '@nestjs/schedule';
 
 @Module({
   imports: [
     ConfigModule.forRoot({
       isGlobal: true,
     }),
+    ScheduleModule.forRoot(),
   ],
   controllers: [AppController],
   providers: [KubernetesService],