openAgent

1import { describe, expect } from "bun:test"
2import { Effect } from "effect"
3import { CrossSpawnSpawner } from "@opencode-ai/core/cross-spawn-spawner"
4import { Npm } from "@opencode-ai/core/npm"
5import path from "path"
6import { pathToFileURL } from "url"
7import { Account } from "../../src/account/account"
8import { Auth } from "../../src/auth"
9import { RuntimeFlags } from "../../src/effect/runtime-flags"
10import { Plugin } from "../../src/plugin/index"
11 
12import { TestInstance } from "../fixture/fixture"
13import { testEffect } from "../lib/effect"
14import { AccountTest } from "../fake/account"
15import { AuthTest } from "../fake/auth"
16import { NpmTest } from "../fake/npm"
17import { ProviderV2 } from "@opencode-ai/core/provider"
18import { ModelV2 } from "@opencode-ai/core/model"
19import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"
20import { LayerNode } from "@opencode-ai/core/effect/layer-node"
21 
22const it = testEffect(
23  AppNodeBuilder.build(LayerNode.group([Plugin.node, CrossSpawnSpawner.node]), [
24    [Auth.node, AuthTest.empty],
25    [Account.node, AccountTest.empty],
26    [Npm.node, NpmTest.noop],
27    [RuntimeFlags.node, RuntimeFlags.layer({ disableDefaultPlugins: true })],
28  ]),
29)
30const systemHook = "experimental.chat.system.transform"
31 
32function withProject<A, E, R>(source: string, self: Effect.Effect<A, E, R>) {
33  return Effect.gen(function* () {
34    const test = yield* TestInstance
35    const file = path.join(test.directory, "plugin.ts")
36    yield* Effect.all(
37      [
38        Effect.promise(() => Bun.write(file, source)),
39        Effect.promise(() =>
40          Bun.write(
41            path.join(test.directory, "opencode.json"),
42            JSON.stringify(
43              {
44                $schema: "https://opencode.ai/config.json",
45                plugin: [pathToFileURL(file).href],
46              },
47              null,
48              2,
49            ),
50          ),
51        ),
52      ],
53      { discard: true, concurrency: 2 },
54    )
55    return yield* self
56  })
57}
58 
59const triggerSystemTransform = Effect.fn("PluginTriggerTest.triggerSystemTransform")(function* () {
60  const plugin = yield* Plugin.Service
61  const out = { system: [] as string[] }
62  yield* plugin.trigger(
63    systemHook,
64    {
65      model: {
66        providerID: ProviderV2.ID.anthropic,
67        modelID: ModelV2.ID.make("claude-sonnet-4-6"),
68      },
69    },
70    out,
71  )
72  return out.system
73})
74 
75describe("plugin.trigger", () => {
76  it.instance("runs synchronous hooks without crashing", () =>
77    withProject(
78      [
79        "export default async () => ({",
80        `  ${JSON.stringify(systemHook)}: (_input, output) => {`,
81        '    output.system.unshift("sync")',
82        "  },",
83        "})",
84        "",
85      ].join("\n"),
86      Effect.gen(function* () {
87        expect(yield* triggerSystemTransform()).toEqual(["sync"])
88      }),
89    ),
90  )
91 
92  it.instance("awaits asynchronous hooks", () =>
93    withProject(
94      [
95        "export default async () => ({",
96        `  ${JSON.stringify(systemHook)}: async (_input, output) => {`,
97        "    await Bun.sleep(1)",
98        '    output.system.unshift("async")',
99        "  },",
100        "})",
101        "",
102      ].join("\n"),
103      Effect.gen(function* () {
104        expect(yield* triggerSystemTransform()).toEqual(["async"])
105      }),
106    ),
107  )
108})
109