Как прервать выполнение цепочки промисов, если совпадает условие в цикле с промисами?

Question

[verycooldev]

Есть участок, где я в цикле выпоняю промисы

.then(result => {
    for (let t of article.tags) {
      Tag.findOneAndUpdate({ _id: t }, {$push: {"articles": article._id}}, {new: true})
      .then(tag => {
        if (tag === null) throw new Error('Tag not found')
      })
      .catch(err => next(err))
    }
  })

Я рассчитывал, что если это условие выполняется, то все операции идущие за этим блоком then() также оборвутся. Но нет, выполняется следующий блок, даже если if (tag === null) throw new Error('Tag not found')

.then(result => {
    article.save()
    .then(result => {
      console.log(result)
      res.status(201).json({
        status: 'OK',
        article
      })
    })
  })

И в итоге я получаю

(node:8682) UnhandledPromiseRejectionWarning: Error [ERR_HTTP_HEADERS_SENT]: Cannot set headers after they are sent to the client
(node:8682) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). (rejection id: 1)
(node:8682) [DEP0018] DeprecationWarning: Unhandled promise rejections are deprecated. In the future, promise rejections that are not handled will terminate the Node.js process with a non-zero exit code.

Т.е. заголовки отправляются два раза - сначала throw new Error('Tag not found') отправляет заголовки (это мой эррор хэндлер), потом следующий блок then()

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

Плз, не предлагайте варианты с async/await (у меня есть рабочий код на них), хочу все на промисах (изучаю тему)

Comments

[Dmitriy Uvarov]

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

[verycooldev]

Dmitriy Uvarov, это не статья хранит теги, а тэги хранят соответсвующие статьи (популяции). На этапе создания статьи я хочу проводить проверку, существует ли такой тэг. если тэг существует - пушим туда ID статьи. В цикле я не могу понять как это делать - пушится все равно. Вот я переделал так, все равно в цикле тэгов проблема, все равно это гавно происходит.

Section.find({_id: article.section}).exec()
  .then(section => {
    console.log(section)
    if (section.length === 0) throw new Error('Section not found')
    for (let t of article.tags) {
      Tag.find({_id: t})
      .then(tag => {
        console.log(tag)
        if (tag.length === 0) throw new Error('Tag not found')
      })
      .catch(err => next(err))
    }
  })
  .then(result => {
    console.log('HELLO')
    article.save()
    .then(result => {
      // console.log(result)
      res.status(201).json({
        status: 'OK',
        article
      })
    })
    .catch(err => next(err))
  })
  .catch(err => next(err))

второй then выполняется раньше чем заканчивается цикл. Вот в чем проблема. Как ждать?

[verycooldev]

Dmitriy Uvarov, переделал так, как вам моя лапша (пошел 3 день как я более менее начал использовать промисы, поэтому очень хочется чтобы кто-то оценил)

Section.find({_id: article.section}).exec()
  .then(section => {
    if (section.length === 0) throw new Error('Section not found')
    let tagsPromises = []
    for (let t of article.tags) {
      tagsPromises.push(Tag.find({_id: t}))
    }
    Promise.all(tagsPromises)
    .then(tags => {
      tags.map(tag => {
        if (tag.length === 0) throw new Error('Tag not found')
      })
      article.save()
      .then(result => {
        Section.findOneAndUpdate({ _id: article.section }, {$push: {"articles": article._id}}, {new: true})
        .then(result => {
          console.log(result)
          let tagsPromises = []
          for (let t of article.tags) {
            tagsPromises.push(Tag.findOneAndUpdate({ _id: t }, {$push: {"articles": article._id}}, {new: true}))
          }
          Promise.all(tagsPromises)
          .then(result => {
            res.status(201).json({
              status: 'OK',
              article
            })
          })
        })
      })
      .catch(err => next(err))
    })
    .catch(err => next(err))
  })
  .catch(err => next(err))