@lskjs/proxy/utils/filterProxy.js

"use strict";

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

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.filterProxy = exports["default"] = exports.checkProxy = void 0;

var _get = _interopRequireDefault(require("lodash/get"));

var _isFunction = _interopRequireDefault(require("lodash/isFunction"));

var includes = function includes(list, target) {
  return (list || []).includes(target);
};

var checkProxy = function checkProxy(proxy, filter) {
  if ((0, _isFunction["default"])(filter)) return filter(proxy);
  if (filter.key && (0, _get["default"])(proxy, 'key') !== filter.key) return false;
  if (filter.type && (0, _get["default"])(proxy, 'type') !== filter.type) return false;
  if (filter.provider && (0, _get["default"])(proxy, 'provider') !== filter.provider) return false;
  if (filter.target && !includes((0, _get["default"])(proxy, 'targets'), filter.target)) return false;
  if (filter.test && !includes((0, _get["default"])(proxy, 'tests'), filter.test)) return false;
  if (filter.worker && (0, _get["default"])(proxy, 'tags.worker') !== filter.worker) return false;
  if (filter.country && (0, _get["default"])(proxy, 'tags.country') !== filter.country) return false;
  if (filter.subtype && (0, _get["default"])(proxy, 'tags.subtype') !== filter.subtype) return false;
  if (filter.ipv && !(0, _get["default"])(proxy, 'tags.ipv', '').startsWith(filter.ipv)) return false;
  if (filter.check) return filter.check(proxy);
  return true;
};

exports.checkProxy = checkProxy;

var filterProxy = function filterProxy() {
  var proxies = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : [];
  var filter = arguments.length > 1 ? arguments[1] : undefined;
  return proxies.filter(function (proxy) {
    return checkProxy(proxy, filter);
  });
};

exports.filterProxy = filterProxy;
var _default = filterProxy;
exports["default"] = _default;
//# sourceMappingURL=filterProxy.js.map