Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-07-20 23:30:07 +02:00
Code Issues Packages Projects Releases Wiki Activity

closes #2458

Browse Source
This commit is contained in:
barisusakli
2014-12-21 16:29:32 -05:00
parent 2ea5f85d9b
commit 2f8e6a1f2b
6 changed files with 90 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/database/mongo/sets.js
View File

@@ -186,10 +186,23 @@ module.exports = function(db, module) {
return callback(null, 0);
}
db.collection('objects').findOne({_key: key}, {_id: 0}, function(err, data) {
return callback(err, data ? data.members.length : 0);
callback(err, data ? data.members.length : 0);
});
};
module.setsCount = function(keys, callback) {
module.getSetsMembers(keys, function(err, setsMembers) {
if (err) {
return callback(err);
}
var counts = setsMembers.map(function(members) {
return (members && members.length) || 0;
});
callback(null, counts);
});
}
module.setRemoveRandom = function(key, callback) {
callback = callback || function() {};
db.collection('objects').findOne({_key:key}, function(err, data) {

8
src/database/redis/sets.js
View File

@@ -94,6 +94,14 @@ module.exports = function(redisClient, module) {
redisClient.scard(key, callback);
};
module.setsCount = function(keys, callback) {
var multi = redisClient.multi();
for (var i=0; i<keys.length; ++i) {
multi.scard(keys[i]);
}
multi.exec(callback);
};
module.setRemoveRandom = function(key, callback) {
redisClient.spop(key, callback);
};