Merge pull request #239 from Digital-Engineering/bugfix/redis

fixed bad args

src/services/cache/cache.ts

@@ -102,7 +102,7 @@ export class MemoryCacheImpl implements CacheInterface {
     }
     flushByPattern(pattern: string): Promise<boolean> {
         // in the case of memory cache, this method is the same as flush
-        return this.flush()
+        return this.flush();
     }
 
     constructor(emitter: EventEmitter) {
@@ -181,25 +181,27 @@ export class RedisCacheImpl implements CacheInterface {
         // wrapping this in a promise, that way it won't return before stream is complete
         return new Promise((resolve) => {
             stream.on('data', async (keys: string[]) => {
-                const deleted = await this._redis.del(keys);
-
-                // deleted returns an integer indicating how many objects were
-                // deleted. If this does not match the length of objects found,
-                // throw an error
-                if (deleted !== keys.length) {
-                    Logger.error(`error deleting value(s) from redis: ${deleted}`)
-                    resolve(false)
+                if (keys.length > 0) {
+                    const deleted = await this._redis.del(keys);
+
+                    // deleted returns an integer indicating how many objects were
+                    // deleted. If this does not match the length of objects found,
+                    // throw an error
+                    if (deleted !== keys.length) {
+                        Logger.error(`error deleting value(s) from redis: ${deleted}`);
+                        resolve(false);
+                    }
                 }
             });
 
             stream.on('error', (e: Error) => {
                 Logger.error(`error deleting value(s) from redis: ${e}`);
-                resolve(false)
-            })
+                resolve(false);
+            });
 
             stream.on('end', () => {
                 this._emitter.emit('flushed');
-                resolve(true)
+                resolve(true);
             });
         });
     }