Class Worktrees

packages/tools/api-diff/src/Worktrees.ts:25–243

}

export class Worktrees extends Context.Service<Worktrees, {
  readonly resolveRef: (repoRoot: string, ref: string) => Effect.Effect<string, ApiDiffError>
  readonly prepareSnapshot: (options: PrepareSnapshotOptions) => Effect.Effect<ApiSnapshot, ApiDiffError>
}>()("@effect/api-diff/Worktrees") {
  static readonly layerNoDependencies = Layer.effect(
    Worktrees,
    Effect.gen(function*() {
      const fs = yield* FileSystem.FileSystem
      const path = yield* Path.Path
      const snapshotter = yield* Snapshotter
      const spawner = yield* ChildProcessSpawner.ChildProcessSpawner

      const runCommandScoped = Effect.fnUntraced(function*(
        command: string,
        args: ReadonlyArray<string>,
        cwd: string
      ) {
        const display = `${command} ${args.join(" ")}`
        const handle = yield* spawner.spawn(
          ChildProcess.make(command, args, { cwd })
        ).pipe(
          Effect.mapError((cause) =>
            new ApiDiffError({
              message: `Could not start command (${display})`,
              cause
            })
          )
        )
        const [output, exitCode] = yield* Effect.all([
          Stream.mkString(Stream.decodeText(handle.all)),
          handle.exitCode
        ], { concurrency: "unbounded" }).pipe(
          Effect.mapError((cause) =>
            new ApiDiffError({
              message: `Could not run command (${display})`,
              cause
            })
          )
        )
        return { display, exitCode, output }
      })

      const runCommand = (
        command: string,
        args: ReadonlyArray<string>,
        cwd: string
      ): Effect.Effect<{
        readonly display: string
        readonly exitCode: ChildProcessSpawner.ExitCode
        readonly output: string
      }, ApiDiffError> => Effect.scoped(runCommandScoped(command, args, cwd))

      const runChecked = Effect.fnUntraced(function*(
        command: string,
        args: ReadonlyArray<string>,
        cwd: string
      ) {
        const result = yield* runCommand(command, args, cwd)