NodeBB/src/upgrades/develop/post_votes_zset.js

/* jslint node: true */

'use strict';

var db = require('../database');

var async = require('async');

module.exports = {
	name: 'New sorted set posts:votes',
	timestamp: Date.UTC(2017, 1, 27),
	method: function (callback) {
		require('../batch').processSortedSet('posts:pid', function (pids, next) {
			async.each(pids, function (pid, next) {
				db.getObjectFields('post:' + pid, ['upvotes', 'downvotes'], function (err, postData) {
					if (err || !postData) {
						return next(err);
					}

					var votes = parseInt(postData.upvotes || 0, 10) - parseInt(postData.downvotes || 0, 10);
					db.sortedSetAdd('posts:votes', votes, pid, next);
				});
			}, next);
		}, {}, callback);
	},
};