Mongoose 阻止下一个 then() 被执行

Question

使用 Mongoose，我将任务保存到 task 集合中，如果进展顺利，应该使用任务数据更新板。但是，如果上一个（保存任务）出错，我不知道如何防止执行最后一个then()（保存到板）。

我一直在尝试使用Promise.reject()，但我不确定如何返回Promise.reject() 和错误的响应状态。

// POST add a new task
taskRouter.post('/:boardId', (req, res) => {
  let task = new Task(req.body)
  let boardId = req.params.boardId
  let newTaskNumber
  let newTaskId

  // get lastTaskNumber from the board
  Board.findById(boardId)
    .select('lastTaskNumber')
    .exec()
    .then(board => {
      newTaskNumber = board.lastTaskNumber + increaseTaskNumberBy
      newTaskId = `${boardId}-${newTaskNumber}`
      task._id = newTaskId
      return
    })
    // save the task in the task collection
    .then(() => {
      return task.save(
        (err, task) => {
          if (err) {
            return res.status(400).json({
              message: 'Error saving a task',
              error: err
            })
          } else {
            res.status(200).json(task)
          }
        },
        { _id: false }
      )
    })
    // *********
    //if the above fails, don't execute the next then() 
    // *********
    .catch(() => console.log('error saving a task'))
    // update lastTaskNumber in the board
    // add task to the 1st column of the board
    .then(() => {
      return Board.findByIdAndUpdate(boardId, {
        lastTaskNumber: newTaskNumber,
        $push: {
          'columns.0.tasks': {
            taskId: newTaskId,
            title: task.title,
            priority: task.priority
          }
        }
      })
    })
})

Answer 1

这是 mongoose 中的工作示例，其中包含 cmets 中建议的 async/await 和 transactions。

按顺序调用调用，在前一个调用完成后开始下一个调用。通过使用事务，所有异步函数只有一个catch。如果其中一个调用失败，所有以前的更改都将从数据库中恢复，并调用 catch。

taskRouter.post('/:boardId', (req, res) => {
  let task = new Task(req.body)
  let boardId = req.params.boardId
  let newTaskNumber
  let newTaskId

    // tslint:disable-next-line
  ;(async function addTask() {
    const session = await mongoose.startSession()
    session.startTransaction()

    try {
      await Board.findById(boardId, null, { session })
        .select('lastTaskNumber -_id')
        .exec()
        .then(board => {
          newTaskNumber = board.lastTaskNumber + increaseTaskNumberBy
          newTaskId = `${boardId}-${newTaskNumber}`
          task._id = newTaskId
        })

      await Task.create([task], { session }, null, {
        _id: false
      })

      await Board.findByIdAndUpdate(
        boardId,
        {
          lastTaskNumber: newTaskNumber,
          $push: {
            'columns.0.tasks': {
              taskId: newTaskId,
              title: task.title,
              priority: task.priority
            }
          }
        },
        { session }
      )

      await session.commitTransaction()
      session.endSession()
      return res.status(200).json(task)
    } catch (error) {
      await session.abortTransaction()
      session.endSession()
      return res.status(400).json({
        message: 'Error saving a new task',
        error: error
      })
    }
  })()
})

Answer 2

    Board.findById(boardId)
        .select('lastTaskNumber')
        .exec()
        .then(board => {
             newTaskNumber = board.lastTaskNumber + increaseTaskNumberBy
             newTaskId = `${boardId}-${newTaskNumber}`  
             task._id = newTaskId 
             return
        }) // save the task in the task collection
       .then(() => { 
             return task.save( (err, task) => { 
                   if (err) { 
                        return res.status(400).json({ message: 'Error saving a task', error: err }) 
                   }
                   return Board.findByIdAndUpdate(boardId, 
                   {
                        lastTaskNumber: newTaskNumber, 
                        $push: { 
                             'columns.0.tasks': {
                                  taskId: newTaskId,
                                  title: task.title, 
                                  priority: task.priority 
                              } 
                        } 
                   }) 
             }, 
             { _id: false } ) 
        })
       // *********
       //if the above fails, don't execute the next then()
      // ********* 
      .catch(() => console.log('error saving a task')) 

结构改变了，但应该这样做