simpler method for getting pids

src/upgrade.js

@@ -480,24 +480,15 @@ Upgrade.upgrade = function (callback) {
 			}
 		},
 		function (next) {
-			thisSchemaDate = Date.UTC(2017, 1, 27);
+			thisSchemaDate = Date.UTC(2017, 1, 28);
 			var schemaName = '[2017/2/27] New sorted set posts:votes';
 
 			if (schemaDate < thisSchemaDate) {
 				updatesMade = true;
 				winston.verbose(schemaName);
 
-				db.getSortedSetRange('categories:cid', 0, -1, function (err, cids) {
-					if (err) {
-						return next(err);
-					}
-
-					async.eachSeries(cids, function (cid, next) {
-						db.getSortedSetRevRange('cid:' + cid + ':pids', 0, -1, function (err, pids) {
-							if (err || !pids) {
-								return next(err);
-							}
-
+				require('./batch').processSortedSet('posts:pid', function (pids, next) {
+					async.each(pids, function (pid, next) {
 						async.each(pids, function (pid, next) {
 							db.getObjectFields('post:' + pid, ['upvotes', 'downvotes'], function (err, postData) {
 								if (err || !postData) {
@@ -508,8 +499,8 @@ Upgrade.upgrade = function (callback) {
 								db.sortedSetAdd('posts:votes', votes, pid, next);
 							});
 						}, next);
-						});
-					}, function (err) {
+					}, next);
+				}, {}, function (err) {
 					if (err) {
 						return next(err);
 					}
@@ -517,7 +508,6 @@ Upgrade.upgrade = function (callback) {
 					winston.info(schemaName + ' - done');
 					Upgrade.update(thisSchemaDate, next);
 				});
-				});
 			} else {
 				winston.info(schemaName + ' - skipped!');
 				next();