fix: expose monitor as client._monitor, bind events as well

Author: niftylettuce

index.js

@@ -7,16 +7,36 @@ function getMeta(client) {
   };
 }
 
+function bindEvents(client, logger) {
+  client.on('connect', () =>
+    logger.debug('redis connection established', getMeta(client))
+  );
+  client.on('ready', () =>
+    logger.debug('redis connection ready', getMeta(client))
+  );
+  client.on('error', err => logger.error(err, getMeta(client)));
+  client.on('close', () =>
+    logger.debug('redis connection closed', getMeta(client))
+  );
+  client.on('reconnecting', () =>
+    logger.debug('redis reconnecting', getMeta(client))
+  );
+  client.on('end', () =>
+    logger.debug('redis conection ended', getMeta(client))
+  );
+}
+
 function Redis(config = {}, logger = console, monitor = false) {
   const client = new IORedis(config);
   // https://github.com/luin/ioredis#monitor
   if (monitor) {
     client.monitor((err, monitor) => {
       if (err) return logger.error(err, getMeta(client));
-      logger.debug('redis monitor established', {
+      logger.debug('redis monitor instance created', {
         ...getMeta(client),
         monitor
       });
+      client._monitor = monitor;
       monitor.on('monitor', (time, args, source, database) =>
         logger.debug('redis monitor', {
           ...getMeta(client),
@@ -26,25 +46,11 @@ function Redis(config = {}, logger = console, monitor = false) {
           database
         })
       );
+      bindEvents(monitor, logger);
     });
   }
 
-  client.on('connect', () =>
-    logger.debug('redis connection established', getMeta(client))
-  );
-  client.on('ready', () =>
-    logger.debug('redis connection ready', getMeta(client))
-  );
-  client.on('error', err => logger.error(err, getMeta(client)));
-  client.on('close', () =>
-    logger.debug('redis connection closed', getMeta(client))
-  );
-  client.on('reconnecting', () =>
-    logger.debug('redis reconnecting', getMeta(client))
-  );
-  client.on('end', () =>
-    logger.debug('redis conection ended', getMeta(client))
-  );
+  bindEvents(client);
   return client;
 }