async wooo

v1.18.x
MrWaffle 11 years ago
parent c0e2e9d011
commit da317b5a85

@ -1,4 +1,6 @@
var db = require('./database'), var async = require('async'),
db = require('./database'),
posts = require('./posts'), posts = require('./posts'),
user = require('./user'), user = require('./user'),
translator = require('./../public/src/translator'); translator = require('./../public/src/translator');
@ -116,22 +118,18 @@ var db = require('./database'),
}; };
Favourites.getFavouritedUidsByPids = function (pids, callback) { Favourites.getFavouritedUidsByPids = function (pids, callback) {
//Might as well take the method above this as an example
var loaded = 0;
var data = {}; var data = {};
for (var i = 0, ii = pids.length; i < ii; i++) { function getUids(pid, next) {
(function (post_id) { db.getSetMembers('pid:' + pid + ':users_favourited', function(err, uids) {
db.getSetMembers('pid:' + post_id + ':users_favourited', function(err, uids) { data[pid] = uids;
data[post_id] = uids; next();
loaded++;
if (loaded === pids.length) {
callback(data);
}
}); });
}(pids[i]));
} }
//Literally
async.each(pids, getUids, function(err) {
callback(data);
});
}; };
}(exports)); }(exports));
Loading…
Cancel
Save