"use strict";
|
|
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
|
|
Object.defineProperty(exports, "__esModule", {
|
value: true
|
});
|
exports.isNetworkError = isNetworkError;
|
exports.isRetryableError = isRetryableError;
|
exports.isSafeRequestError = isSafeRequestError;
|
exports.isIdempotentRequestError = isIdempotentRequestError;
|
exports.isNetworkOrIdempotentRequestError = isNetworkOrIdempotentRequestError;
|
exports.exponentialDelay = exponentialDelay;
|
exports.default = axiosRetry;
|
|
var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
|
|
var _typeof2 = _interopRequireDefault(require("@babel/runtime/helpers/typeof"));
|
|
var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
|
|
var _defineProperty2 = _interopRequireDefault(require("@babel/runtime/helpers/defineProperty"));
|
|
var _isRetryAllowed = _interopRequireDefault(require("is-retry-allowed"));
|
|
function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) { symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); } keys.push.apply(keys, symbols); } return keys; }
|
|
function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; if (i % 2) { ownKeys(Object(source), true).forEach(function (key) { (0, _defineProperty2.default)(target, key, source[key]); }); } else if (Object.getOwnPropertyDescriptors) { Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)); } else { ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } } return target; }
|
|
var namespace = 'axios-retry';
|
/**
|
* @param {Error} error
|
* @return {boolean}
|
*/
|
|
function isNetworkError(error) {
|
return !error.response && Boolean(error.code) && // Prevents retrying cancelled requests
|
error.code !== 'ECONNABORTED' && // Prevents retrying timed out requests
|
(0, _isRetryAllowed.default)(error); // Prevents retrying unsafe errors
|
}
|
|
var SAFE_HTTP_METHODS = ['get', 'head', 'options'];
|
var IDEMPOTENT_HTTP_METHODS = SAFE_HTTP_METHODS.concat(['put', 'delete']);
|
/**
|
* @param {Error} error
|
* @return {boolean}
|
*/
|
|
function isRetryableError(error) {
|
return error.code !== 'ECONNABORTED' && (!error.response || error.response.status >= 500 && error.response.status <= 599);
|
}
|
/**
|
* @param {Error} error
|
* @return {boolean}
|
*/
|
|
|
function isSafeRequestError(error) {
|
if (!error.config) {
|
// Cannot determine if the request can be retried
|
return false;
|
}
|
|
return isRetryableError(error) && SAFE_HTTP_METHODS.indexOf(error.config.method) !== -1;
|
}
|
/**
|
* @param {Error} error
|
* @return {boolean}
|
*/
|
|
|
function isIdempotentRequestError(error) {
|
if (!error.config) {
|
// Cannot determine if the request can be retried
|
return false;
|
}
|
|
return isRetryableError(error) && IDEMPOTENT_HTTP_METHODS.indexOf(error.config.method) !== -1;
|
}
|
/**
|
* @param {Error} error
|
* @return {boolean}
|
*/
|
|
|
function isNetworkOrIdempotentRequestError(error) {
|
return isNetworkError(error) || isIdempotentRequestError(error);
|
}
|
/**
|
* @return {number} - delay in milliseconds, always 0
|
*/
|
|
|
function noDelay() {
|
return 0;
|
}
|
/**
|
* @param {number} [retryNumber=0]
|
* @return {number} - delay in milliseconds
|
*/
|
|
|
function exponentialDelay() {
|
var retryNumber = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : 0;
|
var delay = Math.pow(2, retryNumber) * 100;
|
var randomSum = delay * 0.2 * Math.random(); // 0-20% of the delay
|
|
return delay + randomSum;
|
}
|
/**
|
* Initializes and returns the retry state for the given request/config
|
* @param {AxiosRequestConfig} config
|
* @return {Object}
|
*/
|
|
|
function getCurrentState(config) {
|
var currentState = config[namespace] || {};
|
currentState.retryCount = currentState.retryCount || 0;
|
config[namespace] = currentState;
|
return currentState;
|
}
|
/**
|
* Returns the axios-retry options for the current request
|
* @param {AxiosRequestConfig} config
|
* @param {AxiosRetryConfig} defaultOptions
|
* @return {AxiosRetryConfig}
|
*/
|
|
|
function getRequestOptions(config, defaultOptions) {
|
return _objectSpread(_objectSpread({}, defaultOptions), config[namespace]);
|
}
|
/**
|
* @param {Axios} axios
|
* @param {AxiosRequestConfig} config
|
*/
|
|
|
function fixConfig(axios, config) {
|
if (axios.defaults.agent === config.agent) {
|
delete config.agent;
|
}
|
|
if (axios.defaults.httpAgent === config.httpAgent) {
|
delete config.httpAgent;
|
}
|
|
if (axios.defaults.httpsAgent === config.httpsAgent) {
|
delete config.httpsAgent;
|
}
|
}
|
/**
|
* Checks retryCondition if request can be retried. Handles it's retruning value or Promise.
|
* @param {number} retries
|
* @param {Function} retryCondition
|
* @param {Object} currentState
|
* @param {Error} error
|
* @return {boolean}
|
*/
|
|
|
function shouldRetry(_x, _x2, _x3, _x4) {
|
return _shouldRetry.apply(this, arguments);
|
}
|
/**
|
* Adds response interceptors to an axios instance to retry requests failed due to network issues
|
*
|
* @example
|
*
|
* import axios from 'axios';
|
*
|
* axiosRetry(axios, { retries: 3 });
|
*
|
* axios.get('http://example.com/test') // The first request fails and the second returns 'ok'
|
* .then(result => {
|
* result.data; // 'ok'
|
* });
|
*
|
* // Exponential back-off retry delay between requests
|
* axiosRetry(axios, { retryDelay : axiosRetry.exponentialDelay});
|
*
|
* // Custom retry delay
|
* axiosRetry(axios, { retryDelay : (retryCount) => {
|
* return retryCount * 1000;
|
* }});
|
*
|
* // Also works with custom axios instances
|
* const client = axios.create({ baseURL: 'http://example.com' });
|
* axiosRetry(client, { retries: 3 });
|
*
|
* client.get('/test') // The first request fails and the second returns 'ok'
|
* .then(result => {
|
* result.data; // 'ok'
|
* });
|
*
|
* // Allows request-specific configuration
|
* client
|
* .get('/test', {
|
* 'axios-retry': {
|
* retries: 0
|
* }
|
* })
|
* .catch(error => { // The first request fails
|
* error !== undefined
|
* });
|
*
|
* @param {Axios} axios An axios instance (the axios object or one created from axios.create)
|
* @param {Object} [defaultOptions]
|
* @param {number} [defaultOptions.retries=3] Number of retries
|
* @param {boolean} [defaultOptions.shouldResetTimeout=false]
|
* Defines if the timeout should be reset between retries
|
* @param {Function} [defaultOptions.retryCondition=isNetworkOrIdempotentRequestError]
|
* A function to determine if the error can be retried
|
* @param {Function} [defaultOptions.retryDelay=noDelay]
|
* A function to determine the delay between retry requests
|
*/
|
|
|
function _shouldRetry() {
|
_shouldRetry = (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee2(retries, retryCondition, currentState, error) {
|
var shouldRetryOrPromise, shouldRetryPromiseResult;
|
return _regenerator.default.wrap(function _callee2$(_context2) {
|
while (1) {
|
switch (_context2.prev = _context2.next) {
|
case 0:
|
shouldRetryOrPromise = currentState.retryCount < retries && retryCondition(error); // This could be a promise
|
|
if (!((0, _typeof2.default)(shouldRetryOrPromise) === 'object')) {
|
_context2.next = 12;
|
break;
|
}
|
|
_context2.prev = 2;
|
_context2.next = 5;
|
return shouldRetryOrPromise;
|
|
case 5:
|
shouldRetryPromiseResult = _context2.sent;
|
return _context2.abrupt("return", shouldRetryPromiseResult !== false);
|
|
case 9:
|
_context2.prev = 9;
|
_context2.t0 = _context2["catch"](2);
|
return _context2.abrupt("return", false);
|
|
case 12:
|
return _context2.abrupt("return", shouldRetryOrPromise);
|
|
case 13:
|
case "end":
|
return _context2.stop();
|
}
|
}
|
}, _callee2, null, [[2, 9]]);
|
}));
|
return _shouldRetry.apply(this, arguments);
|
}
|
|
function axiosRetry(axios, defaultOptions) {
|
axios.interceptors.request.use(function (config) {
|
var currentState = getCurrentState(config);
|
currentState.lastRequestTime = Date.now();
|
return config;
|
});
|
axios.interceptors.response.use(null, /*#__PURE__*/function () {
|
var _ref = (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee(error) {
|
var config, _getRequestOptions, _getRequestOptions$re, retries, _getRequestOptions$re2, retryCondition, _getRequestOptions$re3, retryDelay, _getRequestOptions$sh, shouldResetTimeout, currentState, delay, lastRequestDuration;
|
|
return _regenerator.default.wrap(function _callee$(_context) {
|
while (1) {
|
switch (_context.prev = _context.next) {
|
case 0:
|
config = error.config; // If we have no information to retry the request
|
|
if (config) {
|
_context.next = 3;
|
break;
|
}
|
|
return _context.abrupt("return", Promise.reject(error));
|
|
case 3:
|
_getRequestOptions = getRequestOptions(config, defaultOptions), _getRequestOptions$re = _getRequestOptions.retries, retries = _getRequestOptions$re === void 0 ? 3 : _getRequestOptions$re, _getRequestOptions$re2 = _getRequestOptions.retryCondition, retryCondition = _getRequestOptions$re2 === void 0 ? isNetworkOrIdempotentRequestError : _getRequestOptions$re2, _getRequestOptions$re3 = _getRequestOptions.retryDelay, retryDelay = _getRequestOptions$re3 === void 0 ? noDelay : _getRequestOptions$re3, _getRequestOptions$sh = _getRequestOptions.shouldResetTimeout, shouldResetTimeout = _getRequestOptions$sh === void 0 ? false : _getRequestOptions$sh;
|
currentState = getCurrentState(config);
|
_context.next = 7;
|
return shouldRetry(retries, retryCondition, currentState, error);
|
|
case 7:
|
if (!_context.sent) {
|
_context.next = 14;
|
break;
|
}
|
|
currentState.retryCount += 1;
|
delay = retryDelay(currentState.retryCount, error); // Axios fails merging this configuration to the default configuration because it has an issue
|
// with circular structures: https://github.com/mzabriskie/axios/issues/370
|
|
fixConfig(axios, config);
|
|
if (!shouldResetTimeout && config.timeout && currentState.lastRequestTime) {
|
lastRequestDuration = Date.now() - currentState.lastRequestTime; // Minimum 1ms timeout (passing 0 or less to XHR means no timeout)
|
|
config.timeout = Math.max(config.timeout - lastRequestDuration - delay, 1);
|
}
|
|
config.transformRequest = [function (data) {
|
return data;
|
}];
|
return _context.abrupt("return", new Promise(function (resolve) {
|
return setTimeout(function () {
|
return resolve(axios(config));
|
}, delay);
|
}));
|
|
case 14:
|
return _context.abrupt("return", Promise.reject(error));
|
|
case 15:
|
case "end":
|
return _context.stop();
|
}
|
}
|
}, _callee);
|
}));
|
|
return function (_x5) {
|
return _ref.apply(this, arguments);
|
};
|
}());
|
} // Compatibility with CommonJS
|
|
|
axiosRetry.isNetworkError = isNetworkError;
|
axiosRetry.isSafeRequestError = isSafeRequestError;
|
axiosRetry.isIdempotentRequestError = isIdempotentRequestError;
|
axiosRetry.isNetworkOrIdempotentRequestError = isNetworkOrIdempotentRequestError;
|
axiosRetry.exponentialDelay = exponentialDelay;
|
axiosRetry.isRetryableError = isRetryableError;
|
//# sourceMappingURL=index.js.map
|
