fix mainPids in sorted sets

gistfile1.txt

router.get('/fixTopics', function(req, res) {
	var db = require('../database'),
		async = require('async');

	db.getSortedSetRange('topics:tid', 0, -1, function(err, tids) {
			
		function fixTopic(tid, next) {
			topics.getTopicField(tid, 'mainPid', function(err, mainPid) {
				if (err) {
					return next(err);
				}
				db.getSortedSetRange('tid:' + tid + ':posts', 0, -1, function(err, pids) {
					if (err) {
						return next(err);
					}
					if (!Array.isArray(pids) || !pids.length) {
						return next();
					}
					if (pids.indexOf(mainPid) === -1) {
						return next();
					}
					async.parallel([
						function(next) {
							db.sortedSetRemove('tid:' + tid + ':posts', mainPid, next);		
						},
						function(next) {
							db.sortedSetRemove('tid:' + tid + ':posts:votes', mainPid, next);
						}
					], next);
				});
			});
		}

		async.eachLimit(tids, 10, fixTopic, function(err) {
			if (err) {
				return res.json(500, err.message);
			}
			res.json('Done');
		});
	});
});