openAgent

1import { describe, expect, test } from "bun:test"
2import fs from "fs/promises"
3import path from "path"
4import { Process } from "@/util/process"
5import { tmpdir } from "../fixture/fixture"
6 
7function node(script: string) {
8  return [process.execPath, "-e", script]
9}
10 
11describe("util.process", () => {
12  test("captures stdout and stderr", async () => {
13    const out = await Process.run(node('process.stdout.write("out");process.stderr.write("err")'))
14    expect(out.code).toBe(0)
15    expect(out.stdout.toString()).toBe("out")
16    expect(out.stderr.toString()).toBe("err")
17  })
18 
19  test("returns code when nothrow is enabled", async () => {
20    const out = await Process.run(node("process.exit(7)"), { nothrow: true })
21    expect(out.code).toBe(7)
22  })
23 
24  test("throws RunFailedError on non-zero exit", async () => {
25    const err = await Process.run(node('process.stderr.write("bad");process.exit(3)')).catch((error) => error)
26    expect(err).toBeInstanceOf(Process.RunFailedError)
27    if (!(err instanceof Process.RunFailedError)) throw err
28    expect(err.code).toBe(3)
29    expect(err.stderr.toString()).toBe("bad")
30  })
31 
32  test("aborts a running process", async () => {
33    const abort = new AbortController()
34    const started = Date.now()
35    setTimeout(() => abort.abort(), 25)
36 
37    const out = await Process.run(node("setInterval(() => {}, 1000)"), {
38      abort: abort.signal,
39      nothrow: true,
40    })
41 
42    expect(out.code).not.toBe(0)
43    expect(Date.now() - started).toBeLessThan(1000)
44  }, 3000)
45 
46  test("kills after timeout when process ignores terminate signal", async () => {
47    if (process.platform === "win32") return
48 
49    const abort = new AbortController()
50    const started = Date.now()
51    setTimeout(() => abort.abort(), 25)
52 
53    const out = await Process.run(node('process.on("SIGTERM", () => {}); setInterval(() => {}, 1000)'), {
54      abort: abort.signal,
55      nothrow: true,
56      timeout: 25,
57    })
58 
59    expect(out.code).not.toBe(0)
60    expect(Date.now() - started).toBeLessThan(1000)
61  }, 3000)
62 
63  test("uses cwd when spawning commands", async () => {
64    await using tmp = await tmpdir()
65    const out = await Process.run(node("process.stdout.write(process.cwd())"), {
66      cwd: tmp.path,
67    })
68    expect(out.stdout.toString()).toBe(tmp.path)
69  })
70 
71  test("merges environment overrides", async () => {
72    const out = await Process.run(node('process.stdout.write(process.env.OPENCODE_TEST ?? "")'), {
73      env: {
74        OPENCODE_TEST: "set",
75      },
76    })
77    expect(out.stdout.toString()).toBe("set")
78  })
79 
80  test("uses shell in run on Windows", async () => {
81    if (process.platform !== "win32") return
82 
83    const out = await Process.run(["set", "OPENCODE_TEST_SHELL"], {
84      shell: true,
85      env: {
86        OPENCODE_TEST_SHELL: "ok",
87      },
88    })
89 
90    expect(out.code).toBe(0)
91    expect(out.stdout.toString()).toContain("OPENCODE_TEST_SHELL=ok")
92  })
93 
94  test("runs cmd scripts with spaces on Windows without shell", async () => {
95    if (process.platform !== "win32") return
96 
97    await using tmp = await tmpdir()
98    const dir = path.join(tmp.path, "with space")
99    const file = path.join(dir, "echo cmd.cmd")
100 
101    await fs.mkdir(dir, { recursive: true })
102    await Bun.write(file, "@echo off\r\nif %~1==--stdio exit /b 0\r\nexit /b 7\r\n")
103 
104    const proc = Process.spawn([file, "--stdio"], {
105      stdin: "pipe",
106      stdout: "pipe",
107      stderr: "pipe",
108    })
109 
110    expect(await proc.exited).toBe(0)
111  })
112 
113  test("rejects missing commands without leaking unhandled errors", async () => {
114    await using tmp = await tmpdir()
115    const cmd = path.join(tmp.path, "missing" + (process.platform === "win32" ? ".cmd" : ""))
116    const err = await Process.spawn([cmd], {
117      stdin: "pipe",
118      stdout: "pipe",
119      stderr: "pipe",
120    }).exited.catch((err) => err)
121 
122    expect(err).toBeInstanceOf(Error)
123    if (!(err instanceof Error)) throw err
124    expect(err).toMatchObject({
125      code: "ENOENT",
126    })
127  })
128})
129