fix: added @ladjs/redis

Author: niftylettuce

index.js

@@ -4,6 +4,7 @@ const http2 = require('spdy');
 const Cabin = require('cabin');
 const I18N = require('@ladjs/i18n');
 const Koa = require('koa');
+const Redis = require('@ladjs/redis');
 const StoreIPAddress = require('@ladjs/store-ip-address');
 const Timeout = require('koa-better-timeout');
 const _ = require('lodash');
@@ -48,6 +49,13 @@ class API {
     // initialize the app
     const app = new Koa();
 
+    // initialize redis
+    const client = new Redis(
+      this.config.redis,
+      logger,
+      this.config.redisMonitor
+    );
+
     // store the server initialization
     // so that we can gracefully exit
     // later on with `server.close()`
@@ -57,51 +65,6 @@ class API {
     app.on('error', (err, ctx) => ctx.logger.error(err));
     app.on('log', logger.log);
 
-    // check if we've binded _any_ events otherwise
-    // bind all normal events and assume we use the default
-    // <https://github.com/luin/ioredis#events>
-    const client = this.config.redisClient;
-    // go through each event listener type for ioredis and check
-    // if we've binded any listeners already
-    // <https://nodejs.org/api/events.html#events_emitter_listeners_eventname>
-    const listeners = [
-      'connect',
-      'ready',
-      'error',
-      'close',
-      'reconnecting',
-      'end',
-      '+node',
-      '-node',
-      'node error'
-    ];
-    let bindListeners = true;
-    for (let i = 0; i < listeners.length; i++) {
-      if (client.listeners(listeners[i]).length > 0) {
-        bindListeners = false;
-        break;
-      }
-    }
-
-    if (bindListeners) {
-      client.on('connect', () =>
-        app.emit('log', 'debug', 'redis connection established')
-      );
-      client.on('ready', () =>
-        app.emit('log', 'debug', 'redis connection ready')
-      );
-      client.on('error', err => app.emit('error', err));
-      client.on('close', () =>
-        app.emit('log', 'debug', 'redis connection closed')
-      );
-      client.on('reconnecting', () =>
-        app.emit('log', 'debug', 'redis reconnecting')
-      );
-      client.on('end', () =>
-        app.emit('log', 'debug', 'redis connection ended')
-      );
-    }
-
     // only trust proxy if enabled
     app.proxy = boolean(process.env.TRUST_PROXY);
 

package.json

@@ -22,7 +22,8 @@
   "dependencies": {
     "@koa/router": "^8.0.1",
     "@ladjs/i18n": "^1.2.1",
-    "@ladjs/shared-config": "^0.0.4",
+    "@ladjs/redis": "^1.0.2",
+    "@ladjs/shared-config": "^0.0.7",
     "@ladjs/store-ip-address": "^0.0.6",
     "boolean": "^1.0.0",
     "cabin": "^5.0.1",

yarn.lock

@@ -453,13 +453,20 @@
     qs "^6.8.0"
     titleize "^2.1.0"
 
-"@ladjs/shared-config@^0.0.4":
-  version "0.0.4"
-  resolved "https://registry.yarnpkg.com/@ladjs/shared-config/-/shared-config-0.0.4.tgz#5b202e248d5f076471c247f3376821eeef18ba3a"
-  integrity sha512-uSJkPu6jE/fafvFP9J2mCkYacqNrTI8bR9az35wqQSY7/2GMWRRw52zVCYRTzwc5mH3VvV5l0uW+jf9VnSB3eA==
+"@ladjs/redis@^1.0.2":
+  version "1.0.2"
+  resolved "https://registry.yarnpkg.com/@ladjs/redis/-/redis-1.0.2.tgz#04dcfcd96606375927e0a07f3b088e33da27d1bc"
+  integrity sha512-B7SYfjj0GRfQ8R7I+dvGY0Xk9NHoxEgoxC83vQUFHFWsWxIOh4R2bBKxopba+/7I+NX7GQxZVMYmAlrn7ajJNg==
   dependencies:
     ioredis "^4.14.0"
 
+"@ladjs/shared-config@^0.0.7":
+  version "0.0.7"
+  resolved "https://registry.yarnpkg.com/@ladjs/shared-config/-/shared-config-0.0.7.tgz#85cf61a38aebdbd57a8487edddc899e27baae1fc"
+  integrity sha512-FI2jEwLLx+ZhZ527R7/+UhxaICoC0a3faK9/ydlaBsj6UXq+0J9DvQwPzfUBsgXKc4LXtU/UYmIDW07pzRVXqg==
+  dependencies:
+    boolean "^1.0.0"
+
 "@ladjs/store-ip-address@^0.0.6":
   version "0.0.6"
   resolved "https://registry.yarnpkg.com/@ladjs/store-ip-address/-/store-ip-address-0.0.6.tgz#1cf863b00e076a797117dd33b848141afd52d300"