openAgent

1export * as InstructionContext from "./instruction-context"
2 
3import { Array, Effect, Layer, Schema } from "effect"
4import { isAbsolute, join, relative, sep } from "path"
5import { FSUtil } from "./fs-util"
6import { Flag } from "./flag/flag"
7import { Global } from "./global"
8import { Location } from "./location"
9import { AbsolutePath } from "./schema"
10import { SystemContext } from "./system-context/index"
11import { SystemContextRegistry } from "./system-context/registry"
12import { makeLocationNode } from "./effect/app-node"
13 
14class File extends Schema.Class<File>("InstructionContext.File")({
15  path: AbsolutePath,
16  content: Schema.String,
17}) {}
18 
19const Files = Schema.Array(File)
20const key = SystemContext.Key.make("core/instructions")
21 
22const layer = Layer.effectDiscard(
23  Effect.gen(function* () {
24    const fs = yield* FSUtil.Service
25    const global = yield* Global.Service
26    const location = yield* Location.Service
27    const registry = yield* SystemContextRegistry.Service
28 
29    const source = (value: ReadonlyArray<File> | SystemContext.Unavailable) =>
30      SystemContext.make({
31        key,
32        codec: Schema.toCodecJson(Files),
33        load: Effect.succeed(value),
34        baseline: render,
35        update: (_previous, current) =>
36          `These instructions replace all previously loaded ambient instructions.\n\n${render(current)}`,
37        removed: () => "Previously loaded instructions no longer apply.",
38      })
39 
40    const observe = Effect.fn("InstructionContext.observe")(function* () {
41      const start = yield* fs.resolve(location.directory)
42      const stop = yield* fs.resolve(location.project.directory)
43      const fromProject = relative(stop, start)
44      const insideProject =
45        fromProject === "" || (fromProject !== ".." && !fromProject.startsWith(`..${sep}`) && !isAbsolute(fromProject))
46      const discovered = new Set(
47        yield* Effect.forEach(
48          Flag.OPENCODE_DISABLE_PROJECT_CONFIG || !insideProject
49            ? []
50            : yield* fs.up({
51                targets: ["AGENTS.md"],
52                start,
53                stop,
54              }),
55          fs.resolve,
56        ),
57      )
58      const paths = Array.dedupe([yield* fs.resolve(join(global.config, "AGENTS.md")), ...discovered])
59      const files = yield* Effect.forEach(
60        paths,
61        (path) =>
62          fs
63            .readFileStringSafe(path)
64            .pipe(
65              Effect.map((content) =>
66                content === undefined ? undefined : new File({ path: AbsolutePath.make(path), content }),
67              ),
68            ),
69        { concurrency: "unbounded" },
70      )
71      if (files.some((file, index) => file === undefined && discovered.has(paths[index])))
72        return SystemContext.unavailable
73      return files.filter((file): file is File => file !== undefined)
74    })
75 
76    yield* registry.register({
77      key,
78      load: observe().pipe(
79        Effect.map((files) =>
80          files === SystemContext.unavailable
81            ? source(files)
82            : files.length === 0
83              ? SystemContext.empty
84              : source(files),
85        ),
86        Effect.catch(() => Effect.succeed(source(SystemContext.unavailable))),
87        Effect.catchDefect(() => Effect.succeed(source(SystemContext.unavailable))),
88      ),
89    })
90  }),
91)
92 
93export const node = makeLocationNode({
94  name: "instruction-context",
95  layer,
96  deps: [FSUtil.node, Global.node, Location.node, SystemContextRegistry.node],
97})
98 
99function render(files: ReadonlyArray<File>) {
100  return files.map((file) => `Instructions from: ${file.path}\n${file.content}`).join("\n\n")
101}
102