openAgent

1import { describe, expect } from "bun:test"
2import fs from "fs/promises"
3import path from "path"
4import { Effect } from "effect"
5import { LayerNode } from "@opencode-ai/core/effect/layer-node"
6import { Ripgrep } from "@opencode-ai/core/ripgrep"
7import { RelativePath } from "@opencode-ai/core/schema"
8import { tmpdir } from "./fixture/tmpdir"
9import { testEffect } from "./lib/effect"
10 
11const it = testEffect(LayerNode.compile(Ripgrep.node))
12 
13describe("Ripgrep", () => {
14  it.live("keeps ignored files out of catch-all find results", () =>
15    Effect.acquireUseRelease(
16      Effect.promise(() => tmpdir()),
17      (tmp) =>
18        Effect.gen(function* () {
19          yield* Effect.promise(() => fs.mkdir(path.join(tmp.path, "node_modules", "pkg"), { recursive: true }))
20          yield* Effect.promise(() => fs.mkdir(path.join(tmp.path, "src")))
21          yield* Effect.promise(() => Bun.$`git init -q ${tmp.path}`)
22          yield* Effect.promise(() => fs.writeFile(path.join(tmp.path, ".gitignore"), "node_modules/\n"))
23          yield* Effect.promise(() => fs.writeFile(path.join(tmp.path, "node_modules", "pkg", "index.js"), "ignored\n"))
24          yield* Effect.promise(() => fs.writeFile(path.join(tmp.path, "src", "index.js"), "included\n"))
25 
26          const files = yield* (yield* Ripgrep.Service).find({ cwd: tmp.path, pattern: "*", limit: 10 })
27          expect(files.map((item) => item.path)).toContain(RelativePath.make("src/index.js"))
28          expect(files.map((item) => item.path)).not.toContain(RelativePath.make("node_modules/pkg/index.js"))
29        }),
30      (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()),
31    ),
32  )
33 
34  it.live("never includes git metadata", () =>
35    Effect.acquireUseRelease(
36      Effect.promise(() => tmpdir()),
37      (tmp) =>
38        Effect.gen(function* () {
39          yield* Effect.promise(() => fs.mkdir(path.join(tmp.path, ".opencode")))
40          yield* Effect.promise(() => fs.writeFile(path.join(tmp.path, ".opencode", "config"), "needle\n"))
41          yield* Effect.promise(() => fs.mkdir(path.join(tmp.path, ".git")))
42          yield* Effect.promise(() => fs.writeFile(path.join(tmp.path, ".git", "config"), "needle\n"))
43          const ripgrep = yield* Ripgrep.Service
44 
45          const files = yield* ripgrep.find({ cwd: tmp.path, pattern: "**/*", limit: 10 })
46          expect(files.map((item) => item.path)).toContain(RelativePath.make(".opencode/config"))
47          expect(files.map((item) => item.path)).not.toContain(RelativePath.make(".git/config"))
48 
49          const observed: string[] = []
50          const limited = yield* ripgrep.find({
51            cwd: tmp.path,
52            pattern: "**/*",
53            limit: 1,
54            onEntry: (entry) => Effect.sync(() => observed.push(entry.path)),
55          })
56          expect(observed).toEqual(limited.map((item) => item.path))
57 
58          const matches = yield* ripgrep.grep({ cwd: tmp.path, pattern: "needle", include: "config", limit: 10 })
59          expect(matches.map((item) => item.entry.path)).toContain(RelativePath.make(".opencode/config"))
60          expect(matches.map((item) => item.entry.path)).not.toContain(RelativePath.make(".git/config"))
61        }),
62      (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()),
63    ),
64  )
65  it.live("does not split surrogate pairs in oversized line previews", () =>
66    Effect.acquireUseRelease(
67      Effect.promise(() => tmpdir()),
68      (tmp) =>
69        Effect.gen(function* () {
70          yield* Effect.promise(() =>
71            fs.writeFile(path.join(tmp.path, "unicode.txt"), `needle${"x".repeat(1_993)}😀\n`),
72          )
73 
74          const matches = yield* (yield* Ripgrep.Service).grep({
75            cwd: tmp.path,
76            pattern: "needle",
77            limit: 10,
78          })
79 
80          expect(matches[0]?.text).toBe(`needle${"x".repeat(1_993)}...`)
81        }),
82      (tmp) => Effect.promise(() => tmp[Symbol.asyncDispose]()),
83    ),
84  )
85})
86