Как дождаться в NodeJS выполнения mongodb.forEach и подзапросов и вернуть результат?

Question

[Роман Сопов]

Получаю данные с помощью find, прохожу по ним forEach, в каждой итерации нужно выполнить подзапрос, результаты сложить в массив и после этого вернуть их в res.json({..}) ?

Answer 1

[bromzh]

promise

UPD
Отвечаю на коммент тут.

В промисах (их есть несколько реализаций, но суть у всех одна) есть функция all, которая вернёт результат промисов всех переданных в неё промисов. Типа такого

Так что можешь создать массив, на каждом шаге цикла оборачивать ответ в промис (если он сам не промис) и потом передать всё в метод all. Например, смотри в конец первого ответа

Примерный код такой:

var queue = [];
cursor.forEach(function (element) {
    queue.push(Promise.resolve(element));
});
Promise.all(queue).then(function(arrayOfResults) {
    // тут делаешь что-то с массивом результатов.
});

Comments

[Роман Сопов]

Если не сложно, можно пример? Не пойму как их тут применить нужно.

[Роман Сопов]

Пример не заработал, массив получается пустой.

[bromzh]

Роман Сопов: Я же написал, что код примерный. Потому что библиотек для монги на ноду целая куча. И библиотек с промисами такая же куча. Я же не знаю какие конкретно библиотеки ты используешь. Алгоритм я показал, дальше сам.

Answer 2

[Алексей Уколов]

Как сделать так, чтобы функция выполнялась только после того, как другая завершится?

Answer 3

[Миша Коган]

Попробуйте модуль async, очень полезная бибилотека https://github.com/caolan/async

Comments

[Yaroslav Lyzlov]

Зачем? Зачем, когда есть Promise нативный?

Answer 4

[Роман Сопов]

Вот так у меня заработало, это правильное решение или нужно иначе?

cursor.forEach(function(doc) {
    var find = {
        pid: doc._id.toString()
    };
    function cnt() {
        return new Promise(function(resolve, reject) {
            self.Struct.find(find).count().then(function(count) {
                var kids = false;
                if(count > 0) {
                    kids = true;
                }
                resolve({
                    id:         doc._id,
                    value:      doc.name,
                    webix_kids: kids
                }); 
            });
        });
    }
    data.push(cnt());		
}, function(err) {
    if(err == null) {
        Promise.all(data).then(function(data){
            res.json({
                success: true,
                error:   0,
                data:    data,
                parent:  pid
            });
        })
    } else {
         reject(err);
    }
});