@lskjs/proxy/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"];

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 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