Socket
Socket
Sign inDemoInstall

mappersmith

Package Overview
Dependencies
Maintainers
1
Versions
120
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

mappersmith - npm Package Compare versions

Comparing version 2.25.0 to 2.25.1

53

client-builder.js

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,17 +6,14 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; };
var _manifest = _interopRequireDefault(require("./manifest"));
var _manifest = require('./manifest');
var _request = _interopRequireDefault(require("./request"));
var _manifest2 = _interopRequireDefault(_manifest);
var _utils = require("./utils");
var _request = require('./request');
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
var _request2 = _interopRequireDefault(_request);
function _typeof(obj) { if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }
var _utils = require('./utils');
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
function _defineProperty(obj, key, value) { if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }

@@ -31,3 +28,3 @@

if (!manifest) {
throw new Error('[Mappersmith] invalid manifest (' + manifest + ')');
throw new Error("[Mappersmith] invalid manifest (".concat(manifest, ")"));
}

@@ -40,3 +37,3 @@

this.Promise = configs.Promise;
this.manifest = new _manifest2.default(manifest, configs);
this.manifest = new _manifest.default(manifest, configs);
this.GatewayClassFactory = GatewayClassFactory;

@@ -50,8 +47,8 @@ this.maxMiddlewareStackExecutionAllowed = configs.maxMiddlewareStackExecutionAllowed;

var client = { _manifest: this.manifest };
var client = {
_manifest: this.manifest
};
this.manifest.eachResource(function (name, methods) {
client[name] = _this.buildResource(name, methods);
});
return client;

@@ -64,3 +61,3 @@ },

return (0, _utils.assign)(resource, _defineProperty({}, method.name, function (requestParams) {
var request = new _request2.default(method.descriptor, requestParams);
var request = new _request.default(method.descriptor, requestParams);
return _this2.invokeMiddlewares(resourceName, method.name, request);

@@ -73,3 +70,6 @@ }));

var middleware = this.manifest.createMiddleware({ resourceName: resourceName, resourceMethod: resourceMethod });
var middleware = this.manifest.createMiddleware({
resourceName: resourceName,
resourceMethod: resourceMethod
});
var GatewayClass = this.GatewayClassFactory();

@@ -88,7 +88,7 @@ var gatewayConfigs = this.manifest.gatewayConfigs;

requestPhaseExecutionFailed = true;
var error = new Error('[Mappersmith] middleware "' + middleware.__name + '" failed in the request phase: ' + e.message);
var error = new Error("[Mappersmith] middleware \"".concat(middleware.__name, "\" failed in the request phase: ").concat(e.message));
error.stack = e.stack;
throw error;
}).then(function (request) {
if (request instanceof _request2.default) {
if (request instanceof _request.default) {
return request;

@@ -98,6 +98,7 @@ }

requestPhaseExecutionFailed = true;
var typeValue = typeof request === 'undefined' ? 'undefined' : _typeof(request);
var typeValue = _typeof(request);
var prettyType = typeValue === 'object' || typeValue === 'function' ? request.name || typeValue : typeValue;
throw new Error('[Mappersmith] middleware "' + middleware.__name + '" should return "Request" but returned "' + prettyType + '"');
throw new Error("[Mappersmith] middleware \"".concat(middleware.__name, "\" should return \"Request\" but returned \"").concat(prettyType, "\""));
}).then(function (request) {

@@ -115,3 +116,3 @@ return _this3.Promise.resolve(request);

if (executions > _this3.maxMiddlewareStackExecutionAllowed) {
throw new Error('[Mappersmith] infinite loop detected (middleware stack invoked ' + executions + ' times). Check the use of "renew" in one of the middleware.');
throw new Error("[Mappersmith] infinite loop detected (middleware stack invoked ".concat(executions, " times). Check the use of \"renew\" in one of the middleware."));
}

@@ -124,5 +125,7 @@

};
var callGateway = function callGateway() {
return new GatewayClass(finalRequest, gatewayConfigs).call();
};
var execute = middleware.reduce(chainResponsePhase, callGateway);

@@ -140,3 +143,3 @@ return execute();

};
exports.default = ClientBuilder;
var _default = ClientBuilder;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,15 +6,12 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
var _utils = require('./utils');
var _utils = require("./utils");
var _mappersmith = require('./mappersmith');
var _mappersmith = require("./mappersmith");
var _response = require('./response');
var _response = _interopRequireDefault(require("./response"));
var _response2 = _interopRequireDefault(_response);
var _timeoutError = _interopRequireDefault(require("./gateway/timeout-error"));
var _timeoutError = require('./gateway/timeout-error');
var _timeoutError2 = _interopRequireDefault(_timeoutError);
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

@@ -26,6 +23,7 @@

var configs = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
this.request = request;
this.configs = configs;
this.successCallback = function () {};
this.failCallback = function () {};

@@ -72,6 +70,6 @@ }

dispatchClientError: function dispatchClientError(message, error) {
if (_timeoutError2.default.isTimeoutError(error) && this.options().enableHTTP408OnTimeouts) {
this.failCallback(new _response2.default(this.request, 408, message, {}, [error]));
if (_timeoutError.default.isTimeoutError(error) && this.options().enableHTTP408OnTimeouts) {
this.failCallback(new _response.default(this.request, 408, message, {}, [error]));
} else {
this.failCallback(new _response2.default(this.request, 400, message, {}, [error]));
this.failCallback(new _response.default(this.request, 400, message, {}, [error]));
}

@@ -100,3 +98,3 @@ },

};
exports.default = Gateway;
var _default = Gateway;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,19 +6,14 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
var _gateway = require('../gateway');
var _gateway = _interopRequireDefault(require("../gateway"));
var _gateway2 = _interopRequireDefault(_gateway);
var _response = _interopRequireDefault(require("../response"));
var _response = require('../response');
var _mappersmith = require("../mappersmith");
var _response2 = _interopRequireDefault(_response);
var _utils = require("../utils");
var _mappersmith = require('../mappersmith');
var _timeoutError = _interopRequireDefault(require("./timeout-error"));
var _utils = require('../utils');
var _timeoutError = require('./timeout-error');
var _timeoutError2 = _interopRequireDefault(_timeoutError);
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

@@ -30,5 +25,4 @@

if (!fetch) {
throw new Error('[Mappersmith] global fetch does not exist, please assign "configs.fetch" to a valid implementation');
throw new Error("[Mappersmith] global fetch does not exist, please assign \"configs.fetch\" to a valid implementation");
}
/**

@@ -40,7 +34,9 @@ * Gateway which uses the "fetch" implementation configured in "configs.fetch".

*/
function Fetch(request) {
_gateway2.default.apply(this, arguments);
_gateway.default.apply(this, arguments);
}
Fetch.prototype = _gateway2.default.extends({
Fetch.prototype = _gateway.default.extends({
get: function get() {

@@ -74,3 +70,3 @@ this.performRequest('get');

var password = auth.password || '';
customHeaders['authorization'] = 'Basic ' + (0, _utils.btoa)(username + ':' + password);
customHeaders['authorization'] = "Basic ".concat((0, _utils.btoa)("".concat(username, ":").concat(password)));
}

@@ -80,5 +76,8 @@

var requestMethod = this.shouldEmulateHTTP() ? 'post' : method;
var init = (0, _utils.assign)({ method: requestMethod, headers: headers, body: body }, this.options());
var init = (0, _utils.assign)({
method: requestMethod,
headers: headers,
body: body
}, this.options());
var timeout = this.request.timeout();
var timer = null;

@@ -90,3 +89,4 @@ var canceled = false;

canceled = true;
var error = new _timeoutError2.default('Timeout (' + timeout + 'ms)');
var error = new _timeoutError.default("Timeout (".concat(timeout, "ms)"));
_this.dispatchClientError(error.message, error);

@@ -102,4 +102,4 @@ }, timeout);

clearTimeout(timer);
var responseData;
var responseData = void 0;
if (_this.request.isBinary()) {

@@ -124,2 +124,3 @@ if (typeof fetchResponse.buffer === 'function') {

clearTimeout(timer);
_this.dispatchClientError(error.message, error);

@@ -134,7 +135,6 @@ });

});
return new _response2.default(this.request, status, data, responseHeaders);
return new _response.default(this.request, status, data, responseHeaders);
}
});
exports.default = Fetch;
var _default = Fetch;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,36 +6,25 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
var _url = require('url');
var _url = _interopRequireDefault(require("url"));
var _url2 = _interopRequireDefault(_url);
var _http = _interopRequireDefault(require("http"));
var _http = require('http');
var _https = _interopRequireDefault(require("https"));
var _http2 = _interopRequireDefault(_http);
var _utils = require("../utils");
var _https = require('https');
var _gateway = _interopRequireDefault(require("../gateway"));
var _https2 = _interopRequireDefault(_https);
var _response = _interopRequireDefault(require("../response"));
var _utils = require('../utils');
var _timeoutError = _interopRequireDefault(require("./timeout-error"));
var _gateway = require('../gateway');
var _gateway2 = _interopRequireDefault(_gateway);
var _response = require('../response');
var _response2 = _interopRequireDefault(_response);
var _timeoutError = require('./timeout-error');
var _timeoutError2 = _interopRequireDefault(_timeoutError);
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
function HTTP(request) {
_gateway2.default.apply(this, arguments);
_gateway.default.apply(this, arguments);
}
HTTP.prototype = _gateway2.default.extends({
HTTP.prototype = _gateway.default.extends({
get: function get() {

@@ -63,7 +52,8 @@ this.performRequest('get');

var headers = {};
var defaults = _url2.default.parse(this.request.url());
var defaults = _url.default.parse(this.request.url());
var requestMethod = this.shouldEmulateHTTP() ? 'post' : method;
var body = this.prepareBody(method, headers);
var timeout = this.request.timeout();
this.canceled = false;

@@ -75,4 +65,3 @@

var handler = defaults.protocol === 'https:' ? _https2.default : _http2.default;
var handler = defaults.protocol === 'https:' ? _https.default : _http.default;
var requestParams = (0, _utils.assign)(defaults, {

@@ -82,8 +71,8 @@ method: requestMethod,

});
var auth = this.request.auth();
var auth = this.request.auth();
if (auth) {
var username = auth.username || '';
var password = auth.password || '';
requestParams['auth'] = username + ':' + password;
requestParams['auth'] = "".concat(username, ":").concat(password);
}

@@ -100,3 +89,2 @@

});
httpRequest.on('error', function (e) {

@@ -111,3 +99,4 @@ return _this.onError(e);

httpRequest.abort();
var error = new _timeoutError2.default('Timeout (' + timeout + 'ms)');
var error = new _timeoutError.default("Timeout (".concat(timeout, "ms)"));
_this.dispatchClientError(error.message, error);

@@ -146,6 +135,6 @@ });

createResponse: function createResponse(httpResponse, rawData) {
return new _response2.default(this.request, httpResponse.statusCode, this.request.isBinary() ? Buffer.concat(rawData) : rawData.join(''), httpResponse.headers);
return new _response.default(this.request, httpResponse.statusCode, this.request.isBinary() ? Buffer.concat(rawData) : rawData.join(''), httpResponse.headers);
}
});
exports.default = HTTP;
var _default = HTTP;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,16 +6,15 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
var _gateway = require('../gateway');
var _gateway = _interopRequireDefault(require("../gateway"));
var _gateway2 = _interopRequireDefault(_gateway);
var _test = require("../test");
var _test = require('../test');
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
function Mock(request) {
_gateway2.default.apply(this, arguments);
_gateway.default.apply(this, arguments);
}
Mock.prototype = _gateway2.default.extends({
Mock.prototype = _gateway.default.extends({
get: function get() {

@@ -43,3 +42,3 @@ this.callMock();

});
exports.default = Mock;
var _default = Mock;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,16 +6,37 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
function _typeof(obj) { if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
function _possibleConstructorReturn(self, call) { if (!self) { throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); } return call && (typeof call === "object" || typeof call === "function") ? call : self; }
function _possibleConstructorReturn(self, call) { if (call && (_typeof(call) === "object" || typeof call === "function")) { return call; } return _assertThisInitialized(self); }
function _inherits(subClass, superClass) { if (typeof superClass !== "function" && superClass !== null) { throw new TypeError("Super expression must either be null or a function, not " + typeof superClass); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, enumerable: false, writable: true, configurable: true } }); if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass; }
function _assertThisInitialized(self) { if (self === void 0) { throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); } return self; }
var TimeoutError = function (_Error) {
function _defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } }
function _createClass(Constructor, protoProps, staticProps) { if (protoProps) _defineProperties(Constructor.prototype, protoProps); if (staticProps) _defineProperties(Constructor, staticProps); return Constructor; }
function _inherits(subClass, superClass) { if (typeof superClass !== "function" && superClass !== null) { throw new TypeError("Super expression must either be null or a function"); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, writable: true, configurable: true } }); if (superClass) _setPrototypeOf(subClass, superClass); }
function _wrapNativeSuper(Class) { var _cache = typeof Map === "function" ? new Map() : undefined; _wrapNativeSuper = function _wrapNativeSuper(Class) { if (Class === null || !_isNativeFunction(Class)) return Class; if (typeof Class !== "function") { throw new TypeError("Super expression must either be null or a function"); } if (typeof _cache !== "undefined") { if (_cache.has(Class)) return _cache.get(Class); _cache.set(Class, Wrapper); } function Wrapper() { return _construct(Class, arguments, _getPrototypeOf(this).constructor); } Wrapper.prototype = Object.create(Class.prototype, { constructor: { value: Wrapper, enumerable: false, writable: true, configurable: true } }); return _setPrototypeOf(Wrapper, Class); }; return _wrapNativeSuper(Class); }
function isNativeReflectConstruct() { if (typeof Reflect === "undefined" || !Reflect.construct) return false; if (Reflect.construct.sham) return false; if (typeof Proxy === "function") return true; try { Date.prototype.toString.call(Reflect.construct(Date, [], function () {})); return true; } catch (e) { return false; } }
function _construct(Parent, args, Class) { if (isNativeReflectConstruct()) { _construct = Reflect.construct; } else { _construct = function _construct(Parent, args, Class) { var a = [null]; a.push.apply(a, args); var Constructor = Function.bind.apply(Parent, a); var instance = new Constructor(); if (Class) _setPrototypeOf(instance, Class.prototype); return instance; }; } return _construct.apply(null, arguments); }
function _isNativeFunction(fn) { return Function.toString.call(fn).indexOf("[native code]") !== -1; }
function _setPrototypeOf(o, p) { _setPrototypeOf = Object.setPrototypeOf || function _setPrototypeOf(o, p) { o.__proto__ = p; return o; }; return _setPrototypeOf(o, p); }
function _getPrototypeOf(o) { _getPrototypeOf = Object.setPrototypeOf ? Object.getPrototypeOf : function _getPrototypeOf(o) { return o.__proto__ || Object.getPrototypeOf(o); }; return _getPrototypeOf(o); }
var TimeoutError =
/*#__PURE__*/
function (_Error) {
_inherits(TimeoutError, _Error);
_createClass(TimeoutError, null, [{
key: 'isTimeoutError',
key: "isTimeoutError",
value: function isTimeoutError(e) {

@@ -27,6 +48,7 @@ return e && e.name === 'TimeoutError';

function TimeoutError(message) {
var _this;
_classCallCheck(this, TimeoutError);
var _this = _possibleConstructorReturn(this, (TimeoutError.__proto__ || Object.getPrototypeOf(TimeoutError)).call(this));
_this = _possibleConstructorReturn(this, _getPrototypeOf(TimeoutError).call(this));
_this.message = message;

@@ -38,4 +60,4 @@ _this.name = 'TimeoutError';

return TimeoutError;
}(Error);
}(_wrapNativeSuper(Error));
exports.default = TimeoutError;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,17 +6,12 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
var _gateway = require('../gateway');
var _gateway = _interopRequireDefault(require("../gateway"));
var _gateway2 = _interopRequireDefault(_gateway);
var _response = _interopRequireDefault(require("../response"));
var _response = require('../response');
var _utils = require("../utils");
var _response2 = _interopRequireDefault(_response);
var _timeoutError = _interopRequireDefault(require("./timeout-error"));
var _utils = require('../utils');
var _timeoutError = require('./timeout-error');
var _timeoutError2 = _interopRequireDefault(_timeoutError);
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

@@ -27,6 +22,6 @@

function XHR(request) {
_gateway2.default.apply(this, arguments);
_gateway.default.apply(this, arguments);
}
XHR.prototype = _gateway2.default.extends({
XHR.prototype = _gateway.default.extends({
get: function get() {

@@ -70,3 +65,2 @@ var xmlHttpRequest = this.createXHR();

this.timer = null;
var timeout = this.request.timeout();

@@ -79,10 +73,11 @@

clearTimeout(_this.timer);
var error = new _timeoutError2.default('Timeout (' + timeout + 'ms)');
var error = new _timeoutError.default("Timeout (".concat(timeout, "ms)"));
_this.dispatchClientError(error.message, error);
});
}); // PhantomJS doesn't support timeout for XMLHttpRequest
// PhantomJS doesn't support timeout for XMLHttpRequest
this.timer = setTimeout(function () {
_this.canceled = true;
var error = new _timeoutError2.default('Timeout (' + timeout + 'ms)');
var error = new _timeoutError.default("Timeout (".concat(timeout, "ms)"));
_this.dispatchClientError(error.message, error);

@@ -101,5 +96,5 @@ }, timeout + 1);

clearTimeout(_this2.timer);
_this2.dispatchResponse(_this2.createResponse(xmlHttpRequest));
});
xmlHttpRequest.addEventListener('error', function (e) {

@@ -112,10 +107,10 @@ if (_this2.canceled) {

var guessedErrorCause = e ? e.message || e.name : xmlHttpRequest.responseText;
var errorMessage = 'Network error';
var enhancedMessage = guessedErrorCause ? ": ".concat(guessedErrorCause) : '';
var error = new Error("".concat(errorMessage).concat(enhancedMessage));
var errorMessage = 'Network error';
var enhancedMessage = guessedErrorCause ? ': ' + guessedErrorCause : '';
var error = new Error('' + errorMessage + enhancedMessage);
_this2.dispatchClientError(errorMessage, error);
});
var xhrOptions = this.options().XHR;
var xhrOptions = this.options().XHR;
if (xhrOptions.withCredentials) {

@@ -133,3 +128,2 @@ xmlHttpRequest.withCredentials = true;

xmlHttpRequest.open(requestMethod.toUpperCase(), this.request.url(), true);
var customHeaders = {};

@@ -140,6 +134,4 @@ var body = this.prepareBody(method, customHeaders);

this.configureBinary(xmlHttpRequest);
var args = [];
body && args.push(body);
xmlHttpRequest.send.apply(xmlHttpRequest, args);

@@ -151,10 +143,11 @@ },

var responseHeaders = (0, _utils.parseResponseHeaders)(xmlHttpRequest.getAllResponseHeaders());
return new _response2.default(this.request, status, data, responseHeaders);
return new _response.default(this.request, status, data, responseHeaders);
},
setHeaders: function setHeaders(xmlHttpRequest, customHeaders) {
var auth = this.request.auth();
if (auth) {
var username = auth.username || '';
var password = auth.password || '';
customHeaders['authorization'] = 'Basic ' + toBase64(username + ':' + password);
customHeaders['authorization'] = "Basic ".concat(toBase64("".concat(username, ":").concat(password)));
}

@@ -169,2 +162,3 @@

var xmlHttpRequest = new XMLHttpRequest(); // eslint-disable-line no-undef
this.configureCallbacks(xmlHttpRequest);

@@ -174,3 +168,3 @@ return xmlHttpRequest;

});
exports.default = XHR;
var _default = XHR;
exports.default = _default;

@@ -1,7 +0,8 @@

'use strict';
"use strict";
var lib = require('./mappersmith');
var _process, defaultGateway;
// Prevents webpack to load the nodejs processs polyfill
var _process, defaultGateway; // Prevents webpack to load the nodejs processs polyfill
try {

@@ -11,2 +12,3 @@ _process = eval('typeof process === "object" ? process : undefined');

if (typeof XMLHttpRequest !== 'undefined') {

@@ -13,0 +15,0 @@ // For browsers use XHR adapter

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,13 +6,18 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
var _methodDescriptor = require('./method-descriptor');
var _methodDescriptor = _interopRequireDefault(require("./method-descriptor"));
var _methodDescriptor2 = _interopRequireDefault(_methodDescriptor);
var _utils = require("./utils");
var _utils = require('./utils');
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
function _toConsumableArray(arr) { if (Array.isArray(arr)) { for (var i = 0, arr2 = Array(arr.length); i < arr.length; i++) { arr2[i] = arr[i]; } return arr2; } else { return Array.from(arr); } }
function _toConsumableArray(arr) { return _arrayWithoutHoles(arr) || _iterableToArray(arr) || _nonIterableSpread(); }
function _nonIterableSpread() { throw new TypeError("Invalid attempt to spread non-iterable instance"); }
function _iterableToArray(iter) { if (Symbol.iterator in Object(iter) || Object.prototype.toString.call(iter) === "[object Arguments]") return Array.from(iter); }
function _arrayWithoutHoles(arr) { if (Array.isArray(arr)) { for (var i = 0, arr2 = new Array(arr.length); i < arr.length; i++) { arr2[i] = arr[i]; } return arr2; } }
/**

@@ -30,9 +35,12 @@ * @typedef Manifest

var _ref$gatewayConfigs = _ref.gatewayConfigs,
gatewayConfigs = _ref$gatewayConfigs === undefined ? null : _ref$gatewayConfigs,
gatewayConfigs = _ref$gatewayConfigs === void 0 ? null : _ref$gatewayConfigs,
_ref$middleware = _ref.middleware,
middleware = _ref$middleware === undefined ? [] : _ref$middleware,
middleware = _ref$middleware === void 0 ? [] : _ref$middleware,
_ref$context = _ref.context,
context = _ref$context === undefined ? {} : _ref$context;
context = _ref$context === void 0 ? {} : _ref$context;
this.host = obj.host;
this.bodyAttr = obj.bodyAttr;
this.headersAttr = obj.headersAttr;
this.authAttr = obj.authAttr;
this.timeoutAttr = obj.timeoutAttr;
this.clientId = obj.clientId || null;

@@ -42,10 +50,8 @@ this.gatewayConfigs = (0, _utils.assign)({}, gatewayConfigs, obj.gatewayConfigs);

this.context = context;
var clientMiddleware = obj.middleware || obj.middlewares || []; // TODO: deprecate obj.middlewares in favor of obj.middleware
var clientMiddleware = obj.middleware || obj.middlewares || [];
// TODO: deprecate obj.middlewares in favor of obj.middleware
if (obj.ignoreGlobalMiddleware) {
this.middleware = clientMiddleware;
} else {
this.middleware = [].concat(_toConsumableArray(clientMiddleware), _toConsumableArray(middleware));
this.middleware = _toConsumableArray(clientMiddleware).concat(_toConsumableArray(middleware));
}

@@ -76,9 +82,14 @@ }

if (!definition || !definition.path) {
throw new Error('[Mappersmith] path is undefined for resource "' + resourceName + '" method "' + methodName + '"');
throw new Error("[Mappersmith] path is undefined for resource \"".concat(resourceName, "\" method \"").concat(methodName, "\""));
}
return new _methodDescriptor2.default((0, _utils.assign)({ host: this.host }, definition));
return new _methodDescriptor.default((0, _utils.assign)({
host: this.host,
bodyAttr: this.bodyAttr,
headersAttr: this.headersAttr,
authAttr: this.authAttr,
timeoutAttr: this.timeoutAttr
}, definition));
},
/**

@@ -108,3 +119,6 @@ * @param {Object} args

}
}, middlewareFactory((0, _utils.assign)(args, { clientId: _this2.clientId, context: (0, _utils.assign)({}, _this2.context) })));
}, middlewareFactory((0, _utils.assign)(args, {
clientId: _this2.clientId,
context: (0, _utils.assign)({}, _this2.context)
})));
};

@@ -115,3 +129,3 @@

};
exports.default = Manifest;
var _default = Manifest;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,21 +6,20 @@ Object.defineProperty(exports, "__esModule", {

});
exports.setContext = exports.configs = exports.version = undefined;
exports.default = forge;
exports.setContext = exports.configs = exports.version = void 0;
var _clientBuilder = require('./client-builder');
var _clientBuilder = _interopRequireDefault(require("./client-builder"));
var _clientBuilder2 = _interopRequireDefault(_clientBuilder);
var _utils = require("./utils");
var _utils = require('./utils');
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
/* global VERSION */
var version = exports.version = '2.25.0';
var configs = exports.configs = {
var version = "2.25.1";
exports.version = version;
var configs = {
context: {},
middleware: [],
Promise: typeof Promise === 'function' ? Promise : null,
fetch: typeof fetch === 'function' ? fetch : null, // eslint-disable-line no-undef
fetch: typeof fetch === 'function' ? fetch : null,
// eslint-disable-line no-undef

@@ -56,3 +55,2 @@ /**

enableHTTP408OnTimeouts: false,
XHR: {

@@ -77,3 +75,2 @@ /**

},
HTTP: {

@@ -90,3 +87,2 @@ /**

},
Fetch: {

@@ -108,13 +104,19 @@ /**

}
/**
* @param {Object} context
*/
};var setContext = exports.setContext = function setContext(context) {
};
exports.configs = configs;
var setContext = function setContext(context) {
configs.context = (0, _utils.assign)(configs.context, context);
};
/**
* @param {Object} manifest
*/
exports.setContext = setContext;
function forge(manifest) {

@@ -124,3 +126,4 @@ var GatewayClassFactory = function GatewayClassFactory() {

};
return new _clientBuilder2.default(manifest, GatewayClassFactory, configs).build();
return new _clientBuilder.default(manifest, GatewayClassFactory, configs).build();
}

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -7,2 +7,3 @@ Object.defineProperty(exports, "__esModule", {

exports.default = MethodDescriptor;
/**

@@ -30,3 +31,2 @@ * @typedef MethodDescriptor

this.binary = obj.binary || false;
this.bodyAttr = obj.bodyAttr || 'body';

@@ -33,0 +33,0 @@ this.headersAttr = obj.headersAttr || 'headers';

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,4 +6,5 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
var _utils = require('../utils');
var _utils = require("../utils");

@@ -23,3 +24,3 @@ /**

*/
exports.default = function (authConfig) {
var _default = function _default(authConfig) {
return function BasicAuthMiddleware() {

@@ -29,7 +30,12 @@ return {

var auth = _request.auth();
return !auth // Keep the override
? _request.enhance({ auth: (0, _utils.assign)({}, authConfig) }) : _request;
? _request.enhance({
auth: (0, _utils.assign)({}, authConfig)
}) : _request;
}
};
};
};
};
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,2 +6,3 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;

@@ -13,3 +14,3 @@ function _defineProperty(obj, key, value) { if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }

*/
exports.default = function () {
var _default = function _default() {
var cookieName = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : 'csrfToken';

@@ -19,2 +20,3 @@ var headerName = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : 'x-csrf-token';

var REGEXP_COOKIE_NAME = new RegExp(cookieName + '[^;]+');
var getCookie = function getCookie() {

@@ -32,3 +34,2 @@ var cookieString = REGEXP_COOKIE_NAME.exec((document || {}).cookie || '');

var csrf = getCookie();
return !csrf ? _request : _request.enhance({

@@ -40,2 +41,4 @@ headers: _defineProperty({}, headerName, csrf)

};
};
};
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,2 +6,4 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
/**

@@ -14,3 +16,5 @@ * Adds started_at, ended_at and duration headers to the response

return _request.enhance({
headers: { 'X-Started-At': Date.now() }
headers: {
'X-Started-At': Date.now()
}
});

@@ -22,3 +26,2 @@ },

var startedAt = response.request().headers()['x-started-at'];
return response.enhance({

@@ -36,2 +39,3 @@ headers: {

exports.default = DurationMiddleware;
var _default = DurationMiddleware;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,4 +6,4 @@ Object.defineProperty(exports, "__esModule", {

});
var CONTENT_TYPE_JSON = exports.CONTENT_TYPE_JSON = 'application/json;charset=utf-8';
exports.default = exports.CONTENT_TYPE_JSON = void 0;
var CONTENT_TYPE_JSON = 'application/json;charset=utf-8';
/**

@@ -17,2 +17,5 @@ * Automatically encode your objects into JSON

*/
exports.CONTENT_TYPE_JSON = CONTENT_TYPE_JSON;
var EncodeJsonMiddleware = function EncodeJsonMiddleware() {

@@ -24,3 +27,5 @@ return {

return _request.enhance({
headers: { 'content-type': CONTENT_TYPE_JSON },
headers: {
'content-type': CONTENT_TYPE_JSON
},
body: JSON.stringify(_request.body())

@@ -30,2 +35,3 @@ });

} catch (e) {}
return _request;

@@ -36,2 +42,3 @@ }

exports.default = EncodeJsonMiddleware;
var _default = EncodeJsonMiddleware;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,12 +6,11 @@ Object.defineProperty(exports, "__esModule", {

});
exports.setErrorHandler = undefined;
exports.default = exports.setErrorHandler = void 0;
var _index = require('../index');
var _index = require("../index");
var handler = null;
var setErrorHandler = exports.setErrorHandler = function setErrorHandler(errorHandler) {
var setErrorHandler = function setErrorHandler(errorHandler) {
handler = errorHandler;
};
/**

@@ -21,2 +20,6 @@ * Provides a catch-all function for all requests. If the catch-all

*/
exports.setErrorHandler = setErrorHandler;
var GlobalErrorHandlerMiddleware = function GlobalErrorHandlerMiddleware() {

@@ -38,2 +41,3 @@ return {

exports.default = GlobalErrorHandlerMiddleware;
var _default = GlobalErrorHandlerMiddleware;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,3 +6,5 @@ Object.defineProperty(exports, "__esModule", {

});
var defaultSuccessLogger = exports.defaultSuccessLogger = function defaultSuccessLogger(message) {
exports.default = exports.setLoggerEnabled = exports.setErrorLogger = exports.setSuccessLogger = exports.defaultErrorLogger = exports.defaultSuccessLogger = void 0;
var defaultSuccessLogger = function defaultSuccessLogger(message) {
var logger = console.info ? console.info : console.log;

@@ -12,3 +14,5 @@ logger(message);

var defaultErrorLogger = exports.defaultErrorLogger = function defaultErrorLogger(message) {
exports.defaultSuccessLogger = defaultSuccessLogger;
var defaultErrorLogger = function defaultErrorLogger(message) {
var logger = console.error ? console.error : console.log;

@@ -18,2 +22,3 @@ logger(message);

exports.defaultErrorLogger = defaultErrorLogger;
var isLoggerEnabled = console && console.log;

@@ -23,22 +28,29 @@ var successLogger = defaultSuccessLogger;

var setSuccessLogger = exports.setSuccessLogger = function setSuccessLogger(logger) {
var setSuccessLogger = function setSuccessLogger(logger) {
successLogger = logger;
};
var setErrorLogger = exports.setErrorLogger = function setErrorLogger(logger) {
exports.setSuccessLogger = setSuccessLogger;
var setErrorLogger = function setErrorLogger(logger) {
errorLogger = logger;
};
var setLoggerEnabled = exports.setLoggerEnabled = function setLoggerEnabled(value) {
exports.setErrorLogger = setErrorLogger;
var setLoggerEnabled = function setLoggerEnabled(value) {
isLoggerEnabled = value;
};
exports.setLoggerEnabled = setLoggerEnabled;
var log = function log(request, response) {
if (isLoggerEnabled) {
var httpCall = request.method().toUpperCase() + ' ' + request.url();
var httpCall = "".concat(request.method().toUpperCase(), " ").concat(request.url());
var direction = response ? '<-' : '->';
var isError = response && !response.success();
var errorLabel = isError ? '(ERROR) ' : '';
var extra = response ? ' status=' + response.status() + ' \'' + response.rawData() + '\'' : '';
var extra = response ? " status=".concat(response.status(), " '").concat(response.rawData(), "'") : '';
var logger = isError ? errorLogger : successLogger;
logger(direction + ' ' + errorLabel + httpCall + extra);
logger("".concat(direction, " ").concat(errorLabel).concat(httpCall).concat(extra));
}

@@ -48,6 +60,7 @@

};
/**
* Log all requests and responses.
*/
var ConsoleLogMiddleware = function ConsoleLogMiddleware() {

@@ -69,2 +82,3 @@ return {

exports.default = ConsoleLogMiddleware;
var _default = ConsoleLogMiddleware;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,12 +6,9 @@ Object.defineProperty(exports, "__esModule", {

});
var _v = require('./v1');
Object.defineProperty(exports, 'default', {
Object.defineProperty(exports, "default", {
enumerable: true,
get: function get() {
return _interopRequireDefault(_v).default;
return _v.default;
}
});
Object.defineProperty(exports, 'setRetryConfigs', {
Object.defineProperty(exports, "setRetryConfigs", {
enumerable: true,

@@ -22,3 +19,3 @@ get: function get() {

});
Object.defineProperty(exports, 'calculateExponentialRetryTime', {
Object.defineProperty(exports, "calculateExponentialRetryTime", {
enumerable: true,

@@ -30,2 +27,4 @@ get: function get() {

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
var _v = _interopRequireWildcard(require("./v1"));
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { var desc = Object.defineProperty && Object.getOwnPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : {}; if (desc.get || desc.set) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } } newObj.default = obj; return newObj; } }

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,14 +6,12 @@ Object.defineProperty(exports, "__esModule", {

});
exports.calculateExponentialRetryTime = exports.setRetryConfigs = undefined;
exports.default = RetryMiddleware;
exports.calculateExponentialRetryTime = exports.setRetryConfigs = void 0;
var _utils = require('../../../utils');
var _utils = require("../../../utils");
var _v = require('../v2');
var _v = _interopRequireWildcard(require("../v2"));
var _v2 = _interopRequireDefault(_v);
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { var desc = Object.defineProperty && Object.getOwnPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : {}; if (desc.get || desc.set) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } } newObj.default = obj; return newObj; } }
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
var retryConfigs = (0, _utils.assign)({}, _v.defaultRetryConfigs);
/**

@@ -33,7 +31,8 @@ * @deprecated The use of setRetryConfigs is deprecated as it sets a global config

*/
var setRetryConfigs = exports.setRetryConfigs = function setRetryConfigs(newConfigs) {
var setRetryConfigs = function setRetryConfigs(newConfigs) {
console.warn('The use of setRetryConfigs is deprecated - use RetryMiddleware v2 instead.');
retryConfigs = (0, _utils.assign)({}, retryConfigs, newConfigs);
middlewareInstance = (0, _v.default)(retryConfigs)();
};
/**

@@ -54,6 +53,17 @@ * This middleware will automatically retry GET requests up to the configured amount of

*/
var RetryMiddleware = (0, _v2.default)(retryConfigs);
exports.default = RetryMiddleware;
exports.setRetryConfigs = setRetryConfigs;
var middlewareInstance = (0, _v.default)(retryConfigs)();
function RetryMiddleware() {
return {
request: function request(_request) {
return middlewareInstance.request(_request);
},
response: function response(next) {
return middlewareInstance.response(next);
}
};
}
/**

@@ -67,6 +77,9 @@ * Increases the retry time for each attempt using a randomization function that grows exponentially.

var calculateExponentialRetryTime = exports.calculateExponentialRetryTime = function calculateExponentialRetryTime(retryTime) {
var calculateExponentialRetryTime = function calculateExponentialRetryTime(retryTime) {
return Math.min(randomFromRetryTime(retryTime) * retryConfigs.multiplier, retryConfigs.maxRetryTimeInSecs * 1000);
};
exports.calculateExponentialRetryTime = calculateExponentialRetryTime;
var randomFromRetryTime = function randomFromRetryTime(retryTime) {

@@ -73,0 +86,0 @@ var delta = retryConfigs.factor * retryTime;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,11 +6,15 @@ Object.defineProperty(exports, "__esModule", {

});
exports.calculateExponentialRetryTime = exports.defaultRetryConfigs = undefined;
exports.calculateExponentialRetryTime = exports.default = exports.defaultRetryConfigs = void 0;
var _index = require('../../../index');
var _index = require("../../../index");
var _utils = require('../../../utils');
var _utils = require("../../../utils");
var _response = _interopRequireDefault(require("../../../response"));
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
function _defineProperty(obj, key, value) { if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }
var defaultRetryConfigs = exports.defaultRetryConfigs = {
var defaultRetryConfigs = {
headerRetryCount: 'X-Mappersmith-Retry-Count',

@@ -20,5 +24,8 @@ headerRetryTime: 'X-Mappersmith-Retry-Time',

initialRetryTimeInSecs: 0.1,
factor: 0.2, // randomization factor
multiplier: 2, // exponential factor
retries: 5, // max retries
factor: 0.2,
// randomization factor
multiplier: 2,
// exponential factor
retries: 5,
// max retries
validateRetry: function validateRetry(response) {

@@ -28,3 +35,2 @@ return response.responseStatus >= 500;

/**

@@ -52,4 +58,7 @@ * This middleware will automatically retry GET requests up to the configured amount of

*/
};
exports.default = function () {
exports.defaultRetryConfigs = defaultRetryConfigs;
var _default = function _default() {
var customConfigs = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};

@@ -60,5 +69,8 @@ return function RetryMiddleware() {

this.enableRetry = _request.method() === 'get';
this.inboundRequest = _request;
return _request;
},
response: function response(next) {
var _this = this;
var retryConfigs = (0, _utils.assign)({}, defaultRetryConfigs, customConfigs);

@@ -72,3 +84,3 @@

var retryTime = retryConfigs.initialRetryTimeInSecs * 1000;
retriableRequest(resolve, reject, next)(randomFromRetryTime(retryTime, retryConfigs.factor), 0, retryConfigs);
retriableRequest(resolve, reject, next, _this.inboundRequest)(randomFromRetryTime(retryTime, retryConfigs.factor), 0, retryConfigs);
});

@@ -80,6 +92,9 @@ }

var retriableRequest = function retriableRequest(resolve, reject, next) {
exports.default = _default;
var retriableRequest = function retriableRequest(resolve, reject, next, request) {
var retry = function retry(retryTime, retryCount, retryConfigs) {
var nextRetryTime = calculateExponentialRetryTime(retryTime, retryConfigs);
var shouldRetry = retryCount < retryConfigs.retries;
var scheduleRequest = function scheduleRequest() {

@@ -92,5 +107,23 @@ setTimeout(function () {

next().then(function (response) {
shouldRetry && retryConfigs.validateRetry(response) ? scheduleRequest() : resolve(enhancedResponse(response, retryConfigs.headerRetryCount, retryCount, retryConfigs.headerRetryTime, retryTime));
if (shouldRetry && retryConfigs.validateRetry(response)) {
scheduleRequest();
} else {
try {
resolve(enhancedResponse(response, retryConfigs.headerRetryCount, retryCount, retryConfigs.headerRetryTime, retryTime));
} catch (e) {
var errorMessage = response instanceof Error ? response.message : e.message;
reject(new _response.default(request, 400, errorMessage, {}, [response]));
}
}
}).catch(function (response) {
shouldRetry && retryConfigs.validateRetry(response) ? scheduleRequest() : reject(enhancedResponse(response, retryConfigs.headerRetryCount, retryCount, retryConfigs.headerRetryTime, retryTime));
if (shouldRetry && retryConfigs.validateRetry(response)) {
scheduleRequest();
} else {
try {
reject(enhancedResponse(response, retryConfigs.headerRetryCount, retryCount, retryConfigs.headerRetryTime, retryTime));
} catch (e) {
var errorMessage = response instanceof Error ? response.message : e.message;
reject(new _response.default(request, 400, errorMessage, {}, [response]));
}
}
});

@@ -101,3 +134,2 @@ };

};
/**

@@ -110,6 +142,10 @@ * Increases the retry time for each attempt using a randomization function that grows exponentially.

*/
var calculateExponentialRetryTime = exports.calculateExponentialRetryTime = function calculateExponentialRetryTime(retryTime, retryConfigs) {
var calculateExponentialRetryTime = function calculateExponentialRetryTime(retryTime, retryConfigs) {
return Math.min(randomFromRetryTime(retryTime, retryConfigs.factor) * retryConfigs.multiplier, retryConfigs.maxRetryTimeInSecs * 1000);
};
exports.calculateExponentialRetryTime = calculateExponentialRetryTime;
var randomFromRetryTime = function randomFromRetryTime(retryTime, factor) {

@@ -116,0 +152,0 @@ var delta = factor * retryTime;

@@ -6,2 +6,3 @@ "use strict";

});
exports.default = void 0;

@@ -20,3 +21,3 @@ /**

*/
exports.default = function (timeoutValue) {
var _default = function _default(timeoutValue) {
return function TimeoutMiddleware() {

@@ -26,7 +27,12 @@ return {

var timeout = _request.timeout();
return !timeout // Keep the override
? _request.enhance({ timeout: timeoutValue }) : _request;
? _request.enhance({
timeout: timeoutValue
}) : _request;
}
};
};
};
};
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,12 +6,11 @@ Object.defineProperty(exports, "__esModule", {

});
var _basicAuth = require('../middleware/basic-auth');
Object.defineProperty(exports, 'default', {
Object.defineProperty(exports, "default", {
enumerable: true,
get: function get() {
return _interopRequireDefault(_basicAuth).default;
return _basicAuth.default;
}
});
var _basicAuth = _interopRequireDefault(require("../middleware/basic-auth"));
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,12 +6,11 @@ Object.defineProperty(exports, "__esModule", {

});
var _csrf = require('../middleware/csrf');
Object.defineProperty(exports, 'default', {
Object.defineProperty(exports, "default", {
enumerable: true,
get: function get() {
return _interopRequireDefault(_csrf).default;
return _csrf.default;
}
});
var _csrf = _interopRequireDefault(require("../middleware/csrf"));
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,12 +6,11 @@ Object.defineProperty(exports, "__esModule", {

});
var _duration = require('../middleware/duration');
Object.defineProperty(exports, 'default', {
Object.defineProperty(exports, "default", {
enumerable: true,
get: function get() {
return _interopRequireDefault(_duration).default;
return _duration.default;
}
});
var _duration = _interopRequireDefault(require("../middleware/duration"));
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,12 +6,9 @@ Object.defineProperty(exports, "__esModule", {

});
var _encodeJson = require('../middleware/encode-json');
Object.defineProperty(exports, 'default', {
Object.defineProperty(exports, "default", {
enumerable: true,
get: function get() {
return _interopRequireDefault(_encodeJson).default;
return _encodeJson.default;
}
});
Object.defineProperty(exports, 'CONTENT_TYPE_JSON', {
Object.defineProperty(exports, "CONTENT_TYPE_JSON", {
enumerable: true,

@@ -23,2 +20,4 @@ get: function get() {

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
var _encodeJson = _interopRequireWildcard(require("../middleware/encode-json"));
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { var desc = Object.defineProperty && Object.getOwnPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : {}; if (desc.get || desc.set) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } } newObj.default = obj; return newObj; } }

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,12 +6,9 @@ Object.defineProperty(exports, "__esModule", {

});
var _globalErrorHandler = require('../middleware/global-error-handler');
Object.defineProperty(exports, 'default', {
Object.defineProperty(exports, "default", {
enumerable: true,
get: function get() {
return _interopRequireDefault(_globalErrorHandler).default;
return _globalErrorHandler.default;
}
});
Object.defineProperty(exports, 'setErrorHandler', {
Object.defineProperty(exports, "setErrorHandler", {
enumerable: true,

@@ -23,2 +20,4 @@ get: function get() {

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
var _globalErrorHandler = _interopRequireWildcard(require("../middleware/global-error-handler"));
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { var desc = Object.defineProperty && Object.getOwnPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : {}; if (desc.get || desc.set) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } } newObj.default = obj; return newObj; } }

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,12 +6,9 @@ Object.defineProperty(exports, "__esModule", {

});
var _log = require('../middleware/log');
Object.defineProperty(exports, 'default', {
Object.defineProperty(exports, "default", {
enumerable: true,
get: function get() {
return _interopRequireDefault(_log).default;
return _log.default;
}
});
Object.defineProperty(exports, 'defaultSuccessLogger', {
Object.defineProperty(exports, "defaultSuccessLogger", {
enumerable: true,

@@ -22,3 +19,3 @@ get: function get() {

});
Object.defineProperty(exports, 'defaultErrorLogger', {
Object.defineProperty(exports, "defaultErrorLogger", {
enumerable: true,

@@ -29,3 +26,3 @@ get: function get() {

});
Object.defineProperty(exports, 'setSuccessLogger', {
Object.defineProperty(exports, "setSuccessLogger", {
enumerable: true,

@@ -36,3 +33,3 @@ get: function get() {

});
Object.defineProperty(exports, 'setErrorLogger', {
Object.defineProperty(exports, "setErrorLogger", {
enumerable: true,

@@ -43,3 +40,3 @@ get: function get() {

});
Object.defineProperty(exports, 'setLoggerEnabled', {
Object.defineProperty(exports, "setLoggerEnabled", {
enumerable: true,

@@ -51,2 +48,4 @@ get: function get() {

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
var _log = _interopRequireWildcard(require("../middleware/log"));
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { var desc = Object.defineProperty && Object.getOwnPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : {}; if (desc.get || desc.set) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } } newObj.default = obj; return newObj; } }

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,12 +6,9 @@ Object.defineProperty(exports, "__esModule", {

});
var _retry = require('../../middleware/retry');
Object.defineProperty(exports, 'default', {
Object.defineProperty(exports, "default", {
enumerable: true,
get: function get() {
return _interopRequireDefault(_retry).default;
return _retry.default;
}
});
Object.defineProperty(exports, 'setRetryConfigs', {
Object.defineProperty(exports, "setRetryConfigs", {
enumerable: true,

@@ -22,3 +19,3 @@ get: function get() {

});
Object.defineProperty(exports, 'calculateExponentialRetryTime', {
Object.defineProperty(exports, "calculateExponentialRetryTime", {
enumerable: true,

@@ -30,2 +27,4 @@ get: function get() {

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
var _retry = _interopRequireWildcard(require("../../middleware/retry"));
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { var desc = Object.defineProperty && Object.getOwnPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : {}; if (desc.get || desc.set) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } } newObj.default = obj; return newObj; } }

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,12 +6,9 @@ Object.defineProperty(exports, "__esModule", {

});
var _v = require('../../../middleware/retry/v2');
Object.defineProperty(exports, 'default', {
Object.defineProperty(exports, "default", {
enumerable: true,
get: function get() {
return _interopRequireDefault(_v).default;
return _v.default;
}
});
Object.defineProperty(exports, 'calculateExponentialRetryTime', {
Object.defineProperty(exports, "calculateExponentialRetryTime", {
enumerable: true,

@@ -23,2 +20,4 @@ get: function get() {

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
var _v = _interopRequireWildcard(require("../../../middleware/retry/v2"));
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { var desc = Object.defineProperty && Object.getOwnPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : {}; if (desc.get || desc.set) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } } newObj.default = obj; return newObj; } }

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,12 +6,11 @@ Object.defineProperty(exports, "__esModule", {

});
var _timeout = require('../middleware/timeout');
Object.defineProperty(exports, 'default', {
Object.defineProperty(exports, "default", {
enumerable: true,
get: function get() {
return _interopRequireDefault(_timeout).default;
return _timeout.default;
}
});
var _timeout = _interopRequireDefault(require("../middleware/timeout"));
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

@@ -6,2 +6,4 @@ "use strict";

});
exports.default = void 0;
/**

@@ -14,5 +16,7 @@ * @typedef MockAssert

};
this.callsCount = function () {
return calls.length;
};
this.mostRecentCall = function () {

@@ -23,2 +27,3 @@ return calls[calls.length - 1] || null;

exports.default = MockAssert;
var _default = MockAssert;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,13 +6,10 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
var _mockAssert = require('./mock-assert');
var _mockAssert = _interopRequireDefault(require("./mock-assert"));
var _mockAssert2 = _interopRequireDefault(_mockAssert);
var _response = _interopRequireDefault(require("../response"));
var _response = require('../response');
var _utils = require("../utils");
var _response2 = _interopRequireDefault(_response);
var _utils = require('../utils');
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

@@ -33,3 +30,2 @@

this.id = id;
this.method = props.method || 'get';

@@ -43,3 +39,2 @@ this.urlFunction = typeof props.url === 'function';

this.responseStatus = props.response.status || 200;
this.calls = [];

@@ -57,2 +52,3 @@ }

this.responseData = JSON.stringify(responseData);
if (!this.responseHeaders['content-type']) {

@@ -66,3 +62,2 @@ this.responseHeaders['content-type'] = 'application/json';

/**

@@ -73,6 +68,5 @@ * @return {Response}

this.calls.push(request);
return new _response2.default(request, this.responseStatus, this.responseData, this.responseHeaders);
return new _response.default(request, this.responseStatus, this.responseData, this.responseHeaders);
},
/**

@@ -82,6 +76,5 @@ * @return {MockAssert}

assertObject: function assertObject() {
return new _mockAssert2.default(this.calls);
return new _mockAssert.default(this.calls);
},
/**

@@ -94,9 +87,6 @@ * Checks if the request matches with the mock HTTP method, URL and body

var bodyMatch = this.bodyFunction ? this.body(request.body()) : this.body === (0, _utils.toQueryString)(request.body());
var urlMatch = this.urlFunction ? this.url(request.url(), request.params()) : this.url === request.url();
return this.method === request.method() && urlMatch && bodyMatch;
},
/**

@@ -111,3 +101,2 @@ * Checks if the request partially matches the mock HTTP method and URL

/**

@@ -120,3 +109,3 @@ * @return {MockRequest}

};
exports.default = MockRequest;
var _default = MockRequest;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,19 +6,13 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
var _mockRequest = require('./mock-request');
var _mockRequest = _interopRequireDefault(require("./mock-request"));
var _mockRequest2 = _interopRequireDefault(_mockRequest);
var _mockAssert = _interopRequireDefault(require("./mock-assert"));
var _mockAssert = require('./mock-assert');
var _request = _interopRequireDefault(require("../request"));
var _mockAssert2 = _interopRequireDefault(_mockAssert);
var _request = require('../request');
var _request2 = _interopRequireDefault(_request);
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
var VALUE_NOT_MATCHED = '<MAPPERSMITH_VALUE_NOT_MATCHED>';
/**

@@ -28,2 +22,3 @@ * @param {Integer} id

*/
function MockResource(id, client) {

@@ -56,3 +51,2 @@ if (!client || !client._manifest) {

/**

@@ -66,3 +60,2 @@ * @return {MockResource}

/**

@@ -76,3 +69,2 @@ * @return {MockResource}

/**

@@ -86,3 +78,2 @@ * @return {MockResource}

/**

@@ -97,6 +88,6 @@ * @return {MockResource}

}
return this;
},
/**

@@ -111,6 +102,6 @@ * @return {MockResource}

}
return this;
},
/**

@@ -123,3 +114,2 @@ * @return {MockAssert}

/**

@@ -132,6 +122,4 @@ * @return {MockRequest}

var finalRequest = this.createRequest();
var assertObject = this.mockRequest ? this.mockRequest.assertObject() : new _mockAssert2.default([]);
var assertObject = this.mockRequest ? this.mockRequest.assertObject() : new _mockAssert.default([]);
var responseStatus = this.responseStatusHandler ? this.responseStatusHandler(finalRequest, assertObject) : this.responseStatus;
var responseData = this.responseHandler ? this.responseHandler(finalRequest, assertObject) : this.responseData;

@@ -144,5 +132,9 @@

});
var urlMatcher = function urlMatcher(requestUrl, requestParams) {
var expandedParams = _this.expandParams(params, requestParams);
var testRequest = finalRequest.enhance({ params: expandedParams });
var testRequest = finalRequest.enhance({
params: expandedParams
});
return testRequest.url() === requestUrl;

@@ -152,4 +144,3 @@ };

var url = hasParamMatchers ? urlMatcher : finalRequest.url();
this.mockRequest = new _mockRequest2.default(this.id, {
this.mockRequest = new _mockRequest.default(this.id, {
method: finalRequest.method(),

@@ -168,7 +159,5 @@ url: url,

this.mockRequest.setResponseData(responseData);
return this.mockRequest;
},
/**

@@ -180,2 +169,3 @@ * @private

var value = requestParams[key];
if (typeof mockParams[key] === 'function') {

@@ -186,2 +176,3 @@ obj[key] = mockParams[key](value) ? value : VALUE_NOT_MATCHED;

}
return obj;

@@ -191,3 +182,2 @@ }, {});

/**

@@ -198,3 +188,3 @@ * @private

var methodDescriptor = this.manifest.createMethodDescriptor(this.resourceName, this.methodName);
var initialRequest = new _request2.default(methodDescriptor, this.requestParams);
var initialRequest = new _request.default(methodDescriptor, this.requestParams);
var middleware = this.manifest.createMiddleware({

@@ -210,3 +200,3 @@ resourceName: this.resourceName,

};
exports.default = MockResource;
var _default = MockResource;
exports.default = _default;
{
"name": "mappersmith",
"version": "2.25.0",
"version": "2.25.1",
"description": "It is a lightweight rest client for node.js and the browser",

@@ -53,10 +53,11 @@ "author": "Tulio Ornelas <ornelas.tulio@gmail.com>",

"devDependencies": {
"babel-cli": "^6.24.1",
"babel-core": "^6.25.0",
"babel-jest": "^20.0.3",
"babel-loader": "^7.1.1",
"babel-plugin-minify-replace": "^0.2.0",
"babel-polyfill": "^6.23.0",
"babel-preset-es2015": "^6.24.1",
"babel-register": "^6.26.0",
"@babel/cli": "^7.0.0",
"@babel/core": "^7.0.0",
"@babel/polyfill": "^7.0.0",
"@babel/preset-env": "^7.0.0",
"@babel/register": "^7.0.0",
"babel-core": "^7.0.0-bridge.0",
"babel-jest": "^23.4.2",
"babel-loader": "^8.0.0",
"babel-plugin-minify-replace": "^0.4.3",
"body-parser": "^1.15.2",

@@ -73,6 +74,6 @@ "concurrently": "^3.5.1",

"express": "^4.15.4",
"faux-jax": "^5.0.6",
"faux-jax-tulios": "^5.0.8",
"jasmine": "^2.5.2",
"jasmine-core": "^2.5.2",
"jest": "^20.0.4",
"jest": "^23.5.0",
"js-md5": "^0.6.1",

@@ -79,0 +80,0 @@ "karma": "^1.7.0",

@@ -214,2 +214,3 @@ [![npm version](https://badge.fury.io/js/mappersmith.svg)](http://badge.fury.io/js/mappersmith)

__NOTE__: It's possible to post body as JSON, check the [EncodeJsonMiddleware](#encode-json-middleware) below for more information
__NOTE__: The `bodyAttr` param can be set at manifest level.

@@ -236,2 +237,4 @@ ### <a name="headers"></a> Headers

__NOTE__: The `headersAttr` param can be set at manifest level.
### <a name="basic-auth"></a> Basic auth

@@ -261,2 +264,3 @@

__NOTE__: A default basic auth can be configured with the use of the [BasicAuthMiddleware](#basic-auth-middleware), check the middleware section below for more information.
__NOTE__: The `authAttr` param can be set at manifest level.

@@ -284,2 +288,3 @@ ### <a name="timeout"></a> Timeout

__NOTE__: A default timeout can be configured with the use of the [TimeoutMiddleware](#timeout-middleware), check the middleware section below for more information.
__NOTE__: The `timeoutAttr` param can be set at manifest level.

@@ -286,0 +291,0 @@ ### <a name="alternative-host"></a> Alternative host

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,8 +6,8 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
var _utils = require('./utils');
var _utils = require("./utils");
var REGEXP_DYNAMIC_SEGMENT = /{([^}]+)}/;
var REGEXP_TRAILING_SLASH = /\/$/;
/**

@@ -18,2 +18,3 @@ * @typedef Request

*/
function Request(methodDescriptor, requestParams) {

@@ -41,2 +42,3 @@ this.methodDescriptor = methodDescriptor;

}
return obj;

@@ -46,3 +48,2 @@ }, {});

/**

@@ -57,3 +58,2 @@ * Returns the HTTP method in lowercase

/**

@@ -69,3 +69,2 @@ * Returns host name without trailing slash

/**

@@ -88,3 +87,3 @@ * Returns path with parameters and leading slash.

if (this.methodDescriptor.path[0] !== '/') {
path = '/' + this.methodDescriptor.path;
path = "/".concat(this.methodDescriptor.path);
}

@@ -95,13 +94,13 @@

var value = params[key];
var pattern = '{' + key + '}';
var pattern = "{".concat(key, "}");
if (new RegExp(pattern).test(path)) {
path = path.replace('{' + key + '}', value);
path = path.replace("{".concat(key, "}"), value);
delete params[key];
}
});
var missingDynamicSegmentMatch = path.match(REGEXP_DYNAMIC_SEGMENT);
var missingDynamicSegmentMatch = path.match(REGEXP_DYNAMIC_SEGMENT);
if (missingDynamicSegmentMatch) {
throw new Error('[Mappersmith] required parameter missing (' + missingDynamicSegmentMatch[1] + '), "' + path + '" cannot be resolved');
throw new Error("[Mappersmith] required parameter missing (".concat(missingDynamicSegmentMatch[1], "), \"").concat(path, "\" cannot be resolved"));
}

@@ -114,6 +113,6 @@

}, {});
var queryString = (0, _utils.toQueryString)(aliasedParams);
var queryString = (0, _utils.toQueryString)(aliasedParams);
if (queryString.length !== 0) {
path += '?' + queryString;
path += "?".concat(queryString);
}

@@ -124,3 +123,2 @@

/**

@@ -133,6 +131,5 @@ * Returns the full URL

url: function url() {
return '' + this.host() + this.path();
return "".concat(this.host()).concat(this.path());
},
/**

@@ -148,3 +145,2 @@ * Returns an object with the headers. Header names are converted to

/**

@@ -170,3 +166,2 @@ * Utility method to get a header value by name

/**

@@ -187,3 +182,2 @@ * Enhances current request returning a new Request

var requestParams = (0, _utils.assign)({}, this.requestParams, extras.params);
requestParams[headerKey] = (0, _utils.assign)({}, this.requestParams[headerKey], extras.headers);

@@ -193,7 +187,5 @@ extras.body && (requestParams[bodyKey] = extras.body);

extras.timeout && (requestParams[timeoutKey] = extras.timeout);
return new Request(this.methodDescriptor, requestParams);
},
/**

@@ -208,3 +200,3 @@ * Is the request expecting a binary response?

};
exports.default = Request;
var _default = Request;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,9 +6,15 @@ Object.defineProperty(exports, "__esModule", {

});
exports.default = void 0;
var _utils = require('./utils');
var _utils = require("./utils");
function _toConsumableArray(arr) { if (Array.isArray(arr)) { for (var i = 0, arr2 = Array(arr.length); i < arr.length; i++) { arr2[i] = arr[i]; } return arr2; } else { return Array.from(arr); } }
function _toConsumableArray(arr) { return _arrayWithoutHoles(arr) || _iterableToArray(arr) || _nonIterableSpread(); }
function _nonIterableSpread() { throw new TypeError("Invalid attempt to spread non-iterable instance"); }
function _iterableToArray(iter) { if (Symbol.iterator in Object(iter) || Object.prototype.toString.call(iter) === "[object Arguments]") return Array.from(iter); }
function _arrayWithoutHoles(arr) { if (Array.isArray(arr)) { for (var i = 0, arr2 = new Array(arr.length); i < arr.length; i++) { arr2[i] = arr[i]; } return arr2; } }
var REGEXP_CONTENT_TYPE_JSON = /^application\/json/;
/**

@@ -22,6 +28,11 @@ * @typedef Response

*/
function Response(originalRequest, responseStatus, responseData, responseHeaders, errors) {
if (originalRequest.requestParams && originalRequest.requestParams.auth) {
var maskedAuth = (0, _utils.assign)({}, originalRequest.requestParams.auth, { password: '***' });
this.originalRequest = originalRequest.enhance({ auth: maskedAuth });
var maskedAuth = (0, _utils.assign)({}, originalRequest.requestParams.auth, {
password: '***'
});
this.originalRequest = originalRequest.enhance({
auth: maskedAuth
});
} else {

@@ -46,3 +57,2 @@ this.originalRequest = originalRequest;

/**

@@ -60,3 +70,2 @@ * @return {Integer}

/**

@@ -72,3 +81,2 @@ * Returns true if status is greater or equal 200 or lower than 400

/**

@@ -84,3 +92,2 @@ * Returns an object with the headers. Header names are converted to

/**

@@ -97,3 +104,2 @@ * Utility method to get a header value by name

/**

@@ -106,3 +112,2 @@ * Returns the original response data

/**

@@ -129,3 +134,2 @@ * Returns the response data, if "Content-Type" is "application/json"

/**

@@ -138,2 +142,3 @@ * Returns the last error instance that caused the request to fail

var lastError = this.errors[this.errors.length - 1] || null;
if (typeof lastError === 'string') {

@@ -146,3 +151,2 @@ return new Error(lastError);

/**

@@ -160,6 +164,6 @@ * Enhances current Response returning a new Response

enhance: function enhance(extras) {
return new Response(this.request(), extras.status || this.status(), extras.rawData || this.rawData(), (0, _utils.assign)({}, this.headers(), extras.headers), [].concat(_toConsumableArray(this.errors), [extras.error]));
return new Response(this.request(), extras.status || this.status(), extras.rawData || this.rawData(), (0, _utils.assign)({}, this.headers(), extras.headers), _toConsumableArray(this.errors).concat([extras.error]));
}
};
exports.default = Response;
var _default = Response;
exports.default = _default;

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,20 +6,14 @@ Object.defineProperty(exports, "__esModule", {

});
exports.m = exports.lookupResponse = exports.clear = exports.uninstall = exports.install = exports.mockRequest = exports.mockClient = undefined;
exports.m = exports.lookupResponse = exports.clear = exports.uninstall = exports.install = exports.mockRequest = exports.mockClient = void 0;
var _mockRequest = require('./mocks/mock-request');
var _mockRequest = _interopRequireDefault(require("./mocks/mock-request"));
var _mockRequest2 = _interopRequireDefault(_mockRequest);
var _mockResource = _interopRequireDefault(require("./mocks/mock-resource"));
var _mockResource = require('./mocks/mock-resource');
var _mock = _interopRequireDefault(require("./gateway/mock"));
var _mockResource2 = _interopRequireDefault(_mockResource);
var _index = require("./index");
var _mock = require('./gateway/mock');
var _utils = require("./utils");
var _mock2 = _interopRequireDefault(_mock);
var _index = require('./index');
var _utils = require('./utils');
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

@@ -30,3 +24,2 @@

var originalGateway = null;
/**

@@ -39,8 +32,8 @@ * High level abstraction, it works directly on your client mocking

*/
var mockClient = exports.mockClient = function mockClient(client) {
var entry = new _mockResource2.default(ids++, client);
var mockClient = function mockClient(client) {
var entry = new _mockResource.default(ids++, client);
store.push(entry);
return entry;
};
/**

@@ -59,21 +52,32 @@ * Low level abstraction, very useful for automations

*/
var mockRequest = exports.mockRequest = function mockRequest(props) {
var entry = new _mockRequest2.default(ids++, props);
exports.mockClient = mockClient;
var mockRequest = function mockRequest(props) {
var entry = new _mockRequest.default(ids++, props);
store.push(entry);
return entry.assertObject();
};
/**
* Setup the test library
*/
var install = exports.install = function install() {
exports.mockRequest = mockRequest;
var install = function install() {
originalGateway = _index.configs.gateway;
_index.configs.gateway = _mock2.default;
_index.configs.gateway = _mock.default;
};
/**
* Teardown the test library
*/
var uninstall = exports.uninstall = function uninstall() {
exports.install = install;
var uninstall = function uninstall() {
clear();
if (originalGateway) {

@@ -84,10 +88,12 @@ _index.configs.gateway = originalGateway;

};
/**
* Cleans up all mocks
*/
var clear = exports.clear = function clear() {
exports.uninstall = uninstall;
var clear = function clear() {
store = [];
};
/**

@@ -98,7 +104,10 @@ * @param {Request} request

*/
var lookupResponse = exports.lookupResponse = function lookupResponse(request) {
exports.clear = clear;
var lookupResponse = function lookupResponse(request) {
var mocks = store.map(function (mock) {
return mock.toMockRequest();
});
var exactMatch = mocks.filter(function (mock) {

@@ -117,16 +126,19 @@ return mock.isExactMatch(request);

if (partialMatch) {
throw new Error('[Mappersmith Test] No exact match found for ' + requestToLog(request) + ', partial match with ' + mockToLog(partialMatch) + ', check your mock definition');
throw new Error("[Mappersmith Test] No exact match found for ".concat(requestToLog(request), ", partial match with ").concat(mockToLog(partialMatch), ", check your mock definition"));
}
throw new Error('[Mappersmith Test] No match found for ' + requestToLog(request) + ', check your mock definition');
throw new Error("[Mappersmith Test] No match found for ".concat(requestToLog(request), ", check your mock definition"));
};
/**
* List of match functions
*/
var m = exports.m = {
exports.lookupResponse = lookupResponse;
var m = {
stringMatching: function stringMatching(regexp) {
if (!(regexp instanceof RegExp)) {
throw new Error('[Mappersmith Test] "stringMatching" received an invalid regexp (' + regexp + ')');
throw new Error("[Mappersmith Test] \"stringMatching\" received an invalid regexp (".concat(regexp, ")"));
}
return function (string) {

@@ -136,6 +148,5 @@ return regexp.test(string);

},
stringContaining: function stringContaining(sample) {
if (typeof sample !== 'string') {
throw new Error('[Mappersmith Test] "stringContaining" received an invalid string (' + sample + ')');
throw new Error("[Mappersmith Test] \"stringContaining\" received an invalid string (".concat(sample, ")"));
}

@@ -147,7 +158,5 @@

},
uuid4: function uuid4() {
// NOTE: based on https://github.com/chriso/validator.js/blob/3443132beccddf06c3f0a5e88c1dd2ee6513b612/src/lib/isUUID.js
var uuid4Rx = /^[0-9A-F]{8}-[0-9A-F]{4}-4[0-9A-F]{3}-[89AB][0-9A-F]{3}-[0-9A-F]{12}$/i;
return function (string) {

@@ -157,3 +166,2 @@ return uuid4Rx.test(string);

},
anything: function anything() {

@@ -165,8 +173,10 @@ return function () {

};
exports.m = m;
var requestToLog = function requestToLog(request) {
return '"' + request.method().toUpperCase() + ' ' + request.url() + '" (body: "' + (0, _utils.toQueryString)(request.body()) + '")';
return "\"".concat(request.method().toUpperCase(), " ").concat(request.url(), "\" (body: \"").concat((0, _utils.toQueryString)(request.body()), "\")");
};
var mockToLog = function mockToLog(requestMock) {
return '"' + requestMock.method.toUpperCase() + ' ' + requestMock.url + '" (body: "' + requestMock.body + '")';
return "\"".concat(requestMock.method.toUpperCase(), " ").concat(requestMock.url, "\" (body: \"").concat(requestMock.body, "\")");
};

@@ -173,0 +183,0 @@

@@ -1,2 +0,2 @@

'use strict';
"use strict";

@@ -6,5 +6,2 @@ Object.defineProperty(exports, "__esModule", {

});
var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; };
exports.toQueryString = toQueryString;

@@ -15,5 +12,8 @@ exports.performanceNow = performanceNow;

exports.isPlainObject = isPlainObject;
var _process = void 0,
getNanoSeconds = void 0,
loadTime = void 0;
exports.btoa = exports.assign = void 0;
function _typeof(obj) { if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }
var _process, getNanoSeconds, loadTime;
try {

@@ -23,2 +23,3 @@ _process = eval('typeof __TEST_WEB__ === "undefined" && typeof process === "object" ? process : undefined');

var hasProcessHrtime = function hasProcessHrtime() {

@@ -31,4 +32,6 @@ return typeof _process !== 'undefined' && _process !== null && _process.hrtime;

var hr = _process.hrtime();
return hr[0] * 1e9 + hr[1];
};
loadTime = getNanoSeconds();

@@ -48,6 +51,6 @@ }

var isArray = Array.isArray(value);
var isObject = (typeof value === 'undefined' ? 'undefined' : _typeof(value)) === 'object';
var isObject = _typeof(value) === 'object';
if (!isArray && !isObject) {
return encodeURIComponent(key + suffix) + '=' + encodeURIComponent(value);
return "".concat(encodeURIComponent(key + suffix), "=").concat(encodeURIComponent(value));
}

@@ -75,3 +78,2 @@

}
/**

@@ -81,2 +83,4 @@ * Gives time in miliseconds, but with sub-milisecond precision for Browser

*/
function performanceNow() {

@@ -89,3 +93,2 @@ if (hasProcessHrtime()) {

}
/**

@@ -98,4 +101,7 @@ * borrowed from: {@link https://gist.github.com/monsur/706839}

*/
function parseResponseHeaders(headerStr) {
var headers = {};
if (!headerStr) {

@@ -105,8 +111,10 @@ return headers;

var headerPairs = headerStr.split('\r\n');
var headerPairs = headerStr.split("\r\n");
for (var i = 0; i < headerPairs.length; i++) {
var headerPair = headerPairs[i];
// Can't use split() here because it does the wrong thing
var headerPair = headerPairs[i]; // Can't use split() here because it does the wrong thing
// if the header value has the string ": " in it.
var index = headerPair.indexOf(': ');
var index = headerPair.indexOf(": ");
if (index > 0) {

@@ -118,2 +126,3 @@ var key = headerPair.substring(0, index).toLowerCase().trim();

}
return headers;

@@ -130,5 +139,7 @@ }

var hasOwnProperty = Object.prototype.hasOwnProperty;
var assign = exports.assign = Object.assign || function (target) {
var assign = Object.assign || function (target) {
for (var i = 1; i < arguments.length; i++) {
var source = arguments[i];
for (var key in source) {

@@ -140,34 +151,42 @@ if (hasOwnProperty.call(source, key)) {

}
return target;
};
exports.assign = assign;
var toString = Object.prototype.toString;
function isPlainObject(value) {
return toString.call(value) === '[object Object]' && Object.getPrototypeOf(value) === Object.getPrototypeOf({});
}
/**
* borrowed from: {@link https://github.com/davidchambers/Base64.js}
*/
var CHARS = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=';
var btoa = exports.btoa = function btoa(input) {
var btoa = function btoa(input) {
var output = '';
var map = CHARS;
var str = String(input);
for (
// initialize result and counter
var block, charCode, idx = 0;
// if the next str index does not exist:
for ( // initialize result and counter
var block, charCode, idx = 0; // if the next str index does not exist:
// change the mapping table to "="
// check if d has no fractional digits
str.charAt(idx | 0) || (map = '=', idx % 1);
// "8 - idx % 1 * 8" generates the sequence 2, 4, 6, 8
str.charAt(idx | 0) || (map = '=', idx % 1); // "8 - idx % 1 * 8" generates the sequence 2, 4, 6, 8
output += map.charAt(63 & block >> 8 - idx % 1 * 8)) {
charCode = str.charCodeAt(idx += 3 / 4);
if (charCode > 0xFF) {
throw new Error("[Mappersmith] 'btoa' failed: The string to be encoded contains characters outside of the Latin1 range.");
}
block = block << 8 | charCode;
}
return output;
};
};
exports.btoa = btoa;
SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc