Merge pull request #79 from yatin166/refactor-cache-drivers

refactor(core): added storekey for consistency in cache driver

Author: vinayak25

packages/core/lib/cache/drivers/dice-db.ts

@@ -11,7 +11,7 @@ export class DiceDbDriver implements CacheDriver {
 
   async get(key: string): Promise<any> {
     await this.initializeModules();
-    const value = await this.client.get(`${this.options.prefix}:::${key}`);
+    const value = await this.client.get(this.storeKey(key));
     if (!value) return null;
     try {
       return JSON.parse(value);
@@ -27,7 +27,7 @@ export class DiceDbDriver implements CacheDriver {
   ): Promise<boolean> {
     await this.initializeModules();
     try {
-      const redisKey = `${this.options.prefix}:::${key}`;
+      const redisKey = this.storeKey(key);
       ttlInSec
         ? await this.client.set(redisKey, JSON.stringify(value), 'EX', ttlInSec)
         : await this.client.set(redisKey, JSON.stringify(value));
@@ -39,7 +39,7 @@ export class DiceDbDriver implements CacheDriver {
 
   async has(key: string): Promise<boolean> {
     await this.initializeModules();
-    const num = await this.client.exists(`${this.options.prefix}:::${key}`);
+    const num = await this.client.exists(this.storeKey(key));
     return !!num;
   }
 

packages/core/lib/cache/drivers/inMemory.ts

@@ -11,7 +11,7 @@ export class InMemoryDriver implements CacheDriver {
 
   async get<T>(key: string): Promise<T> {
     await this.initialiseModules();
-    const value = await this.client.get(`${this.options.prefix}:::${key}`);
+    const value = await this.client.get(this.storeKey(key));
     if (!value) return null;
     try {
       return JSON.parse(value);
@@ -26,7 +26,7 @@ export class InMemoryDriver implements CacheDriver {
     ttlInSec?: number | undefined,
   ): Promise<boolean> {
     await this.initialiseModules();
-    const cacheKey = `${this.options.prefix}:::${key}`;
+    const cacheKey = this.storeKey(key);
 
     if (ttlInSec) {
       return this.client.set(cacheKey, value, ttlInSec);
@@ -37,7 +37,7 @@ export class InMemoryDriver implements CacheDriver {
 
   async has(key: string): Promise<boolean> {
     await this.initialiseModules();
-    const cacheKey = `${this.options.prefix}:::${key}`;
+    const cacheKey = this.storeKey(key);
     return this.client.has(cacheKey);
   }
 
@@ -75,14 +75,18 @@ export class InMemoryDriver implements CacheDriver {
   async forget(key: string): Promise<boolean> {
     await this.initialiseModules();
     try {
-      const cacheKey = `${this.options.prefix}:::${key}`;
+      const cacheKey = this.storeKey(key);
       await this.client.del(cacheKey);
       return true;
     } catch {
       return false;
     }
   }
 
+  private storeKey(key: string): string {
+    return `${this.options.prefix}:::${key}`;
+  }
+
   getClient<T>(): T {
     return this.client as unknown as T;
   }

packages/core/lib/cache/drivers/redis.ts

@@ -12,7 +12,7 @@ export class RedisDriver implements CacheDriver {
 
   async get(key: string): Promise<any> {
     await this.initializeModules();
-    const value = await this.client.get(`${this.options.prefix}:::${key}`);
+    const value = await this.client.get(this.storeKey(key));
     if (!value) return null;
     try {
       return JSON.parse(value);
@@ -28,7 +28,7 @@ export class RedisDriver implements CacheDriver {
   ): Promise<boolean> {
     await this.initializeModules();
     try {
-      const redisKey = `${this.options.prefix}:::${key}`;
+      const redisKey = this.storeKey(key);
       ttlInSec
         ? await this.client.set(redisKey, JSON.stringify(value), 'EX', ttlInSec)
         : await this.client.set(redisKey, JSON.stringify(value));
@@ -40,7 +40,7 @@ export class RedisDriver implements CacheDriver {
 
   async has(key: string): Promise<boolean> {
     await this.initializeModules();
-    const num = await this.client.exists(`${this.options.prefix}:::${key}`);
+    const num = await this.client.exists(this.storeKey(key));
     return !!num;
   }