"use strict";Object.defineProperty(exports, "__esModule", { value: true });exports.n = wrapFetchWithAbortSignal;exports.t = resolveFetch;var _fetchTimeoutPoCDPIae = require("./fetch-timeout-poCDPIae.js");
//#region src/infra/fetch.ts
const wrapFetchWithAbortSignalMarker = Symbol.for("openclaw.fetch.abort-signal-wrapped");
function withDuplex(init, input) {
  const hasInitBody = init?.body != null;
  const hasRequestBody = !hasInitBody && typeof Request !== "undefined" && input instanceof Request && input.body != null;
  if (!hasInitBody && !hasRequestBody) return init;
  if (init && "duplex" in init) return init;
  return init ? {
    ...init,
    duplex: "half"
  } : { duplex: "half" };
}
function wrapFetchWithAbortSignal(fetchImpl) {
  if (fetchImpl[wrapFetchWithAbortSignalMarker]) return fetchImpl;
  const wrapped = (input, init) => {
    const patchedInit = withDuplex(init, input);
    const signal = patchedInit?.signal;
    if (!signal) return fetchImpl(input, patchedInit);
    if (typeof AbortSignal !== "undefined" && signal instanceof AbortSignal) return fetchImpl(input, patchedInit);
    if (typeof AbortController === "undefined") return fetchImpl(input, patchedInit);
    if (typeof signal.addEventListener !== "function") return fetchImpl(input, patchedInit);
    const controller = new AbortController();
    const onAbort = (0, _fetchTimeoutPoCDPIae.t)(controller);
    let listenerAttached = false;
    if (signal.aborted) controller.abort();else
    {
      signal.addEventListener("abort", onAbort, { once: true });
      listenerAttached = true;
    }
    const cleanup = () => {
      if (!listenerAttached || typeof signal.removeEventListener !== "function") return;
      listenerAttached = false;
      try {
        signal.removeEventListener("abort", onAbort);
      } catch {}
    };
    try {
      return fetchImpl(input, {
        ...patchedInit,
        signal: controller.signal
      }).finally(cleanup);
    } catch (error) {
      cleanup();
      throw error;
    }
  };
  const wrappedFetch = Object.assign(wrapped, fetchImpl);
  const fetchWithPreconnect = fetchImpl;
  wrappedFetch.preconnect = typeof fetchWithPreconnect.preconnect === "function" ? fetchWithPreconnect.preconnect.bind(fetchWithPreconnect) : () => {};
  Object.defineProperty(wrappedFetch, wrapFetchWithAbortSignalMarker, {
    value: true,
    enumerable: false,
    configurable: false,
    writable: false
  });
  return wrappedFetch;
}
function resolveFetch(fetchImpl) {
  const resolved = fetchImpl ?? globalThis.fetch;
  if (!resolved) return;
  return wrapFetchWithAbortSignal(resolved);
}
//#endregion /* v9-6dfdadddac875bcd */