faster getUserGroups

v1.18.x
barisusakli 10 years ago
parent 170126680b
commit e892cf2e51

@ -374,29 +374,18 @@ var async = require('async'),
}; };
Groups.getUserGroups = function(uids, callback) { Groups.getUserGroups = function(uids, callback) {
db.getSortedSetRevRange('groups:createtime', 0, -1, function(err, groupNames) { async.waterfall([
if (err) { function(next) {
return callback(err); db.getSortedSetRevRange('groups:visible:createtime', 0, -1, next);
} },
function(groupNames, next) {
groupNames = groupNames.filter(function(groupName) { groupNames.push('administrators');
return groupName !== 'registered-users' && groupName.indexOf(':privileges:') === -1;
});
Groups.getMultipleGroupFields(groupNames, ['name', 'hidden'], function(err, groupData) {
if (err) {
return callback(err);
}
groupData = groupData.filter(function(group) {
return group && !parseInt(group.hidden, 10);
});
var groupSets = groupData.map(function(group) { var groupSets = groupNames.map(function(name) {
return 'group:' + group.name + ':members'; return 'group:' + name + ':members';
}); });
async.map(uids, function(uid, next) { async.map(uids, function(uid, next) {
db.isMemberOfSortedSets(groupSets, uid, function(err, isMembers) { db.isMemberOfSortedSets(groupSets, uid, function(err, isMembers) {
if (err) { if (err) {
return next(err); return next(err);
@ -405,14 +394,15 @@ var async = require('async'),
var memberOf = []; var memberOf = [];
isMembers.forEach(function(isMember, index) { isMembers.forEach(function(isMember, index) {
if (isMember) { if (isMember) {
memberOf.push(groupData[index].name); memberOf.push(groupNames[index]);
} }
}); });
Groups.getGroupsData(memberOf, next); Groups.getGroupsData(memberOf, next);
}); });
}, callback); }, next);
}); }
}); ], callback);
}; };
}(module.exports)); }(module.exports));

Loading…
Cancel
Save