import {
  type SourceControlDiscoveryResult,
  type VcsDiscoveryItem,
  type VcsDriverKind,
} from "@t3tools/contracts";
import * as Context from "effect/Context";
import * as Effect from "effect/Effect";
import * as Layer from "effect/Layer";
import * as Option from "effect/Option";

import { ServerConfig } from "../config.ts";
import * as VcsProcess from "../vcs/VcsProcess.ts";
import * as SourceControlProviderDiscovery from "./SourceControlProviderDiscovery.ts";
import * as SourceControlProviderRegistry from "./SourceControlProviderRegistry.ts";

interface DiscoveryProbe {
  readonly label: string;
  readonly executable?: string;
  readonly versionArgs?: ReadonlyArray<string>;
  readonly implemented: boolean;
  readonly installHint: string;
}

type VcsProbe = DiscoveryProbe & {
  readonly kind: VcsDriverKind;
  readonly executable: string;
  readonly versionArgs: ReadonlyArray<string>;
};

interface DiscoveryProbeResult<Kind extends string> {
  readonly kind: Kind;
  readonly label: string;
  readonly executable?: string;
  readonly implemented: boolean;
  readonly status: "available" | "missing";
  readonly version: Option.Option<string>;
  readonly installHint: string;
  readonly detail: Option.Option<string>;
}

const VCS_PROBES: ReadonlyArray<VcsProbe> = [
  {
    kind: "git",
    label: "Git",
    executable: "git",
    versionArgs: ["--version"],
    implemented: true,
    installHint: "Install Git from https://git-scm.com/downloads or with your package manager.",
  },
  {
    kind: "jj",
    label: "Jujutsu",
    executable: "jj",
    versionArgs: ["--version"],
    implemented: false,
    installHint: "Install Jujutsu with `brew install jj` or from https://github.com/jj-vcs/jj.",
  },
];

export interface SourceControlDiscoveryShape {
  readonly discover: Effect.Effect<SourceControlDiscoveryResult>;
}

export class SourceControlDiscovery extends Context.Service<
  SourceControlDiscovery,
  SourceControlDiscoveryShape
>()("t3/source-control/SourceControlDiscovery") {}

export const layer = Layer.effect(
  SourceControlDiscovery,
  Effect.gen(function* () {
    const config = yield* ServerConfig;
    const process = yield* VcsProcess.VcsProcess;
    const sourceControlProviders =
      yield* SourceControlProviderRegistry.SourceControlProviderRegistry;

    const probe = <Kind extends VcsDriverKind>(
      input: DiscoveryProbe & { readonly kind: Kind },
    ): Effect.Effect<DiscoveryProbeResult<Kind>> => {
      const executable = input.executable;
      const versionArgs = input.versionArgs;

      if (!executable || !versionArgs) {
        return Effect.succeed({
          kind: input.kind,
          label: input.label,
          implemented: input.implemented,
          status: "missing" as const,
          version: Option.none<string>(),
          installHint: input.installHint,
          detail: Option.some(input.installHint),
        } satisfies DiscoveryProbeResult<Kind>);
      }

      return process
        .run({
          operation: "source-control.discovery.probe",
          command: executable,
          args: versionArgs,
          cwd: config.cwd,
          timeoutMs: 5_000,
          maxOutputBytes: 8_000,
          appendTruncationMarker: true,
        })
        .pipe(
          Effect.map(
            (result) =>
              ({
                kind: input.kind,
                label: input.label,
                executable,
                implemented: input.implemented,
                status: "available" as const,
                version: Option.orElse(
                  SourceControlProviderDiscovery.firstNonEmptyLine(result.stdout),
                  () => SourceControlProviderDiscovery.firstNonEmptyLine(result.stderr),
                ),
                installHint: input.installHint,
                detail: Option.none<string>(),
              }) satisfies DiscoveryProbeResult<Kind>,
          ),
          Effect.catch((cause) =>
            Effect.succeed({
              kind: input.kind,
              label: input.label,
              executable,
              implemented: input.implemented,
              status: "missing" as const,
              version: Option.none<string>(),
              installHint: input.installHint,
              detail: SourceControlProviderDiscovery.detailFromCause(cause),
            } satisfies DiscoveryProbeResult<Kind>),
          ),
        );
    };

    return SourceControlDiscovery.of({
      discover: Effect.all({
        versionControlSystems: Effect.all(
          VCS_PROBES.map((entry) => probe(entry)) as ReadonlyArray<Effect.Effect<VcsDiscoveryItem>>,
          { concurrency: "unbounded" },
        ),
        sourceControlProviders: sourceControlProviders.discover,
      }),
    });
  }),
);