import process from "node:process";

import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";

import { OPENCLAW_CLI_ENV_VALUE } from "../infra/openclaw-exec-env.js";

import { MAX_TIMER_TIMEOUT_MS } from "../shared/number-coercion.js";

const spawnMock = vi.hoisted(() => vi.fn());

},

);

it.runIf(process.platform !== "win32")(

"caps oversized process timeouts before arming timers",

async () => {

vi.useFakeTimers();

const timeoutSpy = vi.spyOn(globalThis, "setTimeout");

const child = createKilledChild();

spawnMock.mockReturnValue(child);

await loadExecModules({ mockSpawn: true });

const resultPromise = runCommandWithTimeout(createSilentIdleArgv(), {

timeoutMs: Number.MAX_SAFE_INTEGER,

});

expect(timeoutSpy).toHaveBeenCalledWith(expect.any(Function), MAX_TIMER_TIMEOUT_MS);

child.emit("exit", 0, null);

child.emit("close", 0, null);

const result = await resultPromise;

expect(result.termination).toBe("exit");

},

);

it.runIf(process.platform !== "win32")(

"caps oversized no-output timeouts before arming timers",

async () => {

vi.useFakeTimers();

const timeoutSpy = vi.spyOn(globalThis, "setTimeout");

const child = createKilledChild();

spawnMock.mockReturnValue(child);

await loadExecModules({ mockSpawn: true });

const resultPromise = runCommandWithTimeout(createSilentIdleArgv(), {

timeoutMs: 1_000,

noOutputTimeoutMs: Number.MAX_SAFE_INTEGER,

});

expect(timeoutSpy).toHaveBeenCalledWith(expect.any(Function), MAX_TIMER_TIMEOUT_MS);

child.emit("exit", 0, null);

child.emit("close", 0, null);

const result = await resultPromise;

expect(result.termination).toBe("exit");

},

);

it.runIf(process.platform !== "win32")(

"swallows stdin EPIPE when child exits before input is consumed (#75438)",

{ timeout: 5_000 },

import { normalizeLowercaseStringOrEmpty } from "@openclaw/normalization-core/string-coerce";

import { danger, shouldLogVerbose } from "../globals.js";

import { markOpenClawExecEnv } from "../infra/openclaw-exec-env.js";

import { resolveTimerTimeoutMs } from "../shared/number-coercion.js";

import {

decodeWindowsOutputBuffer,

resolveWindowsConsoleEncoding,

typeof optionsOrTimeout === "number" ? { timeoutMs: optionsOrTimeout } : optionsOrTimeout;

const { timeoutMs, cwd, input, baseEnv, env, noOutputTimeoutMs, signal, killProcessTree } =

options;

const resolvedTimeoutMs = resolveTimerTimeoutMs(timeoutMs, 1);

const hasInput = input !== undefined;

const resolvedEnv = resolveCommandEnv({ argv, baseEnv, env });

const stdio = resolveCommandStdio({ hasInput, preferInherit: true });

typeof noOutputTimeoutMs === "number" &&

Number.isFinite(noOutputTimeoutMs) &&

noOutputTimeoutMs > 0;

const resolvedNoOutputTimeoutMs = shouldTrackOutputTimeout

? resolveTimerTimeoutMs(noOutputTimeoutMs, 1)

: undefined;

let removeAbortListener: (() => void) | null = null;

const clearNoOutputTimer = () => {

}

noOutputTimedOut = true;

killChild();

}, Math.floor(noOutputTimeoutMs));

}, resolvedNoOutputTimeoutMs);

};

const timer = setTimeout(() => {

timedOut = true;

killChild();

}, timeoutMs);

}, resolvedTimeoutMs);

armNoOutputTimer();

if (signal) {

const onAbort = () => killChild(false);