陣列推送正在填充node.js中的陣列

我正在推送messages_filtered數組中的數據，但是當我嘗試在回調中將其始終爲空時。我在異步循環中將數據推入了兩次。 retMessages是從messages_filtered創建的，但它的空retMessages總是空的。陣列推送正在填充node.js中的陣列

Service.poll = function(user, callback) { 
    var messages_filtered = []; 
    async.forEach(activeAccountsFor(user), function(acct, done) { 
    graph.setAccessToken(acct.accessToken); 
    var connections = ['feed', 'links', 'tagged', 'posts', 'notes', 'inbox', 'outbox']; 
    var args = acct.updated_time ? {since: acct.updated_time - 3000} : {}; 
    args['date_format']= 'U'; 
    User.markAsUpdated(user._id); 
    User.markAccountAsUpdated(user._id, acct.userID); 
    async.forEach(connections, function(connection, next) { 

     graph.setOptions(options).get('me/' + connection, args, 
     function(err, feed) { 
      if (err) { 
      winston.log('error', 'Error in connection '); 
      return done(); 
      } 
      async.forEach(feed.data, function(datum, onward) { 
      profanity_service.analyzeFeedItem(datum, function(err, result) { 
       if(!_.isUndefined(datum.comments)){ 
       if(!_.isUndefined(datum.comments.data) && !_.isEmpty(datum.comments.data)){ 
        _.each(datum.comments.data, function(data){ 
        if(moment(data.created_time).unix() >= user.updated_time){ 
         profanity_service.analyzeFeedItem(data, function(err, result) { 
         if(!err && result){ 
          if (result.isProfane){ 
           messages_filtered.push(result); 
          } 
         } 
         }); 
        } 
        }); 
       } 
       } 
       if(!err && result){ 
       if (result.isProfane) { 
        messages_filtered.push(result); 
       } 
       } 
       onward(err); 
      }); 
      }, next); 
     }); 
    }, done); 
    }, function(err) { 
    console.log('messages_filtered.length ' + messages_filtered.length); 
    if (messages_filtered.length > 0) { 
     var retMessages = []; 
     _.each(messages_filtered, function(message) { 
     if (!hasMessage(retMessages, message)) { 
      retMessages.push(message) 
      Message.flag(user._id, message); 
     } 
     }); 
     user.notify(retMessages); 
    } 
    callback(err); 
    }); 
};

來源

2013-06-04 vcxz

不錯的聖誕樹你在那裏：P – PeeHaa

嗯，你已經得到了很多嵌套行動 - 異步，而你與外環:-)具體來說，你忘了，直到最裏面的profanity_service.analyzeFeedItem做是爲了拖延onward通話接着經過一番執行。它應該是

… function(datum, onward) { 
    profanity_service.analyzeFeedItem(datum, function(err, result) { 
     if(!err && result){ 
     if (result.isProfane) { 
      messages_filtered.push(result); 
     } 
     } 
     if(!_.isUndefined(datum.comments) 
     && !_.isUndefined(datum.comments.data) 
     && !_.isEmpty(datum.comments.data) 
    ) { 
     async.forEach(datum.comments.data, function(data, forward){ 
//  ^^^^^^^^^^^^^ 
      if(moment(data.created_time).unix() >= user.updated_time){ 
      profanity_service.analyzeFeedItem(data, function(err, result) { 
       if(!err && result){ 
       if (result.isProfane){ 
        messages_filtered.push(result); 
       } 
       } 
       forward(err); 
      }); 
      } else { 
      forward(); 
      } 
     }); 
     } else { 
     onward(err); 
     } 
    } …

順便說一句，這看起來很奇怪，你分析datum.comments.data在分析datum的回調 - 它修改它的輸入對象？或者你能平行他們嗎？

此外，將您的回調樹重構爲具有其他地方聲明的描述性名稱的單獨函數將會有所幫助。特別是profanity_service.analyzeFeedItem的重複回調，將result推到陣列上會從中獲益。

來源

2013-06-04 11:00:19 Bergi

陣列推送正在填充node.js中的陣列

回答

相關問題