lambcycle/dist/plugin-body-parser.js

(function webpackUniversalModuleDefinition(root, factory) {
	if(typeof exports === 'object' && typeof module === 'object')
		module.exports = factory();
	else if(typeof define === 'function' && define.amd)
		define([], factory);
	else {
		var a = factory();
		for(var i in a) (typeof exports === 'object' ? exports : root)[i] = a[i];
	}
})(global, function() {
return /******/ (function(modules) { // webpackBootstrap
/******/ 	// The module cache
/******/ 	var installedModules = {};
/******/
/******/ 	// The require function
/******/ 	function __webpack_require__(moduleId) {
/******/
/******/ 		// Check if module is in cache
/******/ 		if(installedModules[moduleId]) {
/******/ 			return installedModules[moduleId].exports;
/******/ 		}
/******/ 		// Create a new module (and put it into the cache)
/******/ 		var module = installedModules[moduleId] = {
/******/ 			i: moduleId,
/******/ 			l: false,
/******/ 			exports: {}
/******/ 		};
/******/
/******/ 		// Execute the module function
/******/ 		modules[moduleId].call(module.exports, module, module.exports, __webpack_require__);
/******/
/******/ 		// Flag the module as loaded
/******/ 		module.l = true;
/******/
/******/ 		// Return the exports of the module
/******/ 		return module.exports;
/******/ 	}
/******/
/******/
/******/ 	// expose the modules object (__webpack_modules__)
/******/ 	__webpack_require__.m = modules;
/******/
/******/ 	// expose the module cache
/******/ 	__webpack_require__.c = installedModules;
/******/
/******/ 	// define getter function for harmony exports
/******/ 	__webpack_require__.d = function(exports, name, getter) {
/******/ 		if(!__webpack_require__.o(exports, name)) {
/******/ 			Object.defineProperty(exports, name, { enumerable: true, get: getter });
/******/ 		}
/******/ 	};
/******/
/******/ 	// define __esModule on exports
/******/ 	__webpack_require__.r = function(exports) {
/******/ 		if(typeof Symbol !== 'undefined' && Symbol.toStringTag) {
/******/ 			Object.defineProperty(exports, Symbol.toStringTag, { value: 'Module' });
/******/ 		}
/******/ 		Object.defineProperty(exports, '__esModule', { value: true });
/******/ 	};
/******/
/******/ 	// create a fake namespace object
/******/ 	// mode & 1: value is a module id, require it
/******/ 	// mode & 2: merge all properties of value into the ns
/******/ 	// mode & 4: return value when already ns object
/******/ 	// mode & 8|1: behave like require
/******/ 	__webpack_require__.t = function(value, mode) {
/******/ 		if(mode & 1) value = __webpack_require__(value);
/******/ 		if(mode & 8) return value;
/******/ 		if((mode & 4) && typeof value === 'object' && value && value.__esModule) return value;
/******/ 		var ns = Object.create(null);
/******/ 		__webpack_require__.r(ns);
/******/ 		Object.defineProperty(ns, 'default', { enumerable: true, value: value });
/******/ 		if(mode & 2 && typeof value != 'string') for(var key in value) __webpack_require__.d(ns, key, function(key) { return value[key]; }.bind(null, key));
/******/ 		return ns;
/******/ 	};
/******/
/******/ 	// getDefaultExport function for compatibility with non-harmony modules
/******/ 	__webpack_require__.n = function(module) {
/******/ 		var getter = module && module.__esModule ?
/******/ 			function getDefault() { return module['default']; } :
/******/ 			function getModuleExports() { return module; };
/******/ 		__webpack_require__.d(getter, 'a', getter);
/******/ 		return getter;
/******/ 	};
/******/
/******/ 	// Object.prototype.hasOwnProperty.call
/******/ 	__webpack_require__.o = function(object, property) { return Object.prototype.hasOwnProperty.call(object, property); };
/******/
/******/ 	// __webpack_public_path__
/******/ 	__webpack_require__.p = "";
/******/
/******/
/******/ 	// Load entry module and return exports
/******/ 	return __webpack_require__(__webpack_require__.s = "./src/Plugins/BodyParser/main.ts");
/******/ })
/************************************************************************/
/******/ ({

/***/ "./node_modules/content-type/index.js":
/*!********************************************!*\
  !*** ./node_modules/content-type/index.js ***!
  \********************************************/
/*! no static exports found */
/***/ (function(module, exports, __webpack_require__) {

"use strict";
/*!
 * content-type
 * Copyright(c) 2015 Douglas Christopher Wilson
 * MIT Licensed
 */



/**
 * RegExp to match *( ";" parameter ) in RFC 7231 sec 3.1.1.1
 *
 * parameter     = token "=" ( token / quoted-string )
 * token         = 1*tchar
 * tchar         = "!" / "#" / "$" / "%" / "&" / "'" / "*"
 *               / "+" / "-" / "." / "^" / "_" / "`" / "|" / "~"
 *               / DIGIT / ALPHA
 *               ; any VCHAR, except delimiters
 * quoted-string = DQUOTE *( qdtext / quoted-pair ) DQUOTE
 * qdtext        = HTAB / SP / %x21 / %x23-5B / %x5D-7E / obs-text
 * obs-text      = %x80-FF
 * quoted-pair   = "\" ( HTAB / SP / VCHAR / obs-text )
 */
var PARAM_REGEXP = /; *([!#$%&'*+.^_`|~0-9A-Za-z-]+) *= *("(?:[\u000b\u0020\u0021\u0023-\u005b\u005d-\u007e\u0080-\u00ff]|\\[\u000b\u0020-\u00ff])*"|[!#$%&'*+.^_`|~0-9A-Za-z-]+) */g
var TEXT_REGEXP = /^[\u000b\u0020-\u007e\u0080-\u00ff]+$/
var TOKEN_REGEXP = /^[!#$%&'*+.^_`|~0-9A-Za-z-]+$/

/**
 * RegExp to match quoted-pair in RFC 7230 sec 3.2.6
 *
 * quoted-pair = "\" ( HTAB / SP / VCHAR / obs-text )
 * obs-text    = %x80-FF
 */
var QESC_REGEXP = /\\([\u000b\u0020-\u00ff])/g

/**
 * RegExp to match chars that must be quoted-pair in RFC 7230 sec 3.2.6
 */
var QUOTE_REGEXP = /([\\"])/g

/**
 * RegExp to match type in RFC 7231 sec 3.1.1.1
 *
 * media-type = type "/" subtype
 * type       = token
 * subtype    = token
 */
var TYPE_REGEXP = /^[!#$%&'*+.^_`|~0-9A-Za-z-]+\/[!#$%&'*+.^_`|~0-9A-Za-z-]+$/

/**
 * Module exports.
 * @public
 */

exports.format = format
exports.parse = parse

/**
 * Format object to media type.
 *
 * @param {object} obj
 * @return {string}
 * @public
 */

function format (obj) {
  if (!obj || typeof obj !== 'object') {
    throw new TypeError('argument obj is required')
  }

  var parameters = obj.parameters
  var type = obj.type

  if (!type || !TYPE_REGEXP.test(type)) {
    throw new TypeError('invalid type')
  }

  var string = type

  // append parameters
  if (parameters && typeof parameters === 'object') {
    var param
    var params = Object.keys(parameters).sort()

    for (var i = 0; i < params.length; i++) {
      param = params[i]

      if (!TOKEN_REGEXP.test(param)) {
        throw new TypeError('invalid parameter name')
      }

      string += '; ' + param + '=' + qstring(parameters[param])
    }
  }

  return string
}

/**
 * Parse media type to object.
 *
 * @param {string|object} string
 * @return {Object}
 * @public
 */

function parse (string) {
  if (!string) {
    throw new TypeError('argument string is required')
  }

  // support req/res-like objects as argument
  var header = typeof string === 'object'
    ? getcontenttype(string)
    : string

  if (typeof header !== 'string') {
    throw new TypeError('argument string is required to be a string')
  }

  var index = header.indexOf(';')
  var type = index !== -1
    ? header.substr(0, index).trim()
    : header.trim()

  if (!TYPE_REGEXP.test(type)) {
    throw new TypeError('invalid media type')
  }

  var obj = new ContentType(type.toLowerCase())

  // parse parameters
  if (index !== -1) {
    var key
    var match
    var value

    PARAM_REGEXP.lastIndex = index

    while ((match = PARAM_REGEXP.exec(header))) {
      if (match.index !== index) {
        throw new TypeError('invalid parameter format')
      }

      index += match[0].length
      key = match[1].toLowerCase()
      value = match[2]

      if (value[0] === '"') {
        // remove quotes and escapes
        value = value
          .substr(1, value.length - 2)
          .replace(QESC_REGEXP, '$1')
      }

      obj.parameters[key] = value
    }

    if (index !== header.length) {
      throw new TypeError('invalid parameter format')
    }
  }

  return obj
}

/**
 * Get content-type from req/res objects.
 *
 * @param {object}
 * @return {Object}
 * @private
 */

function getcontenttype (obj) {
  var header

  if (typeof obj.getHeader === 'function') {
    // res-like
    header = obj.getHeader('content-type')
  } else if (typeof obj.headers === 'object') {
    // req-like
    header = obj.headers && obj.headers['content-type']
  }

  if (typeof header !== 'string') {
    throw new TypeError('content-type header is missing from object')
  }

  return header
}

/**
 * Quote a string if necessary.
 *
 * @param {string} val
 * @return {string}
 * @private
 */

function qstring (val) {
  var str = String(val)

  // no need to quote tokens
  if (TOKEN_REGEXP.test(str)) {
    return str
  }

  if (str.length > 0 && !TEXT_REGEXP.test(str)) {
    throw new TypeError('invalid parameter value')
  }

  return '"' + str.replace(QUOTE_REGEXP, '\\$1') + '"'
}

/**
 * Class to represent a content type.
 * @private
 */
function ContentType (type) {
  this.parameters = Object.create(null)
  this.type = type
}


/***/ }),

/***/ "./src/Plugins/BodyParser/Constants/ContentType.ts":
/*!*********************************************************!*\
  !*** ./src/Plugins/BodyParser/Constants/ContentType.ts ***!
  \*********************************************************/
/*! no static exports found */
/***/ (function(module, exports, __webpack_require__) {

"use strict";

Object.defineProperty(exports, "__esModule", { value: true });
var ContentType;
(function (ContentType) {
    ContentType["APPLICATION_JSON"] = "application/json";
})(ContentType || (ContentType = {}));
exports.default = ContentType;


/***/ }),

/***/ "./src/Plugins/BodyParser/Constants/ErrorTypes.ts":
/*!********************************************************!*\
  !*** ./src/Plugins/BodyParser/Constants/ErrorTypes.ts ***!
  \********************************************************/
/*! no static exports found */
/***/ (function(module, exports, __webpack_require__) {

"use strict";

Object.defineProperty(exports, "__esModule", { value: true });
var ErrorTypes;
(function (ErrorTypes) {
    ErrorTypes["BODY_PARSER_OPTION_TYPE_INVALID"] = "BODY_PARSER_OPTION_TYPE_INVALID";
    ErrorTypes["BODY_PARSER_REQUEST_HEADERS_MISSING"] = "BODY_PARSER_REQUEST_HEADERS_MISSING";
    ErrorTypes["BODY_PARSER_REQUEST_HEADERS_CONTENT_TYPE_KEY_INVALID"] = "BODY_PARSER_REQUEST_HEADERS_CONTENT_TYPE_KEY_INVALID";
    ErrorTypes["BODY_PARSER_REQUEST_HEADERS_CONTENT_TYPE_VALUE_INVALID"] = "BODY_PARSER_REQUEST_HEADERS_CONTENT_TYPE_VALUE_INVALID";
    ErrorTypes["BODY_PARSER_JSON_PARSE_FAILED"] = "BODY_PARSER_JSON_PARSE_FAILED";
})(ErrorTypes || (ErrorTypes = {}));
exports.default = ErrorTypes;


/***/ }),

/***/ "./src/Plugins/BodyParser/Constants/ParsingOption.ts":
/*!***********************************************************!*\
  !*** ./src/Plugins/BodyParser/Constants/ParsingOption.ts ***!
  \***********************************************************/
/*! no static exports found */
/***/ (function(module, exports, __webpack_require__) {

"use strict";

Object.defineProperty(exports, "__esModule", { value: true });
var ParsingOption;
(function (ParsingOption) {
    ParsingOption["JSON"] = "json";
    ParsingOption["RAW"] = "raw";
    ParsingOption["TEXT"] = "text";
    ParsingOption["URL_ENCODED"] = "urlencoded";
})(ParsingOption || (ParsingOption = {}));
exports.default = ParsingOption;


/***/ }),

/***/ "./src/Plugins/BodyParser/Constants/RequestHeaders.ts":
/*!************************************************************!*\
  !*** ./src/Plugins/BodyParser/Constants/RequestHeaders.ts ***!
  \************************************************************/
/*! no static exports found */
/***/ (function(module, exports, __webpack_require__) {

"use strict";

Object.defineProperty(exports, "__esModule", { value: true });
var RequestHeaders;
(function (RequestHeaders) {
    RequestHeaders["CONTENT_TYPE"] = "content-type";
})(RequestHeaders || (RequestHeaders = {}));
exports.default = RequestHeaders;


/***/ }),

/***/ "./src/Plugins/BodyParser/Utils/toLowerCaseShallow.ts":
/*!************************************************************!*\
  !*** ./src/Plugins/BodyParser/Utils/toLowerCaseShallow.ts ***!
  \************************************************************/
/*! no static exports found */
/***/ (function(module, exports, __webpack_require__) {

"use strict";

Object.defineProperty(exports, "__esModule", { value: true });
var toLowerCaseShallow = function (obj) {
    return Object.keys(obj).reduce(function (output, currentKey) {
        var key = currentKey.toLowerCase();
        var value = obj[currentKey];
        if (typeof value === 'string')
            value = value.toLowerCase();
        output[key] = value;
        return output;
    }, {});
};
exports.default = toLowerCaseShallow;


/***/ }),

/***/ "./src/Plugins/BodyParser/bodyParser.ts":
/*!**********************************************!*\
  !*** ./src/Plugins/BodyParser/bodyParser.ts ***!
  \**********************************************/
/*! no static exports found */
/***/ (function(module, exports, __webpack_require__) {

"use strict";

Object.defineProperty(exports, "__esModule", { value: true });
var _a;
var ParsingOption_1 = __webpack_require__(/*! ./Constants/ParsingOption */ "./src/Plugins/BodyParser/Constants/ParsingOption.ts");
var json_1 = __webpack_require__(/*! ./json */ "./src/Plugins/BodyParser/json.ts");
var bodyParser = (_a = {},
    _a[ParsingOption_1.default.JSON] = json_1.default,
    _a);
exports.default = bodyParser;


/***/ }),

/***/ "./src/Plugins/BodyParser/json.ts":
/*!****************************************!*\
  !*** ./src/Plugins/BodyParser/json.ts ***!
  \****************************************/
/*! no static exports found */
/***/ (function(module, exports, __webpack_require__) {

"use strict";

Object.defineProperty(exports, "__esModule", { value: true });
var contentType = __webpack_require__(/*! content-type */ "./node_modules/content-type/index.js");
var createError_1 = __webpack_require__(/*! ../../Utils/createError */ "./src/Utils/createError.ts");
var ContentType_1 = __webpack_require__(/*! ./Constants/ContentType */ "./src/Plugins/BodyParser/Constants/ContentType.ts");
var ErrorTypes_1 = __webpack_require__(/*! ./Constants/ErrorTypes */ "./src/Plugins/BodyParser/Constants/ErrorTypes.ts");
var RequestHeaders_1 = __webpack_require__(/*! ./Constants/RequestHeaders */ "./src/Plugins/BodyParser/Constants/RequestHeaders.ts");
var toLowerCaseShallow_1 = __webpack_require__(/*! ./Utils/toLowerCaseShallow */ "./src/Plugins/BodyParser/Utils/toLowerCaseShallow.ts");
var jsonParser = function (handler) {
    var request = handler.event;
    if (!request.headers) {
        throw createError_1.default({
            type: ErrorTypes_1.default.BODY_PARSER_REQUEST_HEADERS_MISSING
        });
    }
    var content;
    request.headers = toLowerCaseShallow_1.default(request.headers);
    try {
        content = contentType.parse(handler.event);
    }
    catch (e) {
        throw createError_1.default({
            type: ErrorTypes_1.default.BODY_PARSER_REQUEST_HEADERS_CONTENT_TYPE_KEY_INVALID,
            details: RequestHeaders_1.default.CONTENT_TYPE,
            source: e
        });
    }
    if (content.type !== ContentType_1.default.APPLICATION_JSON) {
        throw createError_1.default({
            type: ErrorTypes_1.default.BODY_PARSER_REQUEST_HEADERS_CONTENT_TYPE_VALUE_INVALID,
            details: content.type
        });
    }
    try {
        request.body = JSON.parse(request.body);
    }
    catch (e) {
        throw createError_1.default({
            type: ErrorTypes_1.default.BODY_PARSER_JSON_PARSE_FAILED,
            details: e
        });
    }
};
exports.default = jsonParser;


/***/ }),

/***/ "./src/Plugins/BodyParser/main.ts":
/*!****************************************!*\
  !*** ./src/Plugins/BodyParser/main.ts ***!
  \****************************************/
/*! no static exports found */
/***/ (function(module, exports, __webpack_require__) {

"use strict";

Object.defineProperty(exports, "__esModule", { value: true });
var createError_1 = __webpack_require__(/*! ../../Utils/createError */ "./src/Utils/createError.ts");
var bodyParser_1 = __webpack_require__(/*! ./bodyParser */ "./src/Plugins/BodyParser/bodyParser.ts");
var ErrorTypes_1 = __webpack_require__(/*! ./Constants/ErrorTypes */ "./src/Plugins/BodyParser/Constants/ErrorTypes.ts");
var ParsingOption_1 = __webpack_require__(/*! ./Constants/ParsingOption */ "./src/Plugins/BodyParser/Constants/ParsingOption.ts");
var validate = function (config) {
    if (!Object['values'](ParsingOption_1.default).includes(config.type)) {
        return createError_1.default({
            type: ErrorTypes_1.default.BODY_PARSER_OPTION_TYPE_INVALID,
            details: 'one of json|raw|text|urlencoded'
        });
    }
};
var bodyParserPlugin = function (config) {
    var pluginManifest = {
        plugin: {
            onRequest: function (handler) {
                var error = validate(config);
                if (error) {
                    throw error;
                }
                var parser = bodyParser_1.default[config.type];
                parser(handler);
            }
        }
    };
    return pluginManifest;
};
exports.default = bodyParserPlugin;


/***/ }),

/***/ "./src/Utils/createError.ts":
/*!**********************************!*\
  !*** ./src/Utils/createError.ts ***!
  \**********************************/
/*! no static exports found */
/***/ (function(module, exports, __webpack_require__) {

"use strict";

Object.defineProperty(exports, "__esModule", { value: true });
var createError = function (errorEvent) {
    return errorEvent;
};
exports.default = createError;


/***/ })

/******/ });
});
//# sourceMappingURL=plugin-body-parser.js.map