fix(redis): add missing prefix checks

gibsonjoshua55 · gibsonjoshua55 · commit 8124c7cd89be · 2021-01-27T11:18:59.000-05:00
diff --git a/src/modules/services/redis/redis.service.ts b/src/modules/services/redis/redis.service.ts
@@ -68,7 +68,7 @@ export class RedisService {
                     }
                 );
             } else {
-                this.client.connection.set(`${this.keyPrefix}${key}`, JSON.stringify(value), (err, response) => {
+                this.client.connection.set(`${ignorePrefix ? '' : this.keyPrefix}${key}`, JSON.stringify(value), (err, response) => {
                     if (err) {
                         return reject(err);
                     }
@@ -82,7 +82,7 @@ export class RedisService {
         if (Array.isArray(key)) {
             key = key.map(individualKey => ignorePrefix ? '' : this.keyPrefix + individualKey);
         } else {
-            key = `${this.keyPrefix}${key}`;
+            key = `${ignorePrefix ? '' : this.keyPrefix}${key}`;
         }
         try {
             await this.client.connection.del(key);

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ export class RedisService {`
`68`	`68`	`}`
`69`	`69`	`);`
`70`	`70`	`} else {`
`71`		- this.client.connection.set(`${this.keyPrefix}${key}`, JSON.stringify(value), (err, response) => {
	`71`	+ this.client.connection.set(`${ignorePrefix ? '' : this.keyPrefix}${key}`, JSON.stringify(value), (err, response) => {
`72`	`72`	`if (err) {`
`73`	`73`	`return reject(err);`
`74`	`74`	`}`
`@@ -82,7 +82,7 @@ export class RedisService {`
`82`	`82`	`if (Array.isArray(key)) {`
`83`	`83`	`key = key.map(individualKey => ignorePrefix ? '' : this.keyPrefix + individualKey);`
`84`	`84`	`} else {`
`85`		- key = `${this.keyPrefix}${key}`;
	`85`	+ key = `${ignorePrefix ? '' : this.keyPrefix}${key}`;
`86`	`86`	`}`
`87`	`87`	`try {`
`88`	`88`	`await this.client.connection.del(key);`