function isRetryableGatewayCallError(error) {

const text = error instanceof Error ? error.message : String(error);

return (

isRetryableTransientNetworkError(error) ||

text.includes("gateway starting") ||

text.includes("gateway closed") ||

text.includes("handshake timeout") ||

text.includes("GatewayTransportError") ||

text.includes("ECONNREFUSED") ||

text.includes("fetch failed")

text.includes("GatewayTransportError")

);

}

async function fetchJson(url) {

const response = await fetch(url);

const text = await response.text();

let body = null;

try {

body = text ? JSON.parse(text) : null;

} catch {

body = text;

function isRetryableTransientNetworkError(error, seen = new Set()) {

if (!error || seen.has(error)) {

return false;

}

seen.add(error);

const candidate = error;

const message = candidate instanceof Error ? candidate.message : String(candidate);

const code = typeof candidate === "object" && candidate !== null ? candidate.code : undefined;

const text = `${String(code ?? "")} ${message}`;

if (

/\b(?:ECONNRESET|ECONNREFUSED|ETIMEDOUT|EPIPE|EHOSTUNREACH|ENETUNREACH)\b/iu.test(text) ||

/\b(?:fetch failed|socket hang up|connection reset)\b/iu.test(text)

) {

return true;

}

if (typeof candidate === "object" && candidate !== null && "cause" in candidate) {

return isRetryableTransientNetworkError(candidate.cause, seen);

}

return false;

}

export async function fetchJson(url, options = {}) {

const attempts = Math.max(1, options.attempts ?? 3);

let lastError;

for (let attempt = 1; attempt <= attempts; attempt += 1) {

try {

const response = await (options.fetchImpl ?? fetch)(url);

const text = await response.text();

let body = null;

try {

body = text ? JSON.parse(text) : null;

} catch {

body = text;

}

return { ok: response.ok, status: response.status, body };

} catch (error) {

lastError = error;

if (attempt >= attempts || !isRetryableTransientNetworkError(error)) {

throw error;

}

await delay(options.retryDelayMs ?? 250);

}

}

return { ok: response.ok, status: response.status, body };

throw lastError ?? new Error(`fetch ${url} failed`);

}

function configureKitchenSink(env, port) {