openAgent

1import { describe, expect, test } from "bun:test"
2import { realpathSync } from "node:fs"
3import { mkdtemp, rm } from "node:fs/promises"
4import { join, resolve, sep } from "node:path"
5 
6const directory = resolve(import.meta.dir, "..")
7const effect = realpathSync(resolve(import.meta.dir, "../node_modules/effect"))
8const schema = resolve(import.meta.dir, "../../schema")
9const protocol = resolve(import.meta.dir, "../../protocol")
10const core = resolve(import.meta.dir, "../../core")
11const server = resolve(import.meta.dir, "../../server")
12 
13describe("public import boundaries", () => {
14  test("isolates each public entrypoint", async () => {
15    const root = await bundleInputs("@opencode-ai/client", "browser")
16 
17    expect(within(root, effect)).toEqual([])
18    expect(within(root, schema)).toEqual([])
19    expect(within(root, protocol)).toEqual([])
20    expect(within(root, core)).toEqual([])
21    expect(within(root, server)).toEqual([])
22 
23    const network = await bundleInputs("@opencode-ai/client/effect", "browser")
24 
25    expect(within(network, effect).length).toBeGreaterThan(0)
26    expect(within(network, schema).length).toBeGreaterThan(0)
27    expect(within(network, protocol).length).toBeGreaterThan(0)
28    expect(within(network, core)).toEqual([])
29    expect(within(network, server)).toEqual([])
30  })
31})
32 
33async function bundleInputs(specifier: string, target: "browser" | "bun") {
34  const temporary = await mkdtemp(join(import.meta.dir, ".import-boundary-"))
35  const entrypoint = join(temporary, "index.ts")
36  const metafile = join(temporary, "meta.json")
37  try {
38    await Bun.write(entrypoint, `export * from ${JSON.stringify(specifier)}`)
39    const child = Bun.spawn(
40      [
41        process.execPath,
42        "build",
43        entrypoint,
44        `--target=${target}`,
45        "--format=esm",
46        "--packages=bundle",
47        `--metafile=${metafile}`,
48        `--outdir=${join(temporary, "out")}`,
49      ],
50      { cwd: directory, stdout: "pipe", stderr: "pipe" },
51    )
52    const [exitCode, stdout, stderr] = await Promise.all([
53      child.exited,
54      new Response(child.stdout).text(),
55      new Response(child.stderr).text(),
56    ])
57    if (exitCode !== 0) throw new Error(stdout + stderr)
58    const metadata = await Bun.file(metafile).json()
59    return Object.keys(metadata.inputs).map((input) => resolve(directory, input))
60  } finally {
61    await rm(temporary, { recursive: true, force: true })
62  }
63}
64 
65function within(inputs: ReadonlyArray<string>, directory: string) {
66  const prefix = directory.endsWith(sep) ? directory : directory + sep
67  return inputs.filter((input) => input === directory || input.startsWith(prefix))
68}
69