Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-31 11:05:54 +01:00
Code Issues Packages Projects Releases Wiki Activity

sortedSetUnionCard

Browse Source
This commit is contained in:
barisusakli
2016-09-09 13:19:14 +03:00
parent 77c549081c
commit e1263f1057
3 changed files with 48 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/database/mongo/sorted.js
View File

@@ -474,6 +474,26 @@ module.exports = function(db, module) {
});
};
module.sortedSetUnionCard = function(keys, callback) {
if (!Array.isArray(keys) || !keys.length) {
return callback(null, 0);
}
var pipeline = [
{ $match: { _key: {$in: keys} } },
{ $group: { _id: {value: '$value' } } },
{ $group: { _id: null, count: { $sum: 1 } } }
];
var project = { _id: 0, count: '$count' };
pipeline.push({ $project: project });
db.collection('objects').aggregate(pipeline, function(err, data) {
console.log(data);
callback(err, Array.isArray(data) && data.length ? data[0].count : 0);
});
};
module.getSortedSetUnion = function(params, callback) {
params.sort = 1;
getSortedSetUnion(params, callback);
@@ -484,7 +504,6 @@ module.exports = function(db, module) {
getSortedSetUnion(params, callback);
};
function getSortedSetUnion(params, callback) {
if (!Array.isArray(params.sets) || !params.sets.length) {
return callback();
@@ -629,7 +648,7 @@ module.exports = function(db, module) {
getSortedSetRevIntersect(params, callback);
};
function getSortedSetRevIntersect (params, callback) {
function getSortedSetRevIntersect(params, callback) {
var sets = params.sets;
var start = params.hasOwnProperty('start') ? params.start : 0;
var stop = params.hasOwnProperty('stop') ? params.stop : -1;