diff --git a/src/topics.js b/src/topics.js index dc7929a6b7..ab3f4f6ffa 100644 --- a/src/topics.js +++ b/src/topics.js @@ -256,24 +256,11 @@ var async = require('async'), } async.parallel({ + mainPost: function(next) { + Topics.getMainPost(tid, uid, next); + }, posts: function(next) { - posts.getPidsFromSet(set, start, end, reverse, function(err, pids) { - if (err) { - return next(err); - } - - pids = [topicData.mainPid].concat(pids); - posts.getPostsByPids(pids, tid, function(err, posts) { - if (err) { - return next(err); - } - start = parseInt(start, 10); - for(var i=0; i