chore: generate
This commit is contained in:
@@ -328,9 +328,9 @@ export namespace Ripgrep {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return spawner.streamLines(
|
return spawner
|
||||||
ChildProcess.make(args[0], args.slice(1), { cwd: input.cwd }),
|
.streamLines(ChildProcess.make(args[0], args.slice(1), { cwd: input.cwd }))
|
||||||
).pipe(Stream.filter((line: string) => line.length > 0))
|
.pipe(Stream.filter((line: string) => line.length > 0))
|
||||||
})
|
})
|
||||||
|
|
||||||
return Service.of({
|
return Service.of({
|
||||||
|
|||||||
@@ -51,7 +51,11 @@ export const GlobTool = Tool.defineEffect(
|
|||||||
Effect.gen(function* () {
|
Effect.gen(function* () {
|
||||||
const full = path.resolve(search, file)
|
const full = path.resolve(search, file)
|
||||||
const info = yield* fs.stat(full).pipe(Effect.catch(() => Effect.succeed(undefined)))
|
const info = yield* fs.stat(full).pipe(Effect.catch(() => Effect.succeed(undefined)))
|
||||||
const mtime = info?.mtime.pipe(Option.map((d) => d.getTime()), Option.getOrElse(() => 0)) ?? 0
|
const mtime =
|
||||||
|
info?.mtime.pipe(
|
||||||
|
Option.map((d) => d.getTime()),
|
||||||
|
Option.getOrElse(() => 0),
|
||||||
|
) ?? 0
|
||||||
return { path: full, mtime }
|
return { path: full, mtime }
|
||||||
}),
|
}),
|
||||||
),
|
),
|
||||||
|
|||||||
@@ -66,7 +66,10 @@ describe("Ripgrep.Service", () => {
|
|||||||
|
|
||||||
const files = await Effect.gen(function* () {
|
const files = await Effect.gen(function* () {
|
||||||
const rg = yield* Ripgrep.Service
|
const rg = yield* Ripgrep.Service
|
||||||
return yield* rg.files({ cwd: tmp.path }).pipe(Stream.runCollect, Effect.map((chunk) => [...chunk].sort()))
|
return yield* rg.files({ cwd: tmp.path }).pipe(
|
||||||
|
Stream.runCollect,
|
||||||
|
Effect.map((chunk) => [...chunk].sort()),
|
||||||
|
)
|
||||||
}).pipe(Effect.provide(Ripgrep.defaultLayer), Effect.runPromise)
|
}).pipe(Effect.provide(Ripgrep.defaultLayer), Effect.runPromise)
|
||||||
|
|
||||||
expect(files).toEqual(["a.txt", "b.txt"])
|
expect(files).toEqual(["a.txt", "b.txt"])
|
||||||
@@ -82,7 +85,10 @@ describe("Ripgrep.Service", () => {
|
|||||||
|
|
||||||
const files = await Effect.gen(function* () {
|
const files = await Effect.gen(function* () {
|
||||||
const rg = yield* Ripgrep.Service
|
const rg = yield* Ripgrep.Service
|
||||||
return yield* rg.files({ cwd: tmp.path, glob: ["*.ts"] }).pipe(Stream.runCollect, Effect.map((chunk) => [...chunk]))
|
return yield* rg.files({ cwd: tmp.path, glob: ["*.ts"] }).pipe(
|
||||||
|
Stream.runCollect,
|
||||||
|
Effect.map((chunk) => [...chunk]),
|
||||||
|
)
|
||||||
}).pipe(Effect.provide(Ripgrep.defaultLayer), Effect.runPromise)
|
}).pipe(Effect.provide(Ripgrep.defaultLayer), Effect.runPromise)
|
||||||
|
|
||||||
expect(files).toEqual(["keep.ts"])
|
expect(files).toEqual(["keep.ts"])
|
||||||
|
|||||||
Reference in New Issue
Block a user