Node js, подождите, пока не получите все данные из MongoDB

Question

У меня проблема с асинхронной функцией и обратными вызовами в Node js. Мне нужно получить все сообщения моих друзей и показать их. Но если я делаю это без setTimeout (), он возвращает только некоторую часть данных. Как я могу решить эту проблему без установки setTimeout? Конечно, абсурдно ждать 5-6 или 10 секунд, чтобы получить все данные. Я также попробовал с Обещаниями, но снова ответ неполон. Пожалуйста, кто-нибудь может мне помочь?

//Sending request with axios to Controller
axios.post(packages.proxy+'users/getFriendsPosts',{id: user_id},config)
    .then(res => {
        // Code for displaying result
    })


//User Controller
router.post("/getFriendsPosts", getFriendsPosts);


//Send request body to userService.js
function getFriendsPosts(req, res, next) {
    userService.getFriendsPosts(req.body, function(posts, user){
        res.json({posts,user});
    })
        .catch(err => next(err));
}


//userService.js
module.exports = {
    getFriendsPosts,
};


async function getFriendsPosts(user,callback){
    var arr = [];
    var array = [];
    MongoClient.connect(url, async function(errr, db) {
        if (errr) throw errr;
        var dbo = db.db("drone-x");
        //Find user
        dbo.collection("users").find({_id: ObjectId(user.id)}).toArray(async function(err, result) {
            if (err) throw err;
            result.forEach(async function(element, index) {
                if(element.friends.length != 0){
                    element.friends.forEach(async function(elem) {
                        //Find user's friends
                        dbo.collection("users").find({_id: ObjectId(elem.id)}).toArray(async function(error, res) {
                            if (error) throw error;
                            //push user's friends to arr
                            arr.push(res);
                            res.forEach(async function(elements) {
                                //Find user's friends posts
                                dbo.collection("posts").find({userId: elements._id.toString()}).toArray(async function(errors, results) {
                                    if (errors) throw errors;
                                    //push user's friends posts to array
                                    array.push(results);
                                    //callback results through setTimeout
                                    setTimeout(async function(){ await callback(array, arr); db.close(); }, 2000);

                                });
                            });

                        });
                    });
                }
                else
                {
                    await callback("0");
                }
            });
        });

    });
}

Если я не использую функцию setTimeout, она просто возвращает 2-3 данные, но с setTimeout возвращает все данные. И если данные будут подняты, то мне нужно увеличить время setTimeout. Но, конечно, это не очень хорошая идея. Кто-нибудь может мне помочь?

Answer 1

Вы должны использовать try catch в этом коде

getFriendsPosts = async (user,callback) => {
    const arr = [];
    const array = [];
    const db = await MongoClient.connect(url);
    const dbo = db.db("drone-x");
    const results = await dbo.collection("users").find({_id: ObjectId(user.id)})
    const resultPromise =  _.map(results, async element => {
        const friends = _.get(element, 'friends', [])
        if(friends.length != 0) {
        const friendPromise =  _.map(friends, async friend => {
            const ress = await dbo.collection("users").find({_id: ObjectId(friend.id)})
            arr.push(ress);
            const resPromise = _.map(ress, async res => {
             const posts = await dbo.collection("posts").find({userId: res._id.toString()})
                const postPromise =  _.map(posts, post => {
                    array.push(post);
                })
              await Promise.all(postPromise)
            })
           await Promise.all(resPromise)
        })
       await Promise.all(friendPromise)
        } 
    })
   await Promise.all(resultPromise)
    return { arr , array }
}

Я не рекомендую, чтобы это занимало слишком много времени.Вы должны использовать мангуст и использовать агрегацию для длинных запросов.