Add support for auth pass user

Author: gkorland

index.js

@@ -109,6 +109,7 @@ function RedisClient (options, stream) {
     this.closing = false;
     this.server_info = {};
     this.auth_pass = options.auth_pass || options.password;
+    this.auth_user = options.auth_user;
     this.selected_db = options.db; // Save the selected db here, used when reconnecting
     this.fire_strings = true; // Determine if strings or buffers should be written to the stream
     this.pipeline = false;
@@ -240,7 +241,7 @@ RedisClient.prototype.create_stream = function () {
     if (this.auth_pass !== undefined) {
         this.ready = true;
         // Fail silently as we might not be able to connect
-        this.auth(this.auth_pass, function (err) {
+        this.auth(this.auth_pass, this.auth_user, function (err) {
             if (err && err.code !== 'UNCERTAIN_STATE') {
                 self.emit('error', err);
             }

lib/createClient.js

@@ -29,7 +29,11 @@ module.exports = function createClient (port_arg, host_arg, options) {
         // [redis:]//[[user][:password]@][host][:port][/db-number][?db=db-number[&password=bar[&option=value]]]
         if (parsed.slashes) { // We require slashes
             if (parsed.auth) {
-                options.password = parsed.auth.slice(parsed.auth.indexOf(':') + 1);
+            	var columnIndex = parsed.auth.indexOf(':');
+            	options.password = parsed.auth.slice(columnIndex + 1);
+            	if(columnIndex>0){
+            		options.user = parsed.auth.slice(0, columnIndex);
+            	}
             }
             if (parsed.protocol) {
                 if (parsed.protocol === 'rediss:') {

lib/individualCommands.js

@@ -180,7 +180,12 @@ Multi.prototype.info = Multi.prototype.INFO = function info (section, callback)
     return this;
 };
 
-function auth_callback (self, pass, callback) {
+function auth_callback (self, pass, user, callback) {
+	// Backward compatibility support for auth with password only 
+	if (user instanceof Function){
+		callback = user;
+		user = null;
+	}
     return function (err, res) {
         if (err) {
             if (no_password_is_set.test(err.message)) {
@@ -191,7 +196,7 @@ function auth_callback (self, pass, callback) {
                 // If redis is still loading the db, it will not authenticate and everything else will fail
                 debug('Redis still loading, trying to authenticate later');
                 setTimeout(function () {
-                    self.auth(pass, callback);
+                    self.auth(pass, user, callback);
                 }, 100);
                 return;
             }
@@ -200,25 +205,46 @@ function auth_callback (self, pass, callback) {
     };
 }
 
-RedisClient.prototype.auth = RedisClient.prototype.AUTH = function auth (pass, callback) {
+RedisClient.prototype.auth = RedisClient.prototype.AUTH = function auth (pass, user, callback) {
     debug('Sending auth to ' + this.address + ' id ' + this.connection_id);
 
+	// Backward compatibility support for auth with password only 
+	if (user instanceof Function){
+		callback = user;
+		user = null;
+	}
     // Stash auth for connect and reconnect.
     this.auth_pass = pass;
+    this.auth_user = user;
     var ready = this.ready;
     this.ready = ready || this.offline_queue.length === 0;
-    var tmp = this.internal_send_command(new Command('auth', [pass], auth_callback(this, pass, callback)));
+    var tmp;
+    if(user){
+    	tmp = this.internal_send_command(new Command('auth', [pass, user], auth_callback(this, pass, user, callback)));
+    } else {
+    	tmp = this.internal_send_command(new Command('auth', [pass], auth_callback(this, pass, callback)));
+    }
     this.ready = ready;
     return tmp;
 };
 
 // Only works with batch, not in a transaction
-Multi.prototype.auth = Multi.prototype.AUTH = function auth (pass, callback) {
+Multi.prototype.auth = Multi.prototype.AUTH = function auth (pass, user, callback) {
     debug('Sending auth to ' + this.address + ' id ' + this.connection_id);
 
+	// Backward compatibility support for auth with password only 
+	if (user instanceof Function){
+		callback = user;
+		user = null;
+	}
     // Stash auth for connect and reconnect.
     this.auth_pass = pass;
-    this.queue.push(new Command('auth', [pass], auth_callback(this._client, callback)));
+	this.auth_user = user;
+    if(user){
+    	this.queue.push(new Command('auth', [pass, user], auth_callback(this._client, callback)));
+    } else {
+    	this.queue.push(new Command('auth', [pass], auth_callback(this._client, callback)));
+    }
     return this;
 };