Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-26 16:46:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

feat: get rid of async.eachSeries

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2019-07-23 21:47:33 -04:00
parent ce91288607
commit 99cf47ee08
1 changed files with 11 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/topics/tools.js
View File

@@ -1,17 +1,16 @@
'use strict';
var async = require('async');
var _ = require('lodash');
const _ = require('lodash');
var db = require('../database');
var categories = require('../categories');
var user = require('../user');
var plugins = require('../plugins');
var privileges = require('../privileges');
const db = require('../database');
const categories = require('../categories');
const user = require('../user');
const plugins = require('../plugins');
const privileges = require('../privileges');
module.exports = function (Topics) {
var topicTools = {};
const topicTools = {};
Topics.tools = topicTools;
topicTools.delete = async function (tid, uid) {
@@ -161,12 +160,10 @@ module.exports = function (Topics) {
throw new Error('[[error:no-privileges]]');
}
await async.eachSeries(data, async function (topicData) {
const isPinned = await db.isSortedSetMember('cid:' + cid + ':tids:pinned', topicData.tid);
if (isPinned) {
await db.sortedSetAdd('cid:' + cid + ':tids:pinned', topicData.order, topicData.tid);
}
});
const isPinned = await db.isSortedSetMembers('cid:' + cid + ':tids:pinned', tids);
data = data.filter((topicData, index) => isPinned[index]);
const bulk = data.map(topicData => ['cid:' + cid + ':tids:pinned', topicData.order, topicData.tid]);
await db.sortedSetAddBulk(bulk);
};
topicTools.move = async function (tid, data) {