feat: removed series from upgrade script

src/upgrades/1.12.3/user_pid_sets.js

@@ -14,39 +14,30 @@ module.exports = {
 		const progress = this.progress;
 
 		batch.processSortedSet('posts:pid', function (pids, next) {
-			async.eachSeries(pids, function (pid, _next) {
+			progress.incr(pids.length);
-				progress.incr();
 			let postData;
-
 			async.waterfall([
 				function (next) {
-						posts.getPostFields(pid, ['uid', 'tid', 'upvotes', 'downvotes', 'timestamp'], next);
+					posts.getPostsFields(pids, ['uid', 'tid', 'upvotes', 'downvotes', 'timestamp'], next);
 				},
 				function (_postData, next) {
-						if (!_postData.uid || !_postData.tid) {
-							return _next();
-						}
 					postData = _postData;
-						topics.getTopicField(postData.tid, 'cid', next);
+					const tids = postData.map(p => p.tid);
+					topics.getTopicsFields(tids, ['cid'], next);
 				},
-					function (cid, next) {
+				function (topicData, next) {
-						const keys = [
+					const bulk = [];
-							'cid:' + cid + ':uid:' + postData.uid + ':pids',
+					postData.forEach(function (p, index) {
-						];
+						if (p && p.uid && p.tid) {
-						const scores = [
+							bulk.push(['cid:' + topicData[index].cid + ':uid:' + p.uid + ':pids', p.timestamp, p.pid]);
-							postData.timestamp,
+							if (p.votes > 0) {
-						];
+								bulk.push(['cid:' + topicData[index].cid + ':uid:' + p.uid + ':pids:votes', p.votes, p.pid]);
-						if (postData.votes > 0) {
-							keys.push('cid:' + cid + ':uid:' + postData.uid + ':pids:votes');
-							scores.push(postData.votes);
 							}
-						db.sortedSetsAdd(keys, scores, pid, next);
+						}
-					},
+					});
-					function (next) {
+					db.sortedSetAddBulk(bulk, next);
-						db.sortedSetRemove('uid:' + postData.uid + ':posts:votes', pid, next);
 				},
-				], _next);
+			], next);
-			}, next);
 		}, {
 			progress: progress,
 		}, callback);