|
|
@ -158,8 +158,6 @@ var RDB = require('./redis.js'),
|
|
|
|
/* getPostsByPids using redis's multi pipeline */
|
|
|
|
/* getPostsByPids using redis's multi pipeline */
|
|
|
|
Posts.getPostsByPids = function(pids, callback) {
|
|
|
|
Posts.getPostsByPids = function(pids, callback) {
|
|
|
|
var posts = []
|
|
|
|
var posts = []
|
|
|
|
var new_pids = []
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var multi = RDB.multi();
|
|
|
|
var multi = RDB.multi();
|
|
|
|
|
|
|
|
|
|
|
|
for (v in pids) {
|
|
|
|
for (v in pids) {
|
|
|
@ -168,9 +166,7 @@ var RDB = require('./redis.js'),
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
multi.exec(function (err, replies) {
|
|
|
|
multi.exec(function (err, replies) {
|
|
|
|
var pids = replies
|
|
|
|
async.eachSeries(replies, function(postData, _callback) {
|
|
|
|
async.eachSeries(pids, function(pid, _callback) {
|
|
|
|
|
|
|
|
var postData = pid
|
|
|
|
|
|
|
|
if(postData) {
|
|
|
|
if(postData) {
|
|
|
|
postData.relativeTime = utils.relativeTime(postData.timestamp);
|
|
|
|
postData.relativeTime = utils.relativeTime(postData.timestamp);
|
|
|
|
postData.post_rep = postData.reputation;
|
|
|
|
postData.post_rep = postData.reputation;
|
|
|
|