javascript - 我使用 Express 中间件收到 UnhandledPromiseRejection

Question

我尝试在尝试访问 addContact 端点之前检查用户是否已登录。

var isLoggedIn = (req, res, next) => {
   if(req.session.user)
       next();

   //unauthorized
   res.status(401).send('Please log in.');
};

发布路由 addContact 如下所示，我使用 isLoggedIn 中间件来检查用户在添加之前是否登录。

app.post('/addContact', isLoggedIn, (req, res) => {

   //if Mongo database is not started
   if(mongoose.connection.readyState !== 1) {
       res.send(`We're sorry. We are having trouble connecting. Try again later`);
       return;
   }

   var contact = new Contact({
       _userId: req.session.user.id,
       name: req.body.name,
       phone_number: req.body.phone_number,
       email: req.body.email
   });

   console.log('adding contact from session', req.session.user);

   contact.save().then((c) => {
       res.send(`${contact.name} was added succesfully.`);
   }).catch((e) => {
       res.send(e);
   });

});

“从 session 中添加联系人:”正在使用正确的 session ID req.session.user 记录到控制台。但是，一旦它尝试 save() 新联系人，我就会收到以下错误

UnhandledPromiseRejectionWarning: Unhandled promise rejection (rejection id: 1): Cannot set headers after they are sent to the client

发送的响应显示“请登录”，这是在中间件 isLoggedIn 中指定的。

有人可以告诉我为什么会发生这种情况吗？我试图不重复问题，但找不到解决方案。谢谢

Answer 1

您需要在调用 next 后返回:

var isLoggedIn = (req, res, next) => {
   if(req.session.user) {
       next();
       return;
    }

   //unauthorized
   res.status(401).send('Please log in.');
};

实际上更好的是:

var isLoggedIn = (req, res, next) => {
   if (!req.session.user) {
       const err = new Error('Please login')
       err.status = 401
       throw err
    }

   next()
};

然后有实际的错误处理程序中间件:

/**
 * Show useful information to client in development.
 */
exports.development = (err, req, res, next) => {
  err.stack = err.stack || ''
  const status = err.status || 500

  res.status(status).json({
    status,
    error
  })
}

/**
 * Do not show errors in production.
 */
exports.production = (err, req, res, next) => {
  if (err.stack) {
    delete err.stack
  }

  err.message = err.messsage || 'oops'
  err.status = err.status || 500

  res.status(err.status).json({
    status: err.status,
    error: {
      message: err.message
    }
  })
}