fix: adjust close connection redis

williamkoller · Apr 27, 2022 · 337712e · 337712e
1 parent 736191c
commit 337712e
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/src/modules/cache/cache.settings.ts b/src/modules/cache/cache.settings.ts
@@ -1,8 +1,10 @@
 import { CacheModule as BaseCacheModule } from '@nestjs/common';
 import { CachesRepository } from './repositories/caches.repository';
+import * as redisStore from 'cache-manager-redis-store';
 
 export const imports = [
   BaseCacheModule.register({
+    store: redisStore,
     url: process.env.REDIS_URL,
     isGlobal: true,
   }),

diff --git a/src/modules/cache/repositories/caches.repository.ts b/src/modules/cache/repositories/caches.repository.ts
@@ -1,14 +1,12 @@
 import { GET_BOOKS_CACHE_KEY } from '@/modules/cache/constants/books-cache-key.constant';
 import { CACHE_MANAGER, Inject, Injectable } from '@nestjs/common';
 
+import { Cache } from 'cache-manager';
+
 @Injectable()
 export class CachesRepository {
-  constructor(@Inject(CACHE_MANAGER) private readonly cacheManager) {
-    const client = cacheManager.store.getClient();
-    client.on('err', (err) => {
-      console.info(err);
-    });
-  }
+  constructor(@Inject(CACHE_MANAGER) private readonly cacheManager: Cache) {}
+
   async clearCache(): Promise<void> {
     const keys: string[] = await this.cacheManager.store.keys();
 
@@ -24,6 +22,6 @@ export class CachesRepository {
   }
 
   async getCache(name: string): Promise<number> {
-    return await this.cacheManager.get(name);
+    return await this.cacheManager.get<number>(name);
   }
 }