feat: added extra logging to redis client

Author: SerhiyGreench

src/RedisQueue.ts

@@ -40,6 +40,7 @@ import {
     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)/;
@@ -807,7 +808,10 @@ export class RedisQueue extends EventEmitter<EventMap>
                 autoResendUnfulfilledCommands: true,
             });
 
-            context[channel] = makeRedisSafe(redis);
+            context[channel] = makeRedisSafe(
+                redis,
+                options.verbose ? options.logger : undefined,
+            );
             context[channel].__imq = true;
 
             for (const event of [

src/redis.ts

@@ -23,6 +23,7 @@
  */
 /* tslint:disable */
 import Redis from 'ioredis';
+import { ILogger } from './IMessageQueue';
 
 /**
  * Extends default Redis  type to allow dynamic properties access on it
@@ -35,7 +36,10 @@ export interface IRedisClient extends Redis {
 }
 
 // istanbul ignore next
-export function makeRedisSafe(redis: IRedisClient): IRedisClient {
+export function makeRedisSafe(
+    redis: IRedisClient,
+    logger?: ILogger,
+): IRedisClient {
     return new Proxy(redis, {
         get(target, property, receiver) {
             const original = Reflect.get(target, property, receiver);
@@ -44,11 +48,18 @@ export function makeRedisSafe(redis: IRedisClient): IRedisClient {
                 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;
                     }
                 };