import { Context, Effect, Layer, Result, Schema, SchemaIssue } from "effect"; import { TrimmedNonEmptyString, type VcsError } from "@t3tools/contracts"; import { VcsProcess, type VcsProcessOutput } from "../vcs/VcsProcess.ts";import {  decodeGitHubPullRequestJson,  decodeGitHubPullRequestListJson,  formatGitHubJsonDecodeError,} from "./gitHubPullRequests.ts"; const DEFAULT_TIMEOUT_MS = 30_000; export class GitHubCliError extends Schema.TaggedErrorClass<GitHubCliError>()("GitHubCliError", {  operation: Schema.String,  detail: Schema.String,  cause: Schema.optional(Schema.Defect),}) {  override get message(): string {    return `GitHub CLI failed in ${this.operation}: ${this.detail}`;  }} export interface GitHubPullRequestSummary {  readonly number: number;  readonly title: string;  readonly url: string;  readonly baseRefName: string;  readonly headRefName: string;  readonly state?: "open" | "closed" | "merged";  readonly isCrossRepository?: boolean;  readonly headRepositoryNameWithOwner?: string | null;  readonly headRepositoryOwnerLogin?: string | null;} export interface GitHubRepositoryCloneUrls {  readonly nameWithOwner: string;  readonly url: string;  readonly sshUrl: string;} export interface GitHubCliShape {  readonly execute: (input: {    readonly cwd: string;    readonly args: ReadonlyArray<string>;    readonly timeoutMs?: number;  }) => Effect.Effect<VcsProcessOutput, GitHubCliError>;   readonly listOpenPullRequests: (input: {    readonly cwd: string;    readonly headSelector: string;    readonly limit?: number;  }) => Effect.Effect<ReadonlyArray<GitHubPullRequestSummary>, GitHubCliError>;   readonly getPullRequest: (input: {    readonly cwd: string;    readonly reference: string;  }) => Effect.Effect<GitHubPullRequestSummary, GitHubCliError>;   readonly getRepositoryCloneUrls: (input: {    readonly cwd: string;    readonly repository: string;  }) => Effect.Effect<GitHubRepositoryCloneUrls, GitHubCliError>;   readonly createPullRequest: (input: {    readonly cwd: string;    readonly baseBranch: string;    readonly headSelector: string;    readonly title: string;    readonly bodyFile: string;  }) => Effect.Effect<void, GitHubCliError>;   readonly getDefaultBranch: (input: {    readonly cwd: string;  }) => Effect.Effect<string | null, GitHubCliError>;   readonly checkoutPullRequest: (input: {    readonly cwd: string;    readonly reference: string;    readonly force?: boolean;  }) => Effect.Effect<void, GitHubCliError>;} export class GitHubCli extends Context.Service<GitHubCli, GitHubCliShape>()(  "t3/source-control/GitHubCli",) {} function errorText(error: VcsError | unknown): string {  if (typeof error === "object" && error !== null) {    const tag = "_tag" in error && typeof error._tag === "string" ? error._tag : "";    const detail = "detail" in error && typeof error.detail === "string" ? error.detail : "";    const message = "message" in error && typeof error.message === "string" ? error.message : "";    return [tag, detail, message].filter(Boolean).join("\n");  }   return String(error);} function normalizeGitHubCliError(  operation: "execute" | "stdout",  error: VcsError | unknown,): GitHubCliError {  const text = errorText(error);  const lower = text.toLowerCase();   if (lower.includes("command not found: gh") || lower.includes("enoent")) {    return new GitHubCliError({      operation,      detail: "GitHub CLI (`gh`) is required but not available on PATH.",      cause: error,    });  }   if (    lower.includes("authentication failed") ||    lower.includes("not logged in") ||    lower.includes("gh auth login") ||    lower.includes("no oauth token")  ) {    return new GitHubCliError({      operation,      detail: "GitHub CLI is not authenticated. Run `gh auth login` and retry.",      cause: error,    });  }   if (    lower.includes("could not resolve to a pullrequest") ||    lower.includes("repository.pullrequest") ||    lower.includes("no pull requests found for branch") ||    lower.includes("pull request not found")  ) {    return new GitHubCliError({      operation,      detail: "Pull request not found. Check the PR number or URL and try again.",      cause: error,    });  }   return new GitHubCliError({    operation,    detail: text,    cause: error,  });} const RawGitHubRepositoryCloneUrlsSchema = Schema.Struct({  nameWithOwner: TrimmedNonEmptyString,  url: TrimmedNonEmptyString,  sshUrl: TrimmedNonEmptyString,}); function normalizeRepositoryCloneUrls(  raw: Schema.Schema.Type<typeof RawGitHubRepositoryCloneUrlsSchema>,): GitHubRepositoryCloneUrls {  return {    nameWithOwner: raw.nameWithOwner,    url: raw.url,    sshUrl: raw.sshUrl,  };} function decodeGitHubJson<S extends Schema.Top>(  raw: string,  schema: S,  operation: "listOpenPullRequests" | "getPullRequest" | "getRepositoryCloneUrls",  invalidDetail: string,): Effect.Effect<S["Type"], GitHubCliError, S["DecodingServices"]> {  return Schema.decodeEffect(Schema.fromJsonString(schema))(raw).pipe(    Effect.mapError(      (error) =>        new GitHubCliError({          operation,          detail: `${invalidDetail}: ${SchemaIssue.makeFormatterDefault()(error.issue)}`,          cause: error,        }),    ),  );} export const make = Effect.fn("makeGitHubCli")(function* () {  const process = yield* VcsProcess;   const execute: GitHubCliShape["execute"] = (input) =>    process      .run({        operation: "GitHubCli.execute",        command: "gh",        args: input.args,        cwd: input.cwd,        timeoutMs: input.timeoutMs ?? DEFAULT_TIMEOUT_MS,      })      .pipe(Effect.mapError((error) => normalizeGitHubCliError("execute", error)));   return GitHubCli.of({    execute,    listOpenPullRequests: (input) =>      execute({        cwd: input.cwd,        args: [          "pr",          "list",          "--head",          input.headSelector,          "--state",          "open",          "--limit",          String(input.limit ?? 1),          "--json",          "number,title,url,baseRefName,headRefName,state,mergedAt,isCrossRepository,headRepository,headRepositoryOwner",        ],      }).pipe(        Effect.map((result) => result.stdout.trim()),        Effect.flatMap((raw) =>          raw.length === 0            ? Effect.succeed([])            : Effect.sync(() => decodeGitHubPullRequestListJson(raw)).pipe(                Effect.flatMap((decoded) => {                  if (!Result.isSuccess(decoded)) {                    return Effect.fail(                      new GitHubCliError({                        operation: "listOpenPullRequests",                        detail: `GitHub CLI returned invalid PR list JSON: ${formatGitHubJsonDecodeError(decoded.failure)}`,                        cause: decoded.failure,                      }),                    );                  }                   return Effect.succeed(                    decoded.success.map(({ updatedAt: _updatedAt, ...summary }) => summary),                  );                }),              ),        ),      ),    getPullRequest: (input) =>      execute({        cwd: input.cwd,        args: [          "pr",          "view",          input.reference,          "--json",          "number,title,url,baseRefName,headRefName,state,mergedAt,isCrossRepository,headRepository,headRepositoryOwner",        ],      }).pipe(        Effect.map((result) => result.stdout.trim()),        Effect.flatMap((raw) =>          Effect.sync(() => decodeGitHubPullRequestJson(raw)).pipe(            Effect.flatMap((decoded) => {              if (!Result.isSuccess(decoded)) {                return Effect.fail(                  new GitHubCliError({                    operation: "getPullRequest",                    detail: `GitHub CLI returned invalid pull request JSON: ${formatGitHubJsonDecodeError(decoded.failure)}`,                    cause: decoded.failure,                  }),                );              }               return Effect.succeed(                (({ updatedAt: _updatedAt, ...summary }) => summary)(decoded.success),              );            }),          ),        ),      ),    getRepositoryCloneUrls: (input) =>      execute({        cwd: input.cwd,        args: ["repo", "view", input.repository, "--json", "nameWithOwner,url,sshUrl"],      }).pipe(        Effect.map((result) => result.stdout.trim()),        Effect.flatMap((raw) =>          decodeGitHubJson(            raw,            RawGitHubRepositoryCloneUrlsSchema,            "getRepositoryCloneUrls",            "GitHub CLI returned invalid repository JSON.",          ),        ),        Effect.map(normalizeRepositoryCloneUrls),      ),    createPullRequest: (input) =>      execute({        cwd: input.cwd,        args: [          "pr",          "create",          "--base",          input.baseBranch,          "--head",          input.headSelector,          "--title",          input.title,          "--body-file",          input.bodyFile,        ],      }).pipe(Effect.asVoid),    getDefaultBranch: (input) =>      execute({        cwd: input.cwd,        args: ["repo", "view", "--json", "defaultBranchRef", "--jq", ".defaultBranchRef.name"],      }).pipe(        Effect.map((value) => {          const trimmed = value.stdout.trim();          return trimmed.length > 0 ? trimmed : null;        }),      ),    checkoutPullRequest: (input) =>      execute({        cwd: input.cwd,        args: ["pr", "checkout", input.reference, ...(input.force ? ["--force"] : [])],      }).pipe(Effect.asVoid),  });}); export const layer = Layer.effect(GitHubCli, make());