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

feat: optimize copy privileges

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2019-05-30 21:41:54 -04:00
parent 8aef689f05
commit 0dca13e9c2
3 changed files with 29 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

56
src/categories/create.js
View File

@@ -1,6 +1,7 @@
'use strict';
var async = require('async');
var _ = require('lodash');
var db = require('../database');
var groups = require('../groups');
@@ -222,63 +223,52 @@ module.exports = function (Categories) {
async.waterfall([
function (next) {
plugins.fireHook('filter:categories.copyPrivilegesFrom', {
privileges: privileges.privilegeList.slice(),
privileges: group ? privileges.groupPrivilegeList.slice() : privileges.privilegeList.slice(),
fromCid: fromCid,
toCid: toCid,
group: group,
}, next);
},
function (data, next) {
async.each(data.privileges, function (privilege, next) {
if (group) {
copyPrivilegeByGroup(privilege, data.fromCid, data.toCid, group, next);
} else {
copyPrivilege(privilege, data.fromCid, data.toCid, next);
}
}, next);
if (group) {
copyPrivilegesByGroup(data.privileges, data.fromCid, data.toCid, group, next);
} else {
copyPrivileges(data.privileges, data.fromCid, data.toCid, next);
}
},
], callback);
};
function copyPrivilege(privilege, fromCid, toCid, callback) {
function copyPrivileges(privileges, fromCid, toCid, callback) {
const toGroups = privileges.map(privilege => 'group:cid:' + toCid + ':privileges:' + privilege + ':members');
const fromGroups = privileges.map(privilege => 'group:cid:' + fromCid + ':privileges:' + privilege + ':members');
async.waterfall([
function (next) {
db.getSortedSetRange('group:cid:' + toCid + ':privileges:' + privilege + ':members', 0, -1, next);
db.getSortedSetsMembers(toGroups.concat(fromGroups), next);
},
function (currentMembers, next) {
async.eachSeries(currentMembers, function (member, next) {
groups.leave('cid:' + toCid + ':privileges:' + privilege, member, next);
}, next);
},
function (next) {
db.getSortedSetRange('group:cid:' + fromCid + ':privileges:' + privilege + ':members', 0, -1, next);
},
function (members, next) {
if (!members || !members.length) {
return callback();
}
async.eachSeries(members, function (member, next) {
groups.join('cid:' + toCid + ':privileges:' + privilege, member, next);
const copyGroups = _.uniq(_.flatten(currentMembers));
async.each(copyGroups, function (group, next) {
copyPrivilegesByGroup(privileges, fromCid, toCid, group, next);
}, next);
},
], callback);
}
function copyPrivilegeByGroup(privilege, fromCid, toCid, group, callback) {
function copyPrivilegesByGroup(privileges, fromCid, toCid, group, callback) {
async.waterfall([
function (next) {
groups.leave('cid:' + toCid + ':privileges:' + privilege, group, next);
const leaveGroups = privileges.map(privilege => 'cid:' + toCid + ':privileges:' + privilege);
groups.leave(leaveGroups, group, next);
},
function (next) {
db.isSortedSetMember('group:cid:' + fromCid + ':privileges:' + privilege + ':members', group, next);
const checkGroups = privileges.map(privilege => 'group:cid:' + fromCid + ':privileges:' + privilege + ':members');
db.isMemberOfSortedSets(checkGroups, group, next);
},
function (isMember, next) {
if (!isMember) {
return callback();
}
groups.join('cid:' + toCid + ':privileges:' + privilege, group, next);
function (isMembers, next) {
privileges = privileges.filter((priv, index) => isMembers[index]);
const joinGroups = privileges.map(privilege => 'cid:' + toCid + ':privileges:' + privilege);
groups.join(joinGroups, group, next);
},
], callback);
}

4
src/groups/join.js
View File

@@ -14,7 +14,9 @@ module.exports = function (Groups) {
if (!groupNames) {
return callback(new Error('[[error:invalid-data]]'));
}
if (Array.isArray(groupNames) && !groupNames.length) {
return setImmediate(callback);
}
if (!Array.isArray(groupNames)) {
groupNames = [groupNames];
}

3
src/groups/leave.js
View File

@@ -10,6 +10,9 @@ module.exports = function (Groups) {
Groups.leave = function (groupNames, uid, callback) {
callback = callback || function () {};
if (Array.isArray(groupNames) && !groupNames.length) {
return setImmediate(callback);
}
if (!Array.isArray(groupNames)) {
groupNames = [groupNames];
}