openAgent

1export * as PluginInternal from "./internal"
2 
3import { makeLocationNode } from "../effect/app-node"
4import { httpClient } from "../effect/app-node-platform"
5import type { PluginContext } from "@opencode-ai/plugin/v2/effect"
6import { Effect, Layer, Scope } from "effect"
7import { AgentV2 } from "../agent"
8import { Catalog } from "../catalog"
9import { CommandV2 } from "../command"
10import { Config } from "../config"
11import { ConfigAgentPlugin } from "../config/plugin/agent"
12import { ConfigCommandPlugin } from "../config/plugin/command"
13import { ConfigExternalPlugin } from "../config/plugin/external"
14import { ConfigProviderPlugin } from "../config/plugin/provider"
15import { ConfigReferencePlugin } from "../config/plugin/reference"
16import { ConfigSkillPlugin } from "../config/plugin/skill"
17import { EventV2 } from "../event"
18import { FileSystem } from "../filesystem"
19import { FSUtil } from "../fs-util"
20import { Global } from "../global"
21import { Integration } from "../integration"
22import { Location } from "../location"
23import { ModelsDev } from "../models-dev"
24import { Npm } from "../npm"
25import { PluginV2 } from "../plugin"
26import { Reference } from "../reference"
27import { SkillV2 } from "../skill"
28import { State } from "../state"
29import { FetchHttpClient, HttpClient } from "effect/unstable/http"
30import { AgentPlugin } from "./agent"
31import { CommandPlugin } from "./command"
32import { ModelsDevPlugin } from "./models-dev"
33import { ProviderPlugins } from "./provider"
34import { SkillPlugin } from "./skill"
35import { VariantPlugin } from "./variant"
36 
37export type Requirements =
38  | AgentV2.Service
39  | Catalog.Service
40  | CommandV2.Service
41  | Config.Service
42  | EventV2.Service
43  | FileSystem.Service
44  | FSUtil.Service
45  | Global.Service
46  | HttpClient.HttpClient
47  | Integration.Service
48  | Location.Service
49  | ModelsDev.Service
50  | Npm.Service
51  | Reference.Service
52  | SkillV2.Service
53 
54export interface Plugin<R = never> {
55  readonly id: string
56  readonly effect: (context: PluginContext) => Effect.Effect<void, never, R | Scope.Scope>
57}
58 
59export function define<R>(plugin: Plugin<R>) {
60  return plugin
61}
62 
63const layer = Layer.effectDiscard(
64  Effect.gen(function* () {
65    const catalog = yield* Catalog.Service
66    const commands = yield* CommandV2.Service
67    const plugin = yield* PluginV2.Service
68    const integration = yield* Integration.Service
69    const agents = yield* AgentV2.Service
70    const config = yield* Config.Service
71    const location = yield* Location.Service
72    const modelsDev = yield* ModelsDev.Service
73    const npm = yield* Npm.Service
74    const events = yield* EventV2.Service
75    const fs = yield* FSUtil.Service
76    const filesystem = yield* FileSystem.Service
77    const global = yield* Global.Service
78    const http = yield* HttpClient.HttpClient
79    const skill = yield* SkillV2.Service
80    const reference = yield* Reference.Service
81    const add = <R>(input: Plugin<R>) => {
82      const loaded = {
83        id: input.id,
84        effect: (context: PluginContext) =>
85          input
86            .effect(context)
87            .pipe(
88              Effect.provideService(Catalog.Service, catalog),
89              Effect.provideService(CommandV2.Service, commands),
90              Effect.provideService(Integration.Service, integration),
91              Effect.provideService(AgentV2.Service, agents),
92              Effect.provideService(Config.Service, config),
93              Effect.provideService(Location.Service, location),
94              Effect.provideService(ModelsDev.Service, modelsDev),
95              Effect.provideService(Npm.Service, npm),
96              Effect.provideService(EventV2.Service, events),
97              Effect.provideService(FSUtil.Service, fs),
98              Effect.provideService(FileSystem.Service, filesystem),
99              Effect.provideService(Global.Service, global),
100              Effect.provideService(HttpClient.HttpClient, http),
101              Effect.provideService(SkillV2.Service, skill),
102              Effect.provideService(Reference.Service, reference),
103            ),
104      }
105      return plugin.add(PluginV2.ID.make(loaded.id), loaded.effect)
106    }
107 
108    yield* State.batch(
109      Effect.gen(function* () {
110        yield* add(ConfigReferencePlugin.Plugin)
111        yield* add(AgentPlugin.Plugin)
112        yield* add(CommandPlugin.Plugin)
113        yield* add(SkillPlugin.Plugin)
114        yield* add(ModelsDevPlugin)
115        yield* add(ConfigAgentPlugin.Plugin)
116        yield* add(ConfigCommandPlugin.Plugin)
117        yield* add(ConfigSkillPlugin.Plugin)
118        for (const item of ProviderPlugins) yield* add(item)
119        yield* add(ConfigExternalPlugin.Plugin)
120        yield* add(ConfigProviderPlugin.Plugin)
121        yield* add(VariantPlugin.Plugin)
122      }),
123    ).pipe(Effect.withSpan("PluginInternal.boot"), Effect.forkScoped({ startImmediately: true }))
124  }),
125)
126 
127export const locationLayer = layer.pipe(
128  Layer.provideMerge(Config.locationLayer),
129  Layer.provideMerge(FetchHttpClient.layer),
130)
131 
132export const node = makeLocationNode({
133  name: "plugin-internal",
134  layer,
135  deps: [
136    Catalog.node,
137    CommandV2.node,
138    PluginV2.node,
139    Integration.node,
140    AgentV2.node,
141    Config.node,
142    Location.node,
143    ModelsDev.node,
144    Npm.node,
145    EventV2.node,
146    FSUtil.node,
147    FileSystem.node,
148    Global.node,
149    httpClient,
150    SkillV2.node,
151    Reference.node,
152  ],
153})
154