use topic.getMainPids

This commit is contained in:
Barış Soner Uşaklı
2015-03-13 16:33:00 -04:00
parent 64918dfcb4
commit abf27954d3
2 changed files with 10 additions and 24 deletions

View File

@@ -287,13 +287,17 @@ var async = require('async'),
};
Topics.getMainPids = function(tids, callback) {
if (!Array.isArray(tids) || !tids.length) {
return callback(null, []);
}
Topics.getTopicsFields(tids, ['mainPid'], function(err, topicData) {
if (err) {
return callback(err);
}
var mainPids = topicData.map(function(topic) {
return topic ? topic.mainPid : null;
return topic && topic.mainPid;
});
callback(null, mainPids);
});