From 7f534cc7b8fb19a465e856fc81050a631ab06f2c Mon Sep 17 00:00:00 2001
From: barisusakli <barisusakli@gmail.com>
Date: Wed, 25 Jun 2014 18:16:42 -0400
Subject: [PATCH] sorted set refactor

---
 src/database/redis/sorted.js | 26 ++++++++++++--------------
 1 file changed, 12 insertions(+), 14 deletions(-)

diff --git a/src/database/redis/sorted.js b/src/database/redis/sorted.js
index 389f322486..abe6a684f1 100644
--- a/src/database/redis/sorted.js
+++ b/src/database/redis/sorted.js
@@ -10,13 +10,7 @@ module.exports = function(redisClient, module) {
 	};
 
 	module.sortedSetsRemove = function(keys, value, callback) {
-		var multi = redisClient.multi();
-
-		for(var x=0; x<keys.length; ++x) {
-			multi.zrem(keys[x], value);
-		}
-
-		multi.exec(callback);
+		multi('zrem', keys, value, callback);
 	};
 
 	module.getSortedSetRange = function(key, start, stop, callback) {
@@ -75,28 +69,32 @@ module.exports = function(redisClient, module) {
 	};
 
 	module.sortedSetsScore = function(keys, value, callback) {
-		var	multi = redisClient.multi();
+		multi('zscore', keys, value, callback);
+	};
+
+	function multi(command, keys, value, callback) {
+		var	m = redisClient.multi();
 
 		for(var x=0; x<keys.length; ++x) {
-			multi.zscore(keys[x], value);
+			m[command](keys[x], value);
 		}
 
-		multi.exec(callback);
-	};
+		m.exec(callback);
+	}
 
 	module.getSortedSetUnion = function(sets, start, stop, callback) {
 		var args = Array.prototype.slice.call(arguments, 0);
 		args.unshift(null);
 		sortedSetUnion.apply(null, args);
-	}
+	};
 
 	module.getSortedSetRevUnion = function(sets, start, stop, callback) {
 		var args = Array.prototype.slice.call(arguments, 0);
 		args.unshift(true);
 		sortedSetUnion.apply(null, args);
-	}
+	};
 
-	var	sortedSetUnion = function(rev, sets, start, stop, callback) {
+	function sortedSetUnion(rev, sets, start, stop, callback) {
 		// start and stop optional
 		if (typeof start === 'function') {
 			callback = start;