主体解析器使用来自另一个中间件的主体解析器中间件

Question

所以，我在这个快速的应用程序中工作，所有路线都有有限的身体大小，除非你是管理员，因为管理员需要几个路线的无限身体大小。我有限制的身体大小中间件，我这样使用它：app.use（middleware.limit身体大小）

但最终我的身体没有被解析，一切都没有定义。

limitBodySize: (req, res, next) => {
  let admin = true; // removed extra steps for simplicity

  if (admin) {
    bodyParser.urlencoded({ extended: false })(req, res, () => {
      console.log(req.body) // logs undefined
      bodyParser.json()(req, res, () => {
        console.log(req.body) // logs undefined
        next(); // in next route, console.log(req.body) logs undefined
      });
    });
  } else {
    bodyParser.urlencoded({ extended: false, limit: '1kb' })(req, res, () => {
      bodyParser.json({ limit: '1kb' })(req, res, () => {
        next();
      });
    });
  }
}

我怎么能解决这个问题，只有一个中间件，而不是通过传递身体解析器中间件到每一个路由或路由器分开。

Answer 1

首先，您应该在自定义条件中间件之外生成body Parser中间件，因为它是可重用的。

您也没有检查错误；您的bodyParser中间件可能向作为next参数传递给它们的匿名回调提供了错误，因此请正确处理错误。实现这一点的最简单方法之一是使用util模块来提示每个中间件，因为您已经在链接它们了。

我怀疑您的请求主体可能是JSON，而urlencoded中间件正试图解析它，但未成功。此时，bodyParser已经消耗了主体流，因此json中间件也可能会失败。由于您忽略了这两个错误，因此在尝试以下操作之前，您无法确定下一个修复是什么：

const { promisify } = require('util')
const json = promisify(bodyParser.json())
const limitedJson = promisify(bodyParser.json({ limit: '1kb' }))
const urlencoded = promisify(bodyParser.urlencoded({ extended: false }))
const limitedUrlencoded = promisify(bodyParser.urlencoded({ extended: false, limit: '1kb' }))

...

limitBodySize: (req, res, next) => {
  ...

  if (admin) {
    urlencoded(req, res).then(
      () => json(req, res)
    ).then(
      () => next(),
      next
    )
  } else {
    limitedUrlencoded(req, res).then(
      () => limitedJson(req, res)
    ).then(
      () => next(),
      next
    )
  }
}

这将使用的onRejected参数将任何错误传递给express framework。然后（）

使用ECMAScript 2017的async和await语法，您可以使其更易于阅读：

limitBodySize: async (req, res, next) => {
  ...

  try {
    if (admin) {
      await urlencoded(req, res)
      await json(req, res)
    } else {
      await limitedUrlencoded(req, res)
      await limitedJson(req, res)
    }

    next()
  } catch (error) {
    // if error occurs here, you probably need to figure out what your next issue is
    next(error)
  }
}