@lskjs/proxy/utils/parseProxies.js

"use strict";

var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.parseProxies = void 0;
exports.parseProxy = parseProxy;

var _err = _interopRequireDefault(require("@lskjs/err"));

var _set = _interopRequireDefault(require("lodash/set"));

var _createProxy = require("./createProxy");

var setProxyValue = function setProxyValue(proxy, path, value) {
  return (0, _set["default"])(proxy, path, decodeURIComponent(value));
};

function parseProxy(str) {
  var _ref = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {},
      _ref$json = _ref.json,
      json = _ref$json === void 0 ? false : _ref$json,
      _ref$throws = _ref["throws"],
      _throws = _ref$throws === void 0 ? true : _ref$throws;

  if (typeof str !== 'string') return json ? (0, _createProxy.createProxy)(str).toJSON() : (0, _createProxy.createProxy)(str);
  var uri = str;
  if (!uri.includes('://')) uri = "http://".concat(uri);
  var url;

  try {
    // eslint-disable-next-line prefer-const
    url = new URL(uri);
  } catch (err) {
    if (!_throws) return null;
    throw err; // throw new Err(err, { uri });
  }

  var params = Object.fromEntries(url.searchParams);
  var type = url.protocol ? url.protocol.substr(0, url.protocol.length - 1) : 'http';
  var _url = url,
      user = _url.username,
      password = _url.password,
      host = _url.hostname,
      port = _url.port;
  var proxy = {
    type: type,
    host: host,
    port: port
  };
  if (user) setProxyValue(proxy, 'user', user);
  if (password) setProxyValue(proxy, 'password', password);
  if (params.provider) setProxyValue(proxy, 'provider', params.provider); // if (params.provider) set(proxy, 'tags.provider', params.provider);

  if (params.ip) setProxyValue(proxy, 'ip', params.ip);
  if (params.country) setProxyValue(proxy, 'tags.country', params.country);
  if (params.ipv) setProxyValue(proxy, 'tags.ipv', params.ipv);
  if (params.subtype) setProxyValue(proxy, 'tags.subtype', params.subtype); // proxy.uri = createUri(proxy);
  // proxy.key = createKey(proxy);

  return json ? (0, _createProxy.createProxy)(proxy).toJSON() : (0, _createProxy.createProxy)(proxy);
}

var parseProxies = function parseProxies() {
  var str = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : '';
  if (Array.isArray(str)) return str.map(function (p) {
    return parseProxy(p, {
      "throws": false
    });
  }).filter(Boolean);
  if (typeof str !== 'string') return [str];
  return str.trim().split(/[,\n]/).map(function (p) {
    return parseProxy(p, {
      "throws": false
    });
  }).filter(Boolean);
};

exports.parseProxies = parseProxies;
//# sourceMappingURL=parseProxies.js.map