apps/api/src/valkey/valkey.service.spec.ts

@@ -24,6 +24,10 @@ vi.mock("ioredis", () => {
       return this;
     }
 
+    removeAllListeners() {
+      return this;
+    }
+
     // String operations
     async setex(key: string, ttl: number, value: string) {
       store.set(key, value);

apps/api/src/valkey/valkey.service.ts

@@ -63,8 +63,10 @@ export class ValkeyService implements OnModuleInit, OnModuleDestroy {
     }
   }
 
-  async onModuleDestroy() {
+  async onModuleDestroy(): Promise<void> {
     this.logger.log("Disconnecting from Valkey");
+    // Remove all event listeners to prevent memory leaks
+    this.client.removeAllListeners();
     await this.client.quit();
   }