openAgent

1import { describe, expect, test } from "bun:test"
2import { Readable } from "node:stream"
3import { INTERACTIVE_INPUT_ERROR, resolveInteractiveStdin } from "@/cli/cmd/run/runtime.stdin"
4 
5function stream(isTTY: boolean) {
6  return Object.assign(new Readable({ read() {} }), { isTTY }) as NodeJS.ReadStream
7}
8 
9describe("run interactive stdin", () => {
10  test("reuses stdin when it is already a tty", () => {
11    const stdin = stream(true)
12    const seen: string[] = []
13    const result = resolveInteractiveStdin(
14      stdin,
15      (path) => {
16        seen.push(path)
17        return stream(true)
18      },
19      "linux",
20    )
21 
22    expect(result.stdin).toBe(stdin)
23    expect(result.cleanup).toBeUndefined()
24    expect(seen).toEqual([])
25  })
26 
27  test("opens the controlling terminal when stdin is piped", () => {
28    const tty = stream(true)
29    const seen: string[] = []
30    const result = resolveInteractiveStdin(
31      stream(false),
32      (path) => {
33        seen.push(path)
34        return tty
35      },
36      "linux",
37    )
38 
39    expect(result.stdin).toBe(tty)
40    expect(seen).toEqual(["/dev/tty"])
41 
42    result.cleanup?.()
43    expect(tty.destroyed).toBe(true)
44  })
45 
46  test("uses CONIN$ on windows", () => {
47    const seen: string[] = []
48    resolveInteractiveStdin(
49      stream(false),
50      (path) => {
51        seen.push(path)
52        return stream(true)
53      },
54      "win32",
55    )
56 
57    expect(seen).toEqual(["CONIN$"])
58  })
59 
60  test("throws a clear error when no controlling terminal is available", () => {
61    expect(() =>
62      resolveInteractiveStdin(
63        stream(false),
64        () => {
65          throw new Error("open failed")
66        },
67        "linux",
68      ),
69    ).toThrow(INTERACTIVE_INPUT_ERROR)
70  })
71})
72