@lskjs/proxy/lib/createRequest.js

"use strict";

var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.getProviderOptions = exports["default"] = exports.createRequest = exports.NETWORK_TRIES = exports.NETWORK_TIMEOUT = exports.NETWORK_INTERVAL = void 0;
var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
var _toConsumableArray2 = _interopRequireDefault(require("@babel/runtime/helpers/toConsumableArray"));
var _defineProperty2 = _interopRequireDefault(require("@babel/runtime/helpers/defineProperty"));
var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
var _objectWithoutProperties2 = _interopRequireDefault(require("@babel/runtime/helpers/objectWithoutProperties"));
var _env = require("@lskjs/env");
var _err = _interopRequireDefault(require("@lskjs/err"));
var _retry = _interopRequireDefault(require("@lskjs/utils/retry"));
var _axios = _interopRequireDefault(require("axios"));
var _createFeedback = require("./utils/createFeedback");
var _isNetworkError = require("./utils/isNetworkError");
var _excluded = ["createFeedback", "labels", "onProxyManagerError", "axios"],
  _excluded2 = ["driver", "timeout", "interval", "proxy", "interceptors", "logPrefix"];
/* eslint-disable max-len */
function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); 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 = null != arguments[i] ? arguments[i] : {}; i % 2 ? ownKeys(Object(source), !0).forEach(function (key) { (0, _defineProperty2["default"])(target, key, source[key]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)) : ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } return target; }
var NETWORK_TIMEOUT = _env.isDev ? 1000 : 10000;
exports.NETWORK_TIMEOUT = NETWORK_TIMEOUT;
var NETWORK_TRIES = _env.isDev ? 2 : 5;
exports.NETWORK_TRIES = NETWORK_TRIES;
var NETWORK_INTERVAL = _env.isDev ? 100 : 1000;

// TODO: дописать
exports.NETWORK_INTERVAL = NETWORK_INTERVAL;
var getProviderOptions = function getProviderOptions(proxy, driver) {
  return proxy ? proxy.getProviderOptions(driver) : {};
};

// const createNoop = () => ({ success: () => null, error: () => null });
exports.getProviderOptions = getProviderOptions;
var createRequest = function createRequest() {
  var _ref = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {},
    _ref$createFeedback = _ref.createFeedback,
    createFeedback = _ref$createFeedback === void 0 ? _createFeedback.createFeedback : _ref$createFeedback,
    labels = _ref.labels,
    onProxyManagerError = _ref.onProxyManagerError,
    axiosCreateParams = _ref.axios,
    feedbackOptions = (0, _objectWithoutProperties2["default"])(_ref, _excluded);
  return function () {
    var props = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};
    var _props$driver = props.driver,
      driver = _props$driver === void 0 ? 'axios' : _props$driver,
      _props$timeout = props.timeout,
      timeout = _props$timeout === void 0 ? NETWORK_TIMEOUT : _props$timeout,
      _props$interval = props.interval,
      interval = _props$interval === void 0 ? NETWORK_INTERVAL : _props$interval,
      initProxy = props.proxy,
      interceptors = props.interceptors,
      logPrefix = props.logPrefix,
      params = (0, _objectWithoutProperties2["default"])(props, _excluded2);
    var maxTries = props.max_tries || props.maxTries || props.max_retries || props.maxRetries || props.max_retry || props.maxRetry || props.tries || NETWORK_TRIES;
    if (driver !== 'axios') throw new _err["default"]('REQUEST_DRIVER', 'driver not realized yet', {
      driver: driver
    });
    var tries = 0;
    return (0, _retry["default"])( /*#__PURE__*/(0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee() {
      var proxy, proxyManager, options, feedback, _res$headers, _res$headers2, abortTimeout, CancelToken, source, client, _client$interceptors$, _client$interceptors$2, res, size, _res$headers3, _res$headers4, _res, _size, code, fatal, isNetwork, errProps, err;
      return _regenerator["default"].wrap(function _callee$(_context) {
        while (1) switch (_context.prev = _context.next) {
          case 0:
            if (initProxy) proxy = initProxy;
            _context.next = 3;
            return props.proxyManager || feedbackOptions.proxyManager;
          case 3:
            proxyManager = _context.sent;
            _context.prev = 4;
            if (!(!proxy && proxyManager)) {
              _context.next = 9;
              break;
            }
            _context.next = 8;
            return proxyManager.getProxy();
          case 8:
            proxy = _context.sent;
          case 9:
            _context.next = 16;
            break;
          case 11:
            _context.prev = 11;
            _context.t0 = _context["catch"](4);
            if (!onProxyManagerError) {
              _context.next = 16;
              break;
            }
            _context.next = 16;
            return onProxyManagerError({
              err: _context.t0,
              tries: tries,
              maxTries: maxTries
            });
          case 16:
            options = _objectSpread(_objectSpread({}, params), getProviderOptions(proxy, driver));
            tries += 1;
            feedback = createFeedback ? createFeedback({
              options: props,
              proxy: proxy,
              tries: tries,
              maxTries: maxTries,
              logPrefix: logPrefix
            }, _objectSpread(_objectSpread({}, feedbackOptions), {}, {
              proxyManager: proxyManager,
              labels: labels
            })) // TODO: подумать а не замудренно ли
            : null;
            _context.prev = 19;
            if (timeout && !params.cancelToken) {
              CancelToken = _axios["default"].CancelToken;
              source = CancelToken.source();
              options.cancelToken = source.token;
              abortTimeout = setTimeout(function () {
                return source.cancel('REQUEST_NETWORK_TIMEOUT');
              }, timeout);
            }
            client = _axios["default"].create(axiosCreateParams);
            if (interceptors) {
              if (Array.isArray(interceptors.request)) {
                (_client$interceptors$ = client.interceptors.request).use.apply(_client$interceptors$, (0, _toConsumableArray2["default"])(interceptors.request));
              } else {
                client.interceptors.request.use(interceptors.request);
              }
              if (Array.isArray(interceptors.response)) {
                (_client$interceptors$2 = client.interceptors.response).use.apply(_client$interceptors$2, (0, _toConsumableArray2["default"])(interceptors.response));
              } else {
                client.interceptors.response.use(interceptors.response);
              }
            }
            _context.next = 25;
            return client(options);
          case 25:
            res = _context.sent;
            res.proxyManager = proxyManager;
            res.proxy = proxy;
            size = res !== null && res !== void 0 && (_res$headers = res.headers) !== null && _res$headers !== void 0 && _res$headers['content-length'] ? Number(res === null || res === void 0 ? void 0 : (_res$headers2 = res.headers) === null || _res$headers2 === void 0 ? void 0 : _res$headers2['content-length']) : null;
            if (abortTimeout) clearTimeout(abortTimeout);
            if (!feedback) {
              _context.next = 33;
              break;
            }
            _context.next = 33;
            return feedback.success({
              size: size
            });
          case 33:
            return _context.abrupt("return", res);
          case 36:
            _context.prev = 36;
            _context.t1 = _context["catch"](19);
            _res = _context.t1 === null || _context.t1 === void 0 ? void 0 : _context.t1.response;
            _size = _res !== null && _res !== void 0 && (_res$headers3 = _res.headers) !== null && _res$headers3 !== void 0 && _res$headers3['content-length'] ? Number(_res === null || _res === void 0 ? void 0 : (_res$headers4 = _res.headers) === null || _res$headers4 === void 0 ? void 0 : _res$headers4['content-length']) : null;
            code = (0, _isNetworkError.getErrCode)(_context.t1);
            fatal = (0, _isNetworkError.isNetworkFatal)(_context.t1);
            isNetwork = (0, _isNetworkError.isNetworkError)(_context.t1);
            proxy = null;
            errProps = {
              proxyManager: proxyManager,
              proxy: proxy
            };
            if (isNetwork) {
              errProps = {
                message: code,
                subcode: _err["default"].getCode(_context.t1),
                "class": 'network',
                tries: tries,
                maxTries: maxTries,
                isNetwork: isNetwork
              };
            }
            err = new _err["default"](code, _context.t1, errProps);
            _err["default"].copyProps(err, _context.t1);
            err.code = code;
            if (!feedback) {
              _context.next = 52;
              break;
            }
            _context.next = 52;
            return feedback.error(err, {
              fatal: fatal,
              size: _size
            });
          case 52:
            if (isNetwork) {
              _context.next = 54;
              break;
            }
            throw _retry["default"].StopError(err);
          case 54:
            throw err;
          case 55:
          case "end":
            return _context.stop();
        }
      }, _callee, null, [[4, 11], [19, 36]]);
    })), {
      throw_original: true,
      interval: interval,
      max_tries: maxTries
    });
  };
};
exports.createRequest = createRequest;
var _default = createRequest;
exports["default"] = _default;
//# sourceMappingURL=createRequest.js.map