decord/source/1480_InternetReachability.js

// Module ID: 1480
// Function ID: 1481
// Name: InternetReachability
// Dependencies: [42, 41]

// Module 1480 (InternetReachability)
import _classCallCheck from "_classCallCheck";
import _createClass from "_createClass";

class InternetReachability {
  constructor(arg0, arg1) {
    self = this;
    tmp = self(this, InternetReachability);
    this._isInternetReachable = undefined;
    this._currentInternetReachabilityCheckHandler = null;
    this._currentTimeoutHandle = null;
    this._setIsInternetReachable = (_isInternetReachable) => {
      if (self._isInternetReachable !== _isInternetReachable) {
        obj._isInternetReachable = _isInternetReachable;
        obj._listener(obj._isInternetReachable);
      }
    };
    this._setExpectsConnection = (arg0) => {
      if (null !== self._currentInternetReachabilityCheckHandler) {
        obj._currentInternetReachabilityCheckHandler.cancel();
        obj._currentInternetReachabilityCheckHandler = null;
        const _currentInternetReachabilityCheckHandler = obj._currentInternetReachabilityCheckHandler;
      }
      if (null !== self._currentTimeoutHandle) {
        const _clearTimeout = clearTimeout;
        clearTimeout(obj._currentTimeoutHandle);
        obj._currentTimeoutHandle = null;
      }
      if (arg0) {
        const _configuration = obj._configuration;
        if (_configuration.reachabilityShouldRun()) {
          if (!obj._isInternetReachable) {
            const result = obj._setIsInternetReachable(null);
          }
          obj._currentInternetReachabilityCheckHandler = obj._checkInternetReachability();
        }
      }
      const result1 = obj._setIsInternetReachable(false);
    };
    this._checkInternetReachability = () => {
      const abortController = new AbortController();
      let obj = { headers: self._configuration.reachabilityHeaders, method: self._configuration.reachabilityMethod, cache: "no-cache", signal: abortController.signal };
      const response = fetch(self._configuration.reachabilityUrl, obj);
      let promise = new Promise((arg0, arg1) => {
        let timeout = arg1;
        timeout = setTimeout(() => callback("timedout"), outer1_0._configuration.reachabilityRequestTimeout);
      });
      function cancel() {

      }
      promise = new Promise((arg0, arg1) => {
        let _classCallCheck = arg1;
        function cancel() {
          return callback("canceled");
        }
      });
      obj = { promise: null, cancel: null };
      const items = [response, promise, promise];
      const racePromise = Promise.race(items);
      const nextPromise = Promise.race(items).then((status) => {
        const _configuration = _classCallCheck._configuration;
        return _configuration.reachabilityTest(status);
      });
      const nextPromise1 = Promise.race(items).then((status) => {
        const _configuration = _classCallCheck._configuration;
        return _configuration.reachabilityTest(status);
      }).then((arg0) => {
        const result = _classCallCheck._setIsInternetReachable(arg0);
        const _configuration = _classCallCheck._configuration;
        _classCallCheck._currentTimeoutHandle = setTimeout(_classCallCheck._checkInternetReachability, _classCallCheck._isInternetReachable ? _configuration.reachabilityLongTimeout : _configuration.reachabilityShortTimeout);
      });
      obj[0] = Promise.race(items).then((status) => {
        const _configuration = _classCallCheck._configuration;
        return _configuration.reachabilityTest(status);
      }).then((arg0) => {
        const result = _classCallCheck._setIsInternetReachable(arg0);
        const _configuration = _classCallCheck._configuration;
        _classCallCheck._currentTimeoutHandle = setTimeout(_classCallCheck._checkInternetReachability, _classCallCheck._isInternetReachable ? _configuration.reachabilityLongTimeout : _configuration.reachabilityShortTimeout);
      }).catch((arg0) => {
        if ("canceled" === arg0) {
          abortController.abort();
        } else {
          if ("timedout" === arg0) {
            abortController.abort();
          }
          const result = outer1_0._setIsInternetReachable(false);
          const _setTimeout = setTimeout;
          outer1_0._currentTimeoutHandle = setTimeout(outer1_0._checkInternetReachability, outer1_0._configuration.reachabilityShortTimeout);
        }
      }).then(() => {
        clearTimeout(_classCallCheck);
      }, (arg0) => {
        clearTimeout(_classCallCheck);
        throw arg0;
      });
      obj[1] = cancel;
      return obj;
    };
    this.update = (isInternetReachable) => {
      if (typeof isInternetReachable.isInternetReachable === "boolean") {
        if (self._configuration.useNativeReachability) {
          const result = self._setIsInternetReachable(isInternetReachable.isInternetReachable);
        }
      }
      const result1 = self._setExpectsConnection(isInternetReachable.isConnected);
    };
    this.currentState = () => self._isInternetReachable;
    this.tearDown = () => {
      if (null !== self._currentInternetReachabilityCheckHandler) {
        tmp._currentInternetReachabilityCheckHandler.cancel();
        tmp._currentInternetReachabilityCheckHandler = null;
        const _currentInternetReachabilityCheckHandler = tmp._currentInternetReachabilityCheckHandler;
      }
      if (null !== self._currentTimeoutHandle) {
        const _clearTimeout = clearTimeout;
        clearTimeout(tmp._currentTimeoutHandle);
        tmp._currentTimeoutHandle = null;
      }
    };
    this._configuration = global;
    this._listener = arg1;
    return;
  }
}

export default _createClass(InternetReachability);