This commit is contained in:
barisusakli
2017-04-13 16:36:02 -04:00
parent 1e3acc0caf
commit 7ce6c1d0ad
5 changed files with 45 additions and 9 deletions

View File

@@ -241,7 +241,7 @@ module.exports = function (db, module) {
module.sortedSetScore = function (key, value, callback) {
if (!key) {
return callback();
return callback(null, null);
}
value = helpers.valueToString(value);
db.collection('objects').findOne({ _key: key, value: value }, { fields: { _id: 0, score: 1 } }, function (err, result) {
@@ -274,7 +274,7 @@ module.exports = function (db, module) {
module.sortedSetScores = function (key, values, callback) {
if (!key) {
return callback();
return callback(null, null);
}
values = values.map(helpers.valueToString);
db.collection('objects').find({ _key: key, value: { $in: values } }, { _id: 0, value: 1, score: 1 }).toArray(function (err, result) {

View File

@@ -1,6 +1,6 @@
'use strict';
var helpers = {};
var helpers = module.exports;
helpers.multiKeys = function (redisClient, command, keys, callback) {
callback = callback || function () {};
@@ -15,7 +15,7 @@ helpers.multiKeysValue = function (redisClient, command, keys, value, callback)
callback = callback || function () {};
var multi = redisClient.multi();
for (var i = 0; i < keys.length; i += 1) {
multi[command](keys[i], value);
multi[command](String(keys[i]), String(value));
}
multi.exec(callback);
};
@@ -24,7 +24,7 @@ helpers.multiKeyValues = function (redisClient, command, key, values, callback)
callback = callback || function () {};
var multi = redisClient.multi();
for (var i = 0; i < values.length; i += 1) {
multi[command](key, values[i]);
multi[command](String(key), String(values[i]));
}
multi.exec(callback);
};
@@ -35,5 +35,3 @@ helpers.resultsToBool = function (results) {
}
return results;
};
module.exports = helpers;

View File

@@ -124,8 +124,12 @@ module.exports = function (redisClient, module) {
};
module.sortedSetScore = function (key, value, callback) {
if (!key || value === undefined) {
return callback(null, null);
}
redisClient.zscore(key, value, function (err, score) {
callback(err, !err ? parseFloat(score) : undefined);
callback(err, !err ? parseFloat(score) : null);
});
};