This commit is contained in:
Ben Lubar
2016-10-27 18:44:45 -05:00
parent 69ee813d3e
commit a654a2a5fe

View File

@@ -923,10 +923,11 @@ Upgrade.upgrade = function (callback) {
return next(err);
}
async.each(data, function (postData, next) {
async.eachSeries(data, function (postData, next) {
if (!parseInt(postData.toPid, 10)) {
return next(null);
}
console.log('processing pid: ' + postData.pid + ' toPid: ' + postData.toPid);
async.parallel([
async.apply(db.sortedSetAdd, 'pid:' + postData.toPid + ':replies', postData.timestamp, postData.pid),
async.apply(db.incrObjectField, 'post:' + postData.toPid, 'replies')