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

Question

[marink0]

Как сделать, чтобы если срабатывал один return res.json(), то следующий уже не выполнялся? Не используя вкладывание.

newArticle
    .save()
    .then(article => {
      Section
        .findOneAndUpdate({ _id: article.section }, {$push: {"articles": article._id}}, {new: true})
        .then(section => {
          if (section === null) return res.json({ message: 'No sections found' })
        })
        .catch((err) => {
          return next(err)
        })
      return article
    })
    .then(article => {
      return res.status(201).json({
        status: 'OK',
        article
      })
    })
    .catch(err => {
      return next(err)
    })

Сейчас если срабатывает

if (section === null) return res.json({ message: 'No sections found' })

то заголовки отправляются дважды и сервер ругается.

Answer 1

[levchak0910]

Async / await можна?

async (req, res) => {
...
try { 
    let article = await newArticle.save();
    let section = await Section.findOneAndUpdate({ _id: article.section }, {$push: {"articles": article._id}}, {new: true});
    if (section === null) return res.json({ message: 'No sections found' });

    res.status(201).json({
        status: 'OK',
        article
    });
}
catch(e) {
    console.log(e);
    next(e);
}

Comments

[marink0]

Можно наверное, я не пробовала монгуз с асинк авейтами еще. Будет работать? Сейчас попробую.

[marink0]

Вообщем код работает не так как надо. Мне надо что если (section === null) то не сохранять в БД, а просто возращать ответ с ошибкой...

[levchak0910]

Ну так поменяйте местами)

let section = await Section.findOneAndUpdate({ _id: newArticle.section }, {$push: {"articles": article._id}}, {new: true});
if (section === null) return res.json({ message: 'No sections found' });
let article = await newArticle.save();

[marink0]

levchak0910, но он же все равно будет сначала же сохранять в базу, потому что article возращается после этого действия

[levchak0910]

1. Cоздаем экземпляр статьи. Bажно использовать new Article а не Article.create, так не будет добавляться в базу
let article = new Artice( articleData );
2. Пробуем обновить секцию
let section = await Section.findOneAndUpdate(...)
2.1 если нетy то блокируем выполнение скрипта и отправляем ответ на фронт

if (section === null) return res.json({ message: 'No sections found' });

return - блокируем, res.json - отправляем
3 сохраняем экземпляр в базу
await article.save();
4 отдаем ок

res.status(201).json({
    status: 'OK',
    article
});

[marink0]

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

article.tags.forEach(async t => {
      let tag = await Tag.findOneAndUpdate({ _id: t }, {$push: {"articles": article._id}}, {new: true})
      if (tag === null) return res.status(404).json({ message: 'Tag not found' })
    })

[levchak0910]

ИМХО: С перебором массива так лучше не делать.
1. Создаем новый массив для промисов
let arrOfPromises = [];
2. В цикле вызываем все функции обновления(они возвращают промис), добавляем их в массив

article.tags.forEach(t => arrOfPromises.push(Tag.findOneAndUpdate(...)) // никаких async/await

3. Используем функцию Promise.all, которая возвращает все объекты в массиве (объект = await Tag.findOneAndUpdate)
let tags = Promise.all(arrOfPromises );
4. Дальше делаем самостоятельно, харе пользоваться моей добротой

[marink0]

levchak0910, т.е. использовать и промисы и асинк эвейт? Ну как-то уродливо же...

Смысл же уйти от этих then

[levchak0910]

async/await для того и созданы чтобы уйти от then пирамид
Настоятельно рекомендую прочитать

[marink0]

levchak0910, я это понимаю. Но вы же сами предлагаете использовать Promise.all а не async/await в данном случае!!! Зачем мне и то и другое?

[marink0]

Хм, я поняла что вы имели ввиду. Но вот я попробовала и все равно та же ошибка - заголовки отсылаются дважды и с промисами!

await Promise.all(article.tags.map(async (t) => {
      let tag = await Tag.findOneAndUpdate({ _id: t }, {$push: {"articles": article._id}}, {new: true})
      console.log(t)
      if (tag === null) return res.status(404).json({ message: 'Tag not found' })
    }))

[levchak0910]

Я ошибся)
let tags = await Promise.all(arrOfPromises );
Cмысл в том, чтобы не использовать a/a в переборе массива

[levchak0910]

let arrPromises = article.tags.map(tag => Tag.findOneAndUpdate(...))
let tags = await Promise.all(arrPromises);
if (tags.includes(null)) return res.status(404).json({ message: 'Tag not found' })