aboutsummaryrefslogtreecommitdiff
path: root/node_modules/raw-body
diff options
context:
space:
mode:
authornanalelfe <nargiza.nosirova@mail.utoronto.ca>2016-07-18 10:54:08 +0000
committernanalelfe <nargiza.nosirova@mail.utoronto.ca>2016-07-18 10:54:08 +0000
commita35da9f9ccc1124d9b6f4461c7216ffbb0285e2f (patch)
treed5b4b8548caae36a20e1258a8341dab4b3d522d2 /node_modules/raw-body
parent16bbc66ebafc6f1a55e47dbda3f3c0f658fe715c (diff)
parentc1ce89359a7b54ec97b54ce577e5534c180c5c4b (diff)
merged
Diffstat (limited to 'node_modules/raw-body')
-rw-r--r--node_modules/raw-body/HISTORY.md209
-rw-r--r--node_modules/raw-body/LICENSE22
-rw-r--r--node_modules/raw-body/README.md126
-rw-r--r--node_modules/raw-body/index.js320
-rw-r--r--node_modules/raw-body/package.json123
5 files changed, 800 insertions, 0 deletions
diff --git a/node_modules/raw-body/HISTORY.md b/node_modules/raw-body/HISTORY.md
new file mode 100644
index 0000000..720c860
--- /dev/null
+++ b/node_modules/raw-body/HISTORY.md
@@ -0,0 +1,209 @@
+2.1.7 / 2016-06-19
+==================
+
+ * deps: bytes@2.4.0
+ * perf: remove double-cleanup on happy path
+
+2.1.6 / 2016-03-07
+==================
+
+ * deps: bytes@2.3.0
+ - Drop partial bytes on all parsed units
+ - Fix parsing byte string that looks like hex
+
+2.1.5 / 2015-11-30
+==================
+
+ * deps: bytes@2.2.0
+ * deps: iconv-lite@0.4.13
+
+2.1.4 / 2015-09-27
+==================
+
+ * Fix masking critical errors from `iconv-lite`
+ * deps: iconv-lite@0.4.12
+ - Fix CESU-8 decoding in Node.js 4.x
+
+2.1.3 / 2015-09-12
+==================
+
+ * Fix sync callback when attaching data listener causes sync read
+ - Node.js 0.10 compatibility issue
+
+2.1.2 / 2015-07-05
+==================
+
+ * Fix error stack traces to skip `makeError`
+ * deps: iconv-lite@0.4.11
+ - Add encoding CESU-8
+
+2.1.1 / 2015-06-14
+==================
+
+ * Use `unpipe` module for unpiping requests
+
+2.1.0 / 2015-05-28
+==================
+
+ * deps: iconv-lite@0.4.10
+ - Improved UTF-16 endianness detection
+ - Leading BOM is now removed when decoding
+ - The encoding UTF-16 without BOM now defaults to UTF-16LE when detection fails
+
+2.0.2 / 2015-05-21
+==================
+
+ * deps: bytes@2.1.0
+ - Slight optimizations
+
+2.0.1 / 2015-05-10
+==================
+
+ * Fix a false-positive when unpiping in Node.js 0.8
+
+2.0.0 / 2015-05-08
+==================
+
+ * Return a promise without callback instead of thunk
+ * deps: bytes@2.0.1
+ - units no longer case sensitive when parsing
+
+1.3.4 / 2015-04-15
+==================
+
+ * Fix hanging callback if request aborts during read
+ * deps: iconv-lite@0.4.8
+ - Add encoding alias UNICODE-1-1-UTF-7
+
+1.3.3 / 2015-02-08
+==================
+
+ * deps: iconv-lite@0.4.7
+ - Gracefully support enumerables on `Object.prototype`
+
+1.3.2 / 2015-01-20
+==================
+
+ * deps: iconv-lite@0.4.6
+ - Fix rare aliases of single-byte encodings
+
+1.3.1 / 2014-11-21
+==================
+
+ * deps: iconv-lite@0.4.5
+ - Fix Windows-31J and X-SJIS encoding support
+
+1.3.0 / 2014-07-20
+==================
+
+ * Fully unpipe the stream on error
+ - Fixes `Cannot switch to old mode now` error on Node.js 0.10+
+
+1.2.3 / 2014-07-20
+==================
+
+ * deps: iconv-lite@0.4.4
+ - Added encoding UTF-7
+
+1.2.2 / 2014-06-19
+==================
+
+ * Send invalid encoding error to callback
+
+1.2.1 / 2014-06-15
+==================
+
+ * deps: iconv-lite@0.4.3
+ - Added encodings UTF-16BE and UTF-16 with BOM
+
+1.2.0 / 2014-06-13
+==================
+
+ * Passing string as `options` interpreted as encoding
+ * Support all encodings from `iconv-lite`
+
+1.1.7 / 2014-06-12
+==================
+
+ * use `string_decoder` module from npm
+
+1.1.6 / 2014-05-27
+==================
+
+ * check encoding for old streams1
+ * support node.js < 0.10.6
+
+1.1.5 / 2014-05-14
+==================
+
+ * bump bytes
+
+1.1.4 / 2014-04-19
+==================
+
+ * allow true as an option
+ * bump bytes
+
+1.1.3 / 2014-03-02
+==================
+
+ * fix case when length=null
+
+1.1.2 / 2013-12-01
+==================
+
+ * be less strict on state.encoding check
+
+1.1.1 / 2013-11-27
+==================
+
+ * add engines
+
+1.1.0 / 2013-11-27
+==================
+
+ * add err.statusCode and err.type
+ * allow for encoding option to be true
+ * pause the stream instead of dumping on error
+ * throw if the stream's encoding is set
+
+1.0.1 / 2013-11-19
+==================
+
+ * dont support streams1, throw if dev set encoding
+
+1.0.0 / 2013-11-17
+==================
+
+ * rename `expected` option to `length`
+
+0.2.0 / 2013-11-15
+==================
+
+ * republish
+
+0.1.1 / 2013-11-15
+==================
+
+ * use bytes
+
+0.1.0 / 2013-11-11
+==================
+
+ * generator support
+
+0.0.3 / 2013-10-10
+==================
+
+ * update repo
+
+0.0.2 / 2013-09-14
+==================
+
+ * dump stream on bad headers
+ * listen to events after defining received and buffers
+
+0.0.1 / 2013-09-14
+==================
+
+ * Initial release
diff --git a/node_modules/raw-body/LICENSE b/node_modules/raw-body/LICENSE
new file mode 100644
index 0000000..d695c8f
--- /dev/null
+++ b/node_modules/raw-body/LICENSE
@@ -0,0 +1,22 @@
+The MIT License (MIT)
+
+Copyright (c) 2013-2014 Jonathan Ong <me@jongleberry.com>
+Copyright (c) 2014-2015 Douglas Christopher Wilson <doug@somethingdoug.com>
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.
diff --git a/node_modules/raw-body/README.md b/node_modules/raw-body/README.md
new file mode 100644
index 0000000..5799c82
--- /dev/null
+++ b/node_modules/raw-body/README.md
@@ -0,0 +1,126 @@
+# raw-body
+
+[![NPM Version][npm-image]][npm-url]
+[![NPM Downloads][downloads-image]][downloads-url]
+[![Node.js Version][node-version-image]][node-version-url]
+[![Build status][travis-image]][travis-url]
+[![Test coverage][coveralls-image]][coveralls-url]
+
+Gets the entire buffer of a stream either as a `Buffer` or a string.
+Validates the stream's length against an expected length and maximum limit.
+Ideal for parsing request bodies.
+
+## API
+
+```js
+var getRawBody = require('raw-body')
+```
+
+### getRawBody(stream, [options], [callback])
+
+**Returns a promise if no callback specified and global `Promise` exists.**
+
+Options:
+
+- `length` - The length of the stream.
+ If the contents of the stream do not add up to this length,
+ an `400` error code is returned.
+- `limit` - The byte limit of the body.
+ If the body ends up being larger than this limit,
+ a `413` error code is returned.
+- `encoding` - The requested encoding.
+ By default, a `Buffer` instance will be returned.
+ Most likely, you want `utf8`.
+ You can use any type of encoding supported by [iconv-lite](https://www.npmjs.org/package/iconv-lite#readme).
+
+You can also pass a string in place of options to just specify the encoding.
+
+`callback(err, res)`:
+
+- `err` - the following attributes will be defined if applicable:
+
+ - `limit` - the limit in bytes
+ - `length` and `expected` - the expected length of the stream
+ - `received` - the received bytes
+ - `encoding` - the invalid encoding
+ - `status` and `statusCode` - the corresponding status code for the error
+ - `type` - either `entity.too.large`, `request.aborted`, `request.size.invalid`, `stream.encoding.set`, or `encoding.unsupported`
+
+- `res` - the result, either as a `String` if an encoding was set or a `Buffer` otherwise.
+
+If an error occurs, the stream will be paused, everything unpiped,
+and you are responsible for correctly disposing the stream.
+For HTTP requests, no handling is required if you send a response.
+For streams that use file descriptors, you should `stream.destroy()` or `stream.close()` to prevent leaks.
+
+## Examples
+
+### Simple Express example
+
+```js
+var getRawBody = require('raw-body')
+var typer = require('media-typer')
+
+app.use(function (req, res, next) {
+ getRawBody(req, {
+ length: req.headers['content-length'],
+ limit: '1mb',
+ encoding: typer.parse(req.headers['content-type']).parameters.charset
+ }, function (err, string) {
+ if (err) return next(err)
+ req.text = string
+ next()
+ })
+})
+```
+
+### Simple Koa example
+
+```js
+app.use(function* (next) {
+ var string = yield getRawBody(this.req, {
+ length: this.length,
+ limit: '1mb',
+ encoding: this.charset
+ })
+})
+```
+
+### Using as a promise
+
+To use this library as a promise, simply omit the `callback` and a promise is
+returned, provided that a global `Promise` is defined.
+
+```js
+var getRawBody = require('raw-body')
+var http = require('http')
+
+var server = http.createServer(function (req, res) {
+ getRawBody(req)
+ .then(function (buf) {
+ res.statusCode = 200
+ res.end(buf.length + ' bytes submitted')
+ })
+ .catch(function (err) {
+ res.statusCode = 500
+ res.end(err.message)
+ })
+})
+
+server.listen(3000)
+```
+
+## License
+
+[MIT](LICENSE)
+
+[npm-image]: https://img.shields.io/npm/v/raw-body.svg
+[npm-url]: https://npmjs.org/package/raw-body
+[node-version-image]: https://img.shields.io/node/v/raw-body.svg
+[node-version-url]: http://nodejs.org/download/
+[travis-image]: https://img.shields.io/travis/stream-utils/raw-body/master.svg
+[travis-url]: https://travis-ci.org/stream-utils/raw-body
+[coveralls-image]: https://img.shields.io/coveralls/stream-utils/raw-body/master.svg
+[coveralls-url]: https://coveralls.io/r/stream-utils/raw-body?branch=master
+[downloads-image]: https://img.shields.io/npm/dm/raw-body.svg
+[downloads-url]: https://npmjs.org/package/raw-body
diff --git a/node_modules/raw-body/index.js b/node_modules/raw-body/index.js
new file mode 100644
index 0000000..57b9c11
--- /dev/null
+++ b/node_modules/raw-body/index.js
@@ -0,0 +1,320 @@
+/*!
+ * raw-body
+ * Copyright(c) 2013-2014 Jonathan Ong
+ * Copyright(c) 2014-2015 Douglas Christopher Wilson
+ * MIT Licensed
+ */
+
+'use strict'
+
+/**
+ * Module dependencies.
+ * @private
+ */
+
+var bytes = require('bytes')
+var iconv = require('iconv-lite')
+var unpipe = require('unpipe')
+
+/**
+ * Module exports.
+ * @public
+ */
+
+module.exports = getRawBody
+
+/**
+ * Module variables.
+ * @private
+ */
+
+var iconvEncodingMessageRegExp = /^Encoding not recognized: /
+
+/**
+ * Get the decoder for a given encoding.
+ *
+ * @param {string} encoding
+ * @private
+ */
+
+function getDecoder (encoding) {
+ if (!encoding) return null
+
+ try {
+ return iconv.getDecoder(encoding)
+ } catch (e) {
+ // error getting decoder
+ if (!iconvEncodingMessageRegExp.test(e.message)) throw e
+
+ // the encoding was not found
+ throw createError(415, 'specified encoding unsupported', 'encoding.unsupported', {
+ encoding: encoding
+ })
+ }
+}
+
+/**
+ * Get the raw body of a stream (typically HTTP).
+ *
+ * @param {object} stream
+ * @param {object|string|function} [options]
+ * @param {function} [callback]
+ * @public
+ */
+
+function getRawBody (stream, options, callback) {
+ var done = callback
+ var opts = options || {}
+
+ if (options === true || typeof options === 'string') {
+ // short cut for encoding
+ opts = {
+ encoding: options
+ }
+ }
+
+ if (typeof options === 'function') {
+ done = options
+ opts = {}
+ }
+
+ // validate callback is a function, if provided
+ if (done !== undefined && typeof done !== 'function') {
+ throw new TypeError('argument callback must be a function')
+ }
+
+ // require the callback without promises
+ if (!done && !global.Promise) {
+ throw new TypeError('argument callback is required')
+ }
+
+ // get encoding
+ var encoding = opts.encoding !== true
+ ? opts.encoding
+ : 'utf-8'
+
+ // convert the limit to an integer
+ var limit = bytes.parse(opts.limit)
+
+ // convert the expected length to an integer
+ var length = opts.length != null && !isNaN(opts.length)
+ ? parseInt(opts.length, 10)
+ : null
+
+ if (done) {
+ // classic callback style
+ return readStream(stream, encoding, length, limit, done)
+ }
+
+ return new Promise(function executor (resolve, reject) {
+ readStream(stream, encoding, length, limit, function onRead (err, buf) {
+ if (err) return reject(err)
+ resolve(buf)
+ })
+ })
+}
+
+/**
+ * Halt a stream.
+ *
+ * @param {Object} stream
+ * @private
+ */
+
+function halt (stream) {
+ // unpipe everything from the stream
+ unpipe(stream)
+
+ // pause stream
+ if (typeof stream.pause === 'function') {
+ stream.pause()
+ }
+}
+
+/**
+ * Make a serializable error object.
+ *
+ * To create serializable errors you must re-set message so
+ * that it is enumerable and you must re configure the type
+ * property so that is writable and enumerable.
+ *
+ * @param {number} status
+ * @param {string} message
+ * @param {string} type
+ * @param {object} props
+ * @private
+ */
+
+function createError (status, message, type, props) {
+ var error = new Error()
+
+ // capture stack trace
+ Error.captureStackTrace(error, createError)
+
+ // set free-form properties
+ for (var prop in props) {
+ error[prop] = props[prop]
+ }
+
+ // set message
+ error.message = message
+
+ // set status
+ error.status = status
+ error.statusCode = status
+
+ // set type
+ Object.defineProperty(error, 'type', {
+ value: type,
+ enumerable: true,
+ writable: true,
+ configurable: true
+ })
+
+ return error
+}
+
+/**
+ * Read the data from the stream.
+ *
+ * @param {object} stream
+ * @param {string} encoding
+ * @param {number} length
+ * @param {number} limit
+ * @param {function} callback
+ * @public
+ */
+
+function readStream (stream, encoding, length, limit, callback) {
+ var complete = false
+ var sync = true
+
+ // check the length and limit options.
+ // note: we intentionally leave the stream paused,
+ // so users should handle the stream themselves.
+ if (limit !== null && length !== null && length > limit) {
+ return done(createError(413, 'request entity too large', 'entity.too.large', {
+ expected: length,
+ length: length,
+ limit: limit
+ }))
+ }
+
+ // streams1: assert request encoding is buffer.
+ // streams2+: assert the stream encoding is buffer.
+ // stream._decoder: streams1
+ // state.encoding: streams2
+ // state.decoder: streams2, specifically < 0.10.6
+ var state = stream._readableState
+ if (stream._decoder || (state && (state.encoding || state.decoder))) {
+ // developer error
+ return done(createError(500, 'stream encoding should not be set', 'stream.encoding.set'))
+ }
+
+ var received = 0
+ var decoder
+
+ try {
+ decoder = getDecoder(encoding)
+ } catch (err) {
+ return done(err)
+ }
+
+ var buffer = decoder
+ ? ''
+ : []
+
+ // attach listeners
+ stream.on('aborted', onAborted)
+ stream.on('close', cleanup)
+ stream.on('data', onData)
+ stream.on('end', onEnd)
+ stream.on('error', onEnd)
+
+ // mark sync section complete
+ sync = false
+
+ function done () {
+ var args = new Array(arguments.length)
+
+ // copy arguments
+ for (var i = 0; i < args.length; i++) {
+ args[i] = arguments[i]
+ }
+
+ // mark complete
+ complete = true
+
+ if (sync) {
+ process.nextTick(invokeCallback)
+ } else {
+ invokeCallback()
+ }
+
+ function invokeCallback () {
+ cleanup()
+
+ if (args[0]) {
+ // halt the stream on error
+ halt(stream)
+ }
+
+ callback.apply(null, args)
+ }
+ }
+
+ function onAborted () {
+ if (complete) return
+
+ done(createError(400, 'request aborted', 'request.aborted', {
+ code: 'ECONNABORTED',
+ expected: length,
+ length: length,
+ received: received
+ }))
+ }
+
+ function onData (chunk) {
+ if (complete) return
+
+ received += chunk.length
+ decoder
+ ? buffer += decoder.write(chunk)
+ : buffer.push(chunk)
+
+ if (limit !== null && received > limit) {
+ done(createError(413, 'request entity too large', 'entity.too.large', {
+ limit: limit,
+ received: received
+ }))
+ }
+ }
+
+ function onEnd (err) {
+ if (complete) return
+ if (err) return done(err)
+
+ if (length !== null && received !== length) {
+ done(createError(400, 'request size did not match content length', 'request.size.invalid', {
+ expected: length,
+ length: length,
+ received: received
+ }))
+ } else {
+ var string = decoder
+ ? buffer + (decoder.end() || '')
+ : Buffer.concat(buffer)
+ done(null, string)
+ }
+ }
+
+ function cleanup () {
+ buffer = null
+
+ stream.removeListener('aborted', onAborted)
+ stream.removeListener('data', onData)
+ stream.removeListener('end', onEnd)
+ stream.removeListener('error', onEnd)
+ stream.removeListener('close', cleanup)
+ }
+}
diff --git a/node_modules/raw-body/package.json b/node_modules/raw-body/package.json
new file mode 100644
index 0000000..b915df3
--- /dev/null
+++ b/node_modules/raw-body/package.json
@@ -0,0 +1,123 @@
+{
+ "_args": [
+ [
+ {
+ "name": "raw-body",
+ "raw": "raw-body@~2.1.7",
+ "rawSpec": "~2.1.7",
+ "scope": null,
+ "spec": ">=2.1.7 <2.2.0",
+ "type": "range"
+ },
+ "/Users/warefhaque/CSC309/solutions_repo/node_modules/body-parser"
+ ]
+ ],
+ "_from": "raw-body@>=2.1.7 <2.2.0",
+ "_id": "raw-body@2.1.7",
+ "_inCache": true,
+ "_installable": true,
+ "_location": "/raw-body",
+ "_nodeVersion": "4.4.3",
+ "_npmOperationalInternal": {
+ "host": "packages-12-west.internal.npmjs.com",
+ "tmp": "tmp/raw-body-2.1.7.tgz_1466363663010_0.38383363327011466"
+ },
+ "_npmUser": {
+ "email": "doug@somethingdoug.com",
+ "name": "dougwilson"
+ },
+ "_npmVersion": "2.15.1",
+ "_phantomChildren": {},
+ "_requested": {
+ "name": "raw-body",
+ "raw": "raw-body@~2.1.7",
+ "rawSpec": "~2.1.7",
+ "scope": null,
+ "spec": ">=2.1.7 <2.2.0",
+ "type": "range"
+ },
+ "_requiredBy": [
+ "/body-parser"
+ ],
+ "_resolved": "https://registry.npmjs.org/raw-body/-/raw-body-2.1.7.tgz",
+ "_shasum": "adfeace2e4fb3098058014d08c072dcc59758774",
+ "_shrinkwrap": null,
+ "_spec": "raw-body@~2.1.7",
+ "_where": "/Users/warefhaque/CSC309/solutions_repo/node_modules/body-parser",
+ "author": {
+ "email": "me@jongleberry.com",
+ "name": "Jonathan Ong",
+ "url": "http://jongleberry.com"
+ },
+ "bugs": {
+ "url": "https://github.com/stream-utils/raw-body/issues"
+ },
+ "contributors": [
+ {
+ "email": "doug@somethingdoug.com",
+ "name": "Douglas Christopher Wilson"
+ },
+ {
+ "email": "raynos2@gmail.com",
+ "name": "Raynos"
+ }
+ ],
+ "dependencies": {
+ "bytes": "2.4.0",
+ "iconv-lite": "0.4.13",
+ "unpipe": "1.0.0"
+ },
+ "description": "Get and validate the raw body of a readable stream.",
+ "devDependencies": {
+ "bluebird": "3.4.1",
+ "eslint": "2.13.0",
+ "eslint-config-standard": "5.3.1",
+ "eslint-plugin-promise": "1.3.2",
+ "eslint-plugin-standard": "1.3.2",
+ "istanbul": "0.4.3",
+ "mocha": "2.5.3",
+ "readable-stream": "2.1.2",
+ "through2": "2.0.1"
+ },
+ "directories": {},
+ "dist": {
+ "shasum": "adfeace2e4fb3098058014d08c072dcc59758774",
+ "tarball": "https://registry.npmjs.org/raw-body/-/raw-body-2.1.7.tgz"
+ },
+ "engines": {
+ "node": ">= 0.8"
+ },
+ "files": [
+ "HISTORY.md",
+ "LICENSE",
+ "README.md",
+ "index.js"
+ ],
+ "gitHead": "9d13a27048cc97958fc14fc12418c6aa76f0b1f9",
+ "homepage": "https://github.com/stream-utils/raw-body#readme",
+ "license": "MIT",
+ "maintainers": [
+ {
+ "email": "doug@somethingdoug.com",
+ "name": "dougwilson"
+ },
+ {
+ "email": "jonathanrichardong@gmail.com",
+ "name": "jongleberry"
+ }
+ ],
+ "name": "raw-body",
+ "optionalDependencies": {},
+ "readme": "ERROR: No README data found!",
+ "repository": {
+ "type": "git",
+ "url": "git+https://github.com/stream-utils/raw-body.git"
+ },
+ "scripts": {
+ "lint": "eslint **/*.js",
+ "test": "mocha --trace-deprecation --reporter spec --bail --check-leaks test/",
+ "test-cov": "istanbul cover node_modules/mocha/bin/_mocha -- --trace-deprecation --reporter dot --check-leaks test/",
+ "test-travis": "istanbul cover node_modules/mocha/bin/_mocha --report lcovonly -- --trace-deprecation --reporter spec --check-leaks test/"
+ },
+ "version": "2.1.7"
+}