LLM/opencode
1
0
Fork 0
mirror of https://github.com/anomalyco/opencode.git synced 2026-05-21 03:15:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(file): stream ripgrep search parsing

Browse Source
This commit is contained in:
Kit Langton
2026-04-13 10:14:19 -04:00
parent c22e34853d
commit f2a83a0a00
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
packages/opencode/src/file/ripgrep.ts
View File

@@ -408,6 +408,14 @@ export namespace Ripgrep {
}) {
return yield* Effect.scoped(
Effect.gen(function* () {
const parse = Effect.fn("Ripgrep.parse")(function* (line: string) {
const row = yield* Effect.try({
try: () => Result.parse(JSON.parse(line)),
catch: (cause) => new Error(`invalid ripgrep output: ${cause}`),
})
if (row.type !== "match") return undefined
return row.data
})
const cmd = yield* args({
mode: "search",
glob: input.glob,
@@ -428,11 +436,8 @@ export namespace Ripgrep {
Stream.decodeText(handle.stdout).pipe(
Stream.splitLines,
Stream.filter((line) => line.length > 0),
Stream.mapEffect((line) =>
decode(line).pipe(Effect.mapError((cause) => new Error("invalid ripgrep output", { cause }))),
),
Stream.filter((row): row is Schema.Schema.Type<typeof Hit> => row.type === "match"),
Stream.map((row): Item => row.data),
Stream.mapEffect(parse),
Stream.filter((item): item is Item => item !== undefined),
Stream.runCollect,
Effect.map((chunk) => [...chunk]),
),