);

const RPC_TIMEOUT_MS = readPositiveInt(process.env.OPENCLAW_KITCHEN_SINK_RPC_CALL_MS, 60000);

const FETCH_TIMEOUT_MS = readPositiveInt(process.env.OPENCLAW_KITCHEN_SINK_RPC_FETCH_MS, 10000);

const FETCH_BODY_MAX_BYTES = readPositiveInt(

process.env.OPENCLAW_KITCHEN_SINK_RPC_FETCH_BODY_BYTES,

1024 * 1024,

);

const MAX_RSS_MIB = readPositiveInt(process.env.OPENCLAW_KITCHEN_SINK_MAX_RSS_MIB, 2048);

const GATEWAY_TEARDOWN_GRACE_MS = 10000;

const GATEWAY_TEARDOWN_KILL_GRACE_MS = 2000;

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

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

const timeoutMs = Math.max(1, options.timeoutMs ?? FETCH_TIMEOUT_MS);

const maxBodyBytes = Math.max(1, options.maxBodyBytes ?? FETCH_BODY_MAX_BYTES);

let lastError;

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

const controller = new AbortController();

(options.fetchImpl ?? fetch)(url, { signal: controller.signal }),

timeoutPromise,

]);

const text = await Promise.race([response.text(), timeoutPromise]);

const text = await Promise.race([

readBoundedResponseText(response, maxBodyBytes),

timeoutPromise,

]);

let body = null;

try {

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

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

}

export async function readBoundedResponseText(response, byteLimit = FETCH_BODY_MAX_BYTES) {

const reader = response.body?.getReader?.();

if (!reader) {

return await response.text();

}

const chunks = [];

let totalBytes = 0;

for (;;) {

const { done, value } = await reader.read();

if (done) {

break;

}

const chunk = Buffer.from(value);

totalBytes += chunk.byteLength;

if (totalBytes > byteLimit) {

await reader.cancel().catch(() => undefined);

throw Object.assign(new Error(`fetch response body exceeded ${byteLimit} bytes`), {

code: "ETOOBIG",

});

}

chunks.push(chunk);

}

return Buffer.concat(chunks, totalBytes).toString("utf8");

}

function configureKitchenSink(env, port) {

const configPath = env.OPENCLAW_CONFIG_PATH;

const config = fs.existsSync(configPath) ? readJson(configPath) : {};