如何在 Express 中修复这个 ES6 承诺链？

Question

我从 Promise 链接开始，我正在尝试在 node.js 中使用 express 和 mongoose 的一些代码。这是我的代码：

const register = (req, res, next) => {
  User.findOne(req.params.email).exec().then(user => {
    if (user) {
      return res.status(409).json({ error: 409 });
    }
    return User.create(req.body);
  }).then(user => {
    const token = jwt.sign({ sub: user._id }, 'test-secret');
    return res.status(200).json({ token });
  }).catch(err => {
    return next(err);
  });
};

这是注册用户并向他发送令牌的简化代码。我要做的是，首先检查用户是否已经注册，如果没有，请注册。

如您所见，我认为第 6 行是错误的，因为我没有返回任何 Promise，所以在第 4 行之后，代码继续执行。我想避免回调地狱，我该如何做到这一点？谢谢

Answer 1

您没有返回Promise 这一事实并不重要。 then() 和 catch() 的返回值会自动包装在 Promise 对象中。

问题是您的流程是线性的（它遵循直线路径），但您正在尝试分支以便某些部分仅在某些情况下运行。你需要两条执行路径：

const register = (req, res, next) => {
  User.findOne(req.params.email).exec().then(user => {
    if (user) {
      // Path 1 stops here:
      return res.status(409).json({ error: 409 });

    } else {
      // Path 2 continues down this 2nd Promise chain:
      return User.create(req.body).then(user => {
        const token = jwt.sign({ sub: user._id }, 'test-secret');
        return res.status(200).json({ token });
      })
    }

  }).catch(err => {
    // Both paths converge on this error handler
    return next(err);
  });
};

如果你想避免深度嵌套，你有两种选择：

1. 将不同的路径封装成函数，这样你就可以这样做：

   if (user) {
     return sendHttpError(res, 409)
   } else {
     return sendNewUser(res, req.body)
   }
   

也许只有sendHttpError函数是必需的，其他可能的路径可以是你路由的主体。这是相当标准的。

1. 由于您的一个分支仅处理错误情况，您可以抛出Error 并在下面捕获它，或者在错误处理中间件中捕获它。它看起来像这样：

   if (user) {
     // This throw will abort execution of everything that follows. By
     // using a custom Error class, you can then handle it appropriately
     // in a catch() handler or Express middleware:
     throw new APIError(409)
   }
   
   // ... create user and proceed normally
   

这也是一种很常见的模式。

Answer 2

如果用户已经存在，只需抛出一个error 即可直接访问catch 函数。

const register = (req, res, next) => {
  User.findOne(req.params.email).exec().then(user => {
    if (user) {
      throw new Error({ error: 409, msg: 'User already exists' });
    }
    return User.create(req.body);
  }).then(user => {
    const token = jwt.sign({ sub: user._id }, 'test-secret');
    return res.status(200).json({ token });
  }).catch(err => {
    return next(err);
  });
};