tj

igirl-channel/app/base/utils/redisClient.js

@@ -7,30 +7,57 @@ bluebird.promisifyAll(redis);
 class RedisClient {
   constructor() {
     const redisConfig = settings.redis();
-    this.client = redis.createClient({
-      host: redisConfig.host,
-      port: redisConfig.port,
-      password: redisConfig.password,
-      db: redisConfig.db,
-      retry_strategy: function (options) {
-        // if (options.error && options.error.code === 'ECONNREFUSED') {
-        //     // End reconnecting on a specific error and flush all commands with
-        //     // a individual error
-        //     return new Error('The server refused the connection');
-        // }
-        if (options.total_retry_time > 1000 * 60 * 60) {
-          // End reconnecting after a specific timeout and flush all commands
-          // with a individual error
-          return new Error('Retry time exhausted');
+    this.client = null;
+    if (!redisConfig.password) {
+      this.client = redis.createClient({
+        host: redisConfig.host,
+        port: redisConfig.port,
+        db: redisConfig.db,
+        retry_strategy: function (options) {
+          // if (options.error && options.error.code === 'ECONNREFUSED') {
+          //     // End reconnecting on a specific error and flush all commands with
+          //     // a individual error
+          //     return new Error('The server refused the connection');
+          // }
+          if (options.total_retry_time > 1000 * 60 * 60) {
+            // End reconnecting after a specific timeout and flush all commands
+            // with a individual error
+            return new Error('Retry time exhausted');
+          }
+          if (options.attempt > 10) {
+            // End reconnecting with built in error
+            return 10000;
+          }
+          // reconnect after
+          return Math.min(options.attempt * 100, 3000);
         }
-        if (options.attempt > 10) {
-          // End reconnecting with built in error
-          return 10000;
+      });
+    } else {
+      this.client = redis.createClient({
+        host: redisConfig.host,
+        port: redisConfig.port,
+        password: redisConfig.password,
+        db: redisConfig.db,
+        retry_strategy: function (options) {
+          // if (options.error && options.error.code === 'ECONNREFUSED') {
+          //     // End reconnecting on a specific error and flush all commands with
+          //     // a individual error
+          //     return new Error('The server refused the connection');
+          // }
+          if (options.total_retry_time > 1000 * 60 * 60) {
+            // End reconnecting after a specific timeout and flush all commands
+            // with a individual error
+            return new Error('Retry time exhausted');
+          }
+          if (options.attempt > 10) {
+            // End reconnecting with built in error
+            return 10000;
+          }
+          // reconnect after
+          return Math.min(options.attempt * 100, 3000);
         }
-        // reconnect after
-        return Math.min(options.attempt * 100, 3000);
-      }
-    });
+      });
+    }
 
     // return client.multi().get('foo').execAsync().then(function(res) {
     //     console.log(res); // => 'bar'