163 lines
3.1 KiB
JavaScript
163 lines
3.1 KiB
JavaScript
/*!
|
|
* body-parser
|
|
* Copyright(c) 2014-2015 Douglas Christopher Wilson
|
|
* MIT Licensed
|
|
*/
|
|
|
|
/**
|
|
* Module dependencies.
|
|
*/
|
|
|
|
var getBody = require('raw-body')
|
|
var iconv = require('iconv-lite')
|
|
var onFinished = require('on-finished')
|
|
var zlib = require('zlib')
|
|
|
|
/**
|
|
* Module exports.
|
|
*/
|
|
|
|
module.exports = read
|
|
|
|
/**
|
|
* Read a request into a buffer and parse.
|
|
*
|
|
* @param {object} req
|
|
* @param {object} res
|
|
* @param {function} next
|
|
* @param {function} parse
|
|
* @param {function} debug
|
|
* @param {object} [options]
|
|
* @api private
|
|
*/
|
|
|
|
function read(req, res, next, parse, debug, options) {
|
|
var length
|
|
var stream
|
|
|
|
// flag as parsed
|
|
req._body = true
|
|
|
|
var opts = options || {}
|
|
|
|
try {
|
|
stream = contentstream(req, debug, opts.inflate)
|
|
length = stream.length
|
|
delete stream.length
|
|
} catch (err) {
|
|
return next(err)
|
|
}
|
|
|
|
opts.length = length
|
|
|
|
var encoding = opts.encoding !== null
|
|
? opts.encoding || 'utf-8'
|
|
: null
|
|
var verify = opts.verify
|
|
|
|
opts.encoding = verify
|
|
? null
|
|
: encoding
|
|
|
|
// read body
|
|
debug('read body')
|
|
getBody(stream, opts, function (err, body) {
|
|
if (err) {
|
|
if (!err.status) {
|
|
err.status = 400
|
|
}
|
|
|
|
// echo back charset
|
|
if (err.type === 'encoding.unsupported') {
|
|
err = new Error('unsupported charset "' + encoding.toUpperCase() + '"')
|
|
err.charset = encoding.toLowerCase()
|
|
err.status = 415
|
|
}
|
|
|
|
// read off entire request
|
|
stream.resume()
|
|
onFinished(req, function onfinished() {
|
|
next(err)
|
|
})
|
|
return
|
|
}
|
|
|
|
// verify
|
|
if (verify) {
|
|
try {
|
|
debug('verify body')
|
|
verify(req, res, body, encoding)
|
|
} catch (err) {
|
|
if (!err.status) err.status = 403
|
|
return next(err)
|
|
}
|
|
}
|
|
|
|
// parse
|
|
try {
|
|
debug('parse body')
|
|
body = typeof body !== 'string' && encoding !== null
|
|
? iconv.decode(body, encoding)
|
|
: body
|
|
req.body = parse(body)
|
|
} catch (err) {
|
|
if (!err.status) {
|
|
err.body = body
|
|
err.status = 400
|
|
}
|
|
return next(err)
|
|
}
|
|
|
|
next()
|
|
})
|
|
}
|
|
|
|
/**
|
|
* Get the content stream of the request.
|
|
*
|
|
* @param {object} req
|
|
* @param {function} debug
|
|
* @param {boolean} [inflate=true]
|
|
* @return {object}
|
|
* @api private
|
|
*/
|
|
|
|
function contentstream(req, debug, inflate) {
|
|
var encoding = (req.headers['content-encoding'] || 'identity').toLowerCase()
|
|
var err
|
|
var length = req.headers['content-length']
|
|
var stream
|
|
|
|
debug('content-encoding "%s"', encoding)
|
|
|
|
if (inflate === false && encoding !== 'identity') {
|
|
err = new Error('content encoding unsupported')
|
|
err.status = 415
|
|
throw err
|
|
}
|
|
|
|
switch (encoding) {
|
|
case 'deflate':
|
|
stream = zlib.createInflate()
|
|
debug('inflate body')
|
|
req.pipe(stream)
|
|
break
|
|
case 'gzip':
|
|
stream = zlib.createGunzip()
|
|
debug('gunzip body')
|
|
req.pipe(stream)
|
|
break
|
|
case 'identity':
|
|
stream = req
|
|
stream.length = length
|
|
break
|
|
default:
|
|
err = new Error('unsupported content encoding "' + encoding + '"')
|
|
err.encoding = encoding
|
|
err.status = 415
|
|
throw err
|
|
}
|
|
|
|
return stream
|
|
}
|