added new features

- fetch list members
- get client
- get ttl by key
- get/remove by pattern

__test__/redis-client/redis-client.service.spec.ts

@@ -38,10 +38,11 @@ describe('RedisClientService', () => {
   });
   describe('set/get value value', () => {
     const key = 'unit-test',
-      value = 'ok';
+      value = 'ok',
+      ttl = 120;
 
     it('should able to set key in redis', async () => {
-      expect(await redisClientService.setValue(key, value, 120)).toBe(true);
+      expect(await redisClientService.setValue(key, value, ttl)).toBe(true);
     });
 
     it('should be able to fetch value from redis', async () => {
@@ -52,6 +53,14 @@ describe('RedisClientService', () => {
       expect(await redisClientService.keys()).toStrictEqual([key]);
     });
 
+    it('should be able to fetch keys with pattern from redis', async () => {
+      expect(await redisClientService.getKeysWithPattern(`${key}*`)).toStrictEqual([key]);
+    });
+
+    it('should be able to fetch ttl from redis', async () => {
+      expect(await redisClientService.getTTL(key)).toBe(ttl);
+    });
+
     it('should be able to del key from redis', async () => {
       expect(await redisClientService.delValue(key)).toBeUndefined();
       expect(await redisClientService.getValue(key)).toBeUndefined();

package.json

@@ -1,6 +1,6 @@
 {
   "name": "nestjs-redis-connector",
-  "version": "1.0.3",
+  "version": "1.0.4",
   "description": "redis connector for NestJs based services",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

src/redis-client/redis-client.service.ts

@@ -10,7 +10,7 @@ export class RedisClientService implements OnModuleDestroy {
   constructor(@Inject(CACHE_MANAGER) private cache: Cache) {}
 
   redisClient() {
-    (this.cache.store as RedisStore).client;
+    return (this.cache.store as RedisStore).client;
   }
 
   onModuleDestroy() {
@@ -47,19 +47,27 @@ export class RedisClientService implements OnModuleDestroy {
   }
 
   async sadd(listName: string, member: string) {
-    (this.cache.store as RedisStore).client.sadd(listName, member);
+    this.redisClient().sadd(listName, member);
   }
 
   async srem(listName: string, member: string) {
-    (this.cache.store as RedisStore).client.srem(listName, member);
+    this.redisClient().srem(listName, member);
+  }
+
+  async smembers(listName: string): Promise<string[]> {
+    return this.redisClient().smembers(listName);
   }
 
   async reset(): Promise<void> {
     await this.cache.reset();
   }
 
-  async keys(): Promise<string[]> {
-    return this.cache.store.keys();
+  async keys(pattern?: string): Promise<string[]> {
+    return this.cache.store.keys(pattern);
+  }
+
+  async getKeysWithPattern(pattern: string): Promise<string[]> {
+    return this.keys(pattern);
   }
 
   async delValue(key: string): Promise<void> {
@@ -69,7 +77,14 @@ export class RedisClientService implements OnModuleDestroy {
   async delMValue(...key: string[]): Promise<void> {
     await this.cache.store.mdel(...key);
   }
+  async delValueWithPattern(key: string): Promise<any> {
+    const keys = await this.keys(key);
+    return this.delMValue(...keys);
+  }
+  async getTTL(key: string): Promise<any> {    
+    return await this.redisClient().ttl(key);
+  }
   disconnect(): void {
-    (this.cache.store as RedisStore).client.disconnect?.();
+    this.redisClient().disconnect?.();
   }
 }