fix: remove safe rwrapper over redis client instance

Author: SerhiyGreench

src/RedisQueue.ts

@@ -34,13 +34,11 @@ import {
     ILogger,
     IMQMode,
     EventMap,
-    makeRedisSafe,
     buildOptions,
     profile,
     uuid,
 } from '.';
 import Redis from './redis';
-import { logger } from '../test/mocks';
 
 const RX_CLIENT_NAME = /name=(\S+)/g;
 const RX_CLIENT_TEST = /:(reader|writer|watcher)/;
@@ -806,12 +804,10 @@ export class RedisQueue extends EventEmitter<EventMap>
                 enableReadyCheck: true,
                 enableOfflineQueue: true,
                 autoResendUnfulfilledCommands: true,
+                offlineQueue: true,
             });
 
-            context[channel] = makeRedisSafe(
-                redis,
-                options.verbose ? options.logger : undefined,
-            );
+            context[channel] = redis;
             context[channel].__imq = true;
 
             for (const event of [

src/redis.ts

@@ -23,7 +23,6 @@
  */
 /* tslint:disable */
 import Redis from 'ioredis';
-import { ILogger } from './IMessageQueue';
 
 /**
  * Extends default Redis  type to allow dynamic properties access on it
@@ -35,40 +34,5 @@ export interface IRedisClient extends Redis {
     __imq?: boolean;
 }
 
-// istanbul ignore next
-export function makeRedisSafe(
-    redis: IRedisClient,
-    logger?: ILogger,
-): IRedisClient {
-    return new Proxy(redis, {
-        get(target, property, receiver) {
-            const original = Reflect.get(target, property, receiver);
-
-            if (typeof original === 'function') {
-                return async (...args: unknown[]) => {
-                    try {
-                        if (target.status !== 'ready') {
-                            logger?.warn(
-                                'Redis client is not ready yet, while ',
-                                `executing command: "${ String(property) }"`,
-                            );
-
-                            return null;
-                        }
-
-                        return await original.apply(target, args);
-                    } catch (err: unknown) {
-                        logger?.error(err);
-
-                        return null;
-                    }
-                };
-            }
-
-            return original;
-        },
-    });
-}
-
 export { Redis };
 export default Redis;