feat: setExpiring for NocoCache

packages/nocodb/src/cache/CacheMgr.ts

@@ -1,6 +1,11 @@
 export default abstract class CacheMgr {
   public abstract get(key: string, type: string): Promise<any>;
   public abstract set(key: string, value: any): Promise<any>;
+  public abstract setExpiring(
+    key: string,
+    value: any,
+    seconds: number,
+  ): Promise<any>;
   public abstract del(key: string): Promise<any>;
   public abstract getAll(pattern: string): Promise<any[]>;
   public abstract delAll(scope: string, pattern: string): Promise<any[]>;

packages/nocodb/src/cache/NocoCache.ts

@@ -29,6 +29,15 @@ export default class NocoCache {
     return this.client.set(`${this.prefix}:${key}`, value);
   }
 
+  public static async setExpiring(key, value, expireSeconds): Promise<boolean> {
+    if (this.cacheDisabled) return Promise.resolve(true);
+    return this.client.setExpiring(
+      `${this.prefix}:${key}`,
+      value,
+      expireSeconds,
+    );
+  }
+
   public static async get(key, type): Promise<any> {
     if (this.cacheDisabled) {
       if (type === CacheGetType.TYPE_ARRAY) return Promise.resolve([]);

packages/nocodb/src/cache/RedisCacheMgr.ts

@@ -94,6 +94,30 @@ export default class RedisCacheMgr extends CacheMgr {
     }
   }
 
+  // @ts-ignore
+  async setExpiring(key: string, value: any, seconds: number): Promise<any> {
+    if (typeof value !== 'undefined' && value) {
+      log(
+        `RedisCacheMgr::set: setting key ${key} with value ${value} for ${seconds} seconds`,
+      );
+      if (typeof value === 'object') {
+        if (Array.isArray(value) && value.length) {
+          return this.client.sadd(key, value);
+        }
+        return this.client.set(
+          key,
+          JSON.stringify(value, this.getCircularReplacer()),
+          'EX',
+          seconds,
+        );
+      }
+      return this.client.set(key, value, 'EX', seconds);
+    } else {
+      log(`RedisCacheMgr::set: value is empty for ${key}. Skipping ...`);
+      return Promise.resolve(true);
+    }
+  }
+
   // @ts-ignore
   async getAll(pattern: string): Promise<any> {
     return this.client.hgetall(pattern);

packages/nocodb/src/cache/RedisMockCacheMgr.ts

@@ -89,6 +89,34 @@ export default class RedisMockCacheMgr extends CacheMgr {
     }
   }
 
+  // @ts-ignore
+  async setExpiring(key: string, value: any, seconds: number): Promise<any> {
+    if (typeof value !== 'undefined' && value) {
+      log(
+        `RedisMockCacheMgr::set: setting key ${key} with value ${value} for ${seconds} seconds`,
+      );
+
+      // TODO: better way to handle expiration in mock redis
+      setTimeout(() => {
+        this.del(key);
+      }, seconds * 1000);
+
+      if (typeof value === 'object') {
+        if (Array.isArray(value) && value.length) {
+          return this.client.sadd(key, value);
+        }
+        return this.client.set(
+          key,
+          JSON.stringify(value, this.getCircularReplacer()),
+        );
+      }
+      return this.client.set(key, value);
+    } else {
+      log(`RedisMockCacheMgr::set: value is empty for ${key}. Skipping ...`);
+      return Promise.resolve(true);
+    }
+  }
+
   // @ts-ignore
   async getAll(pattern: string): Promise<any> {
     return this.client.hgetall(pattern);