Проблема с асинхронным кодом и mongodb - PullRequest
Новая
       18

Проблема с асинхронным кодом и mongodb

0 голосов
/ 13 апреля 2020

Этот код ищет компанию, затем ищет все веб-сайты, перечисленные в массиве этой компании, затем ищет все разговоры на этом веб-сайте, затем ищет все сообщения для каждого разговора, а затем отправляет эти массивы сообщений. ObjectID для функции helper, которая затем возвращает массив данных JSON для каждого сообщения. Чт .. это было полным ртом.

Мне нужно как-то подождать, пока все это завершится, перед тем, как немного его почистить, а затем переслать. Весь код работает, и console.log(messagesWithData) публикует несколько массивов сообщений (поскольку в этом сценарии отправляется несколько).

Вся помощь приветствуется:) 

  Company.findOne({ 'roles.admins': userId }, function (err, doc) {
    if (!err) {
      for (const item of doc.websites) {
        Website.findById(item, function (err, doc) {
          for (const item of doc.conversations) {
            Conversation.findById(item, function (err, doc) {
              async function findMessageData() {
                var messagesWithData = await helper.takeMessageArray(
                  doc.messages
                );
                await sendMessages(messagesWithData);
              }
              findMessageData();

              async function sendMessages(messagesWithData) {
                // not sure what to put here!
                console.log(messagesWithData)
              }
            });
          }
        });
      }
    } else {
      res.send(err);
    }
  });

1 Ответ

1 голос
/ 13 апреля 2020

Код выше можно немного упростить с помощью async / await 

const company = await Company.findOne({ 'roles.admins': userId });
let allMessages = []
for (const websiteId of company.websites) {
    const website = await Website.findById(websiteId);

    for (const conversationId of website.conversations) {
        const conversation = await Conversation.findById(conversationId);
        const messagesWithData = await helper.takeMessageArray(
            conversation.messages
        );
        allMessages = [...allMessages, ...messagesWithData]
    }
}
// Everything completed, messages stored in one place...
console.log(allMessages)
...