/** Timeout wrapper for node-host operations using AbortSignal cancellation. */

import { resolveTimerTimeoutMs } from "@openclaw/normalization-core/number-coercion";

import { toErrorObject } from "../infra/errors.js";

/**

* AbortSignal-based timeout wrapper for node-host operations.

let abortListener: (() => void) | undefined;

const abortPromise: Promise<never> = abortCtrl.signal.aborted

? Promise.reject(

toLintErrorObject(abortCtrl.signal.reason ?? timeoutError, "Non-Error rejection"),

)

? Promise.reject(toErrorObject(abortCtrl.signal.reason ?? timeoutError, "Non-Error rejection"))

: new Promise((_, reject) => {

abortListener = () =>

reject(toLintErrorObject(abortCtrl.signal.reason ?? timeoutError, "Non-Error rejection"));

reject(toErrorObject(abortCtrl.signal.reason ?? timeoutError, "Non-Error rejection"));

abortCtrl.signal.addEventListener("abort", abortListener, { once: true });

});

}

}

}

function toLintErrorObject(value: unknown, fallbackMessage: string): Error {

if (value instanceof Error) {

return value;

}

if (typeof value === "string") {

return new Error(value);

}

const error = new Error(fallbackMessage, { cause: value });

if ((typeof value === "object" && value !== null) || typeof value === "function") {

Object.assign(error, value);

}

return error;

}

// Spawn utilities configure child processes and normalize spawned process handles.

import type { ChildProcess, SpawnOptions } from "node:child_process";

import { spawn } from "node:child_process";

import { toErrorObject } from "../infra/errors.js";

export type SpawnFallback = {

label: string;

}

settled = true;

cleanup();

reject(toLintErrorObject(err, "Non-Error rejection"));

reject(toErrorObject(err, "Non-Error rejection"));

};

const onSpawn = () => {

finishResolve();

throw lastError;

}

function toLintErrorObject(value: unknown, fallbackMessage: string): Error {

if (value instanceof Error) {

return value;

}

if (typeof value === "string") {

return new Error(value);

}

const error = new Error(fallbackMessage, { cause: value });

if ((typeof value === "object" && value !== null) || typeof value === "function") {

Object.assign(error, value);

}

return error;

}

// Child process adapter wraps spawned child processes for the supervisor.

import type { ChildProcessWithoutNullStreams, SpawnOptions } from "node:child_process";

import { toErrorObject } from "../../../infra/errors.js";

import { createWindowsOutputDecoder } from "../../../infra/windows-encoding.js";

import { signalProcessTree } from "../../kill-tree.js";

import { prepareOomScoreAdjustedSpawn } from "../../linux-oom-score.js";

return waitResult;

}

if (waitError !== undefined) {

throw toLintErrorObject(waitError, "Non-Error thrown");

throw toErrorObject(waitError, "Non-Error thrown");

}

if (!waitPromise) {

waitPromise = new Promise<{ code: number | null; signal: NodeJS.Signals | null }>(

const error = waitError;

resolveWait = null;

rejectWait = null;

reject(toLintErrorObject(error, "Non-Error rejection"));

reject(toErrorObject(error, "Non-Error rejection"));

}

},

);

dispose,

};

}

function toLintErrorObject(value: unknown, fallbackMessage: string): Error {

if (value instanceof Error) {

return value;

}

if (typeof value === "string") {

return new Error(value);

}

const error = new Error(fallbackMessage, { cause: value });

if ((typeof value === "object" && value !== null) || typeof value === "function") {

Object.assign(error, value);

}

return error;

}