Pass through database number

Author: dschmidt

README.md

@@ -75,6 +75,12 @@ The Redis port. If [url](#url) is defined, then this option is not needed.
 
 *Default:* `6379`
 
+### database
+
+The Redis database number. If [url](#url) is defined, then this option is not needed.
+
+*Default:* `undefined`
+
 ### password
 
 The Redis password. If [url](#url) is defined, then this option is not needed.

index.js

@@ -39,7 +39,11 @@ module.exports = {
           return context.commandOptions.revision || context.revisionKey;
         },
         redisDeployClient: function(context) {
-          return context.redisDeployClient || new Redis(context.config.redis);
+          if(context.redisDeployClient) {
+            return context.redisDeployClient;
+          }
+
+          return new (context.redisDeployClientClass || Redis)(context.config.redis);
         }
       },
       configure: function(/* context */) {

lib/redis.js

@@ -17,6 +17,10 @@ module.exports = CoreObject.extend({
         redisOptions.password = options.password;
       }
 
+      if (options.database) {
+        redisOptions.database = options.database;
+      }
+
       this._client = require('then-redis').createClient(redisOptions);
     }
     this._maxNumberOfRecentUploads = 10;

tests/unit/index-nodetest.js

@@ -2,6 +2,7 @@
 
 var Promise = require('ember-cli/lib/ext/promise');
 var assert  = require('ember-cli/tests/helpers/assert');
+var CoreObject = require('core-object');
 
 var stubProject = {
   name: function(){
@@ -53,7 +54,8 @@ describe('redis plugin', function() {
         config: {
           redis: {
             host: 'somehost',
-            port: 1234
+            port: 1234,
+            database: 4
           }
         }
       };
@@ -62,6 +64,37 @@ describe('redis plugin', function() {
       assert.ok(true); // didn't throw an error
     });
 
+    it('passes through config options', function () {
+      var plugin = subject.createDeployPlugin({
+        name: 'redis'
+      });
+
+      var redisDeployClientClassInitialised = false;
+      var context = {
+        ui: mockUi,
+        project: stubProject,
+        config: {
+          redis: {
+            host: 'somehost',
+            port: 1234,
+            database: 4
+          }
+        },
+        redisDeployClientClass: CoreObject.extend({
+          init: function (options) {
+            assert.equal(options.host, 'somehost');
+            assert.equal(options.port, 1234);
+            assert.equal(options.database, 4);
+            redisDeployClientClassInitialised = true;
+          }
+        })
+      };
+      plugin.beforeHook(context);
+      plugin.configure(context);
+      plugin.readConfig("redisDeployClient");
+      assert.ok(redisDeployClientClassInitialised);
+    });
+
     describe('resolving revisionKey from the pipeline', function() {
       it('uses the config data if it already exists', function() {
         var plugin = subject.createDeployPlugin({