Как вызывать mongoose findOne внутри forEach дожидаясь ответа?

Question

[angelzzz]

У меня есть массив, я перебираю его с помощью forEach и проверяю тип (type ) каждого значения. Для одного типа мне нужно делать запрос к mongoDB, дождаться ответа и только потом идти дальше по массиву.

Если это имеет значение - я дальше использую эти значения и результат для вызова socket.io emit внутри setTimeOut.

Вот пример перебора:

questionList.forEach((question) => {
    let respName = "";
    let respObj = question;

    if (question.type === "some_type") {
      // some not important code
      // respName = "some_name" 
    } else if (question.type === "some_typeN") {
      // some not important code
      // respName = "some_nameN"
    } else if (question.type === "some_type4") {
      respName = "some_name4"
      respObj = getBlockStats(handle, block);
    } else {
      // some not important code
      // respName = "some_nameX"
    }

    setTimeout(() => {
      io.emit(respName, respObj);
    }, offset);

    offset += offsetIncrease;
});

Вот функция которую я вызываю для обращения к базе:

const getBlockStats = (handle, block) => {
  return GameAnswers.findOne({ handle })
    .then(gameAnswers => {
      let maxQuesstionInBlock = gameAnswers.answers
        .reduce((a, b) => {
          return (parseInt(a.ownId) > parseInt(b.ownId) ? a : b)
        })
      let results = [];

      for (let i = 1; i <= maxQuesstionInBlock.ownId; i++) {
        let team1AllAnswers = gameAnswers.answers
          .filter(el => el.blockId === block)
          .filter((el) => el.team === "team1")
          .filter((el) => parseInt(el.ownId) === i);

        let team1CorrectAnswers = team1AllAnswers
          .filter(el => el.correct === "true");

        let team2AllAnswers = gameAnswers.answers
          .filter(el => el.blockId === block)
          .filter((el) => el.team === "team2")
          .filter((el) => parseInt(el.ownId) === i);

        let team2CorrectAnswers = team2AllAnswers
          .filter(el => el.correct === "true");

        let result = {
          "question": i,
          "team1": {
            "all": team1AllAnswers.length,
            "correct": team1CorrectAnswers.length,
            "percent": team1CorrectAnswers.length * 100 / team1AllAnswers.length
          },
          "team2": {
            "all": team2AllAnswers.length,
            "correct": team2CorrectAnswers.length,
            "percent": team2CorrectAnswers.length * 100 / team2AllAnswers.length
          }
        }

        results.push(result);

      }
      return results;
    })
    .catch(err => {
      console.log("no GameAnswers find err -> ", err);
    });
}

По логам я вижу, что мой запрос к mongoDB происходит после того как forEach пройдет через вес массив. Для for some_type4 значение respObj равно пустому объекту.

Answer 1

[Антон Швец]

https://developer.mozilla.org/en-US/docs/Web/JavaS...

Comments

[angelzzz]

Ничего, что у меня промис только в одном случае из 6?

[Антон Швец]

angelzzz, и что? Если нужно ждать хоть один промис, то весь код превращается в промис, это неизбежно и тут нет ничего страшного.
Ставите await перед getBlockStats, коллбек от forEach выводите в async функцию, и гоняете ее в цикле.

А вот что страшно это дублирование кода и лишние return, что изрядно убавляет читабельности.

[angelzzz]

Антон Швец, c return согласен, пока готовил код для публикации удалял оттуда логи, поэтому остались return , надо бы подчистить.
по остальном не совсем понял

Ставите await перед getBlockStats

else if (question.type === "some_type4") {
      respName = "some_name4"
      respObj = await getBlockStats(handle, block);  //ТУТ?
    }

коллбек от forEach выводите в async функцию

Это не понял

[Антон Швец]

angelzzz,

const questionAction = async (question) => {
    let respName = "";
    let respObj = question;

    if (question.type === "some_type") {
      // some not important code
      // respName = "some_name" 
    } else if (question.type === "some_typeN") {
      // some not important code
      // respName = "some_nameN"
    } else if (question.type === "some_type4") {
      respName = "some_name4"
      respObj = await getBlockStats(handle, block); 
    } else {
      // some not important code
      // respName = "some_nameX"
    }

    setTimeout(() => {
      io.emit(respName, respObj);
    }, offset);

    offset += offsetIncrease;
};
 
(async () => {
  for (const question of questionList) {
    await questionAction(question);
  }
})()

можно и без for await