node.js - 未推送异步瀑布查询？

Question

所以我使用异步瀑布作为将函数结果传递给下一个的过程。我目前在调用由查询产生的用户推送时遇到问题。

这是我的代码：

    exports.contactList = function(req, res) {

    async.waterfall([
    function(callback) {

        Friend.findOne({userId: req.signedCookies.userid}, function(err, users) {
            var friends = [];
            if(err) {throw err};
            for(var i = 0; i < users.friendStatus.length; i++) {
                if(users.friendStatus[i].status === 3) { friends.push(users.friendStatus[i])};  
            }
            //console.log(friends);
            callback(null, friends);
        });


        },

        function(friends, callback) {
            var friendsinfo = [];

            for(var i = 0; i < friends.length; i ++) {
                async.each(friends, function(friend, next) {
                //friendsinfo.push(friend.favorites)


                User.findOne({_id: friend.fuId}, function(err, user) {
                    if (err) { console.log(err); };
                        var object = {'fav': friend.favorites, 'user': user};
                        friendsinfo.push(object);
                        next(err);
                }); 
            }, function(err) {
                console.log('friendsINFO');
                console.log(friendsinfo);
                callback(err, friendsinfo);
            });
            }








        }
    ],

    function(err, results) {
        console.log('RESULTS');
        console.log(results);
        res.render('contactList', {title: 'Weblio', Friends: results});
    });

};

Console.log(user) 实际上打印出用户。数组friendsInfo 显示为未定义。

Answer 1

您在完成任何 User.findOne 之前调用 callback() ，因为它们是异步的。使用 async.each 来解决这个问题。编辑：或者甚至更好地使用 async.map 来创建一个对象（根据@Cam 的建议）。

function (friends, callback) {
    async.map(friends, function (friend, next) {
        User.findOne({ _id: friend.fuId }, function (err, user) {
            friendsinfo.push(user);
            next(err, {
                user: user,
                favorites: friend.favorites
            });
        }); 
    }, function (err, friendsinfo) {
        callback(err, friendsinfo);
    });
}

Answer 2

function (friends, callback) {
var friendsinfo = [];

async.each(friends, function (friend, next) {

    User.findOne({_id: friend.fuId}, function (err, user) {
        friendsinfo.push(user);
        next(err);
    }); 
}, function (err) {
    callback(err, friendsinfo);
});
}

刚刚从上面的答案中清理了功能。认为这就是它应该的样子。