import { assert, it } from "@effect/vitest";import * as NodeServices from "@effect/platform-node/NodeServices";import * as Effect from "effect/Effect";import * as Layer from "effect/Layer";import * as Option from "effect/Option";import { ChildProcessSpawner } from "effect/unstable/process";import { VcsProcessSpawnError } from "@t3tools/contracts"; import * as ServerConfig from "../config.ts";import * as VcsDriverRegistry from "../vcs/VcsDriverRegistry.ts";import * as VcsProcess from "../vcs/VcsProcess.ts";import * as AzureDevOpsCli from "./AzureDevOpsCli.ts";import * as BitbucketApi from "./BitbucketApi.ts";import * as GitHubCli from "./GitHubCli.ts";import * as GitLabCli from "./GitLabCli.ts";import * as SourceControlDiscovery from "./SourceControlDiscovery.ts";import * as SourceControlProviderRegistry from "./SourceControlProviderRegistry.ts"; const sourceControlProviderRegistryTestLayer = (input: {  readonly bitbucket: Partial<BitbucketApi.BitbucketApi["Service"]>;  readonly process: Partial<VcsProcess.VcsProcess["Service"]>;}) =>  SourceControlProviderRegistry.layer.pipe(    Layer.provide(      Layer.mergeAll(        ServerConfig.layerTest(process.cwd(), {          prefix: "t3-source-control-registry-test-",        }).pipe(Layer.provide(NodeServices.layer)),        Layer.mock(AzureDevOpsCli.AzureDevOpsCli)({}),        Layer.mock(BitbucketApi.BitbucketApi)(input.bitbucket),        Layer.mock(GitHubCli.GitHubCli)({}),        Layer.mock(GitLabCli.GitLabCli)({}),        Layer.mock(VcsDriverRegistry.VcsDriverRegistry)({}),        Layer.mock(VcsProcess.VcsProcess)(input.process),      ),    ),  ); const processOutput = (  stdout: string,  options?: {    readonly stderr?: string;    readonly exitCode?: ChildProcessSpawner.ExitCode;  },): VcsProcess.VcsProcessOutput => ({  exitCode: options?.exitCode ?? ChildProcessSpawner.ExitCode(0),  stdout,  stderr: options?.stderr ?? "",  stdoutTruncated: false,  stderrTruncated: false,}); it.effect("reports implemented tools separately from locally available executables", () => {  const processMock = {    run: (input: VcsProcess.VcsProcessInput) => {      if (input.command === "git") {        return Effect.succeed(processOutput("git version 2.51.0\n"));      }      if (input.command === "gh" && input.args[0] === "--version") {        return Effect.succeed(processOutput("gh version 2.83.0\n"));      }      if (input.command === "gh" && input.args.join(" ") === "auth status --json hosts") {        return Effect.succeed(          processOutput(            JSON.stringify({              hosts: {                "github.com": [                  {                    state: "success",                    active: true,                    host: "github.com",                    login: "juliusmarminge",                    tokenSource: "keyring",                    gitProtocol: "ssh",                  },                ],              },            }),          ),        );      }      return Effect.fail(        new VcsProcessSpawnError({          operation: input.operation,          command: input.command,          cwd: input.cwd,          cause: new Error(`${input.command} not found`),        }),      );    },  } satisfies Partial<VcsProcess.VcsProcess["Service"]>;  const testLayer = SourceControlDiscovery.layer.pipe(    Layer.provide(      ServerConfig.layerTest(process.cwd(), {        prefix: "t3-source-control-discovery-",      }),    ),    Layer.provide(Layer.mock(VcsProcess.VcsProcess)(processMock)),    Layer.provide(      sourceControlProviderRegistryTestLayer({        process: processMock,        bitbucket: {          probeAuth: Effect.succeed({            status: "unauthenticated",            account: Option.none(),            host: Option.some("bitbucket.org"),            detail: Option.some(              "Set T3CODE_BITBUCKET_EMAIL and T3CODE_BITBUCKET_API_TOKEN, or T3CODE_BITBUCKET_ACCESS_TOKEN.",            ),          }),        },      }),    ),    Layer.provideMerge(NodeServices.layer),  );   return Effect.gen(function* () {    const discovery = yield* SourceControlDiscovery.SourceControlDiscovery;    const result = yield* discovery.discover;     assert.deepStrictEqual(      result.versionControlSystems.map((item) => ({        kind: item.kind,        implemented: item.implemented,        status: item.status,      })),      [        { kind: "git", implemented: true, status: "available" },        { kind: "jj", implemented: false, status: "missing" },      ],    );    assert.deepStrictEqual(      result.sourceControlProviders.map((item) => ({        kind: item.kind,        status: item.status,        auth: item.auth.status,        account: item.auth.account,      })),      [        {          kind: "github",          status: "available",          auth: "authenticated",          account: Option.some("juliusmarminge"),        },        {          kind: "gitlab",          status: "missing",          auth: "unknown",          account: Option.none(),        },        {          kind: "azure-devops",          status: "missing",          auth: "unknown",          account: Option.none(),        },        {          kind: "bitbucket",          status: "available",          auth: "unauthenticated",          account: Option.none(),        },      ],    );    const bitbucket = result.sourceControlProviders.find((item) => item.kind === "bitbucket");    assert.ok(bitbucket);    assert.strictEqual(bitbucket.executable, undefined);  }).pipe(Effect.provide(testLayer));}); it.effect("probes provider authentication without exposing token details", () => {  const processMock = {    run: (input: VcsProcess.VcsProcessInput) => {      if (input.args[0] === "--version") {        return Effect.succeed(processOutput(`${input.command} version test\n`));      }      if (input.command === "gh" && input.args.join(" ") === "auth status --json hosts") {        return Effect.succeed(          processOutput(            JSON.stringify({              hosts: {                "github.com": [                  {                    state: "success",                    active: true,                    host: "github.com",                    login: "octocat",                    tokenSource: "keyring",                    gitProtocol: "ssh",                  },                ],              },            }),          ),        );      }      if (input.command === "glab" && input.args.join(" ") === "auth status") {        return Effect.succeed(          processOutput(`gitlab.comLogged in to gitlab.com as gitlab-user`),        );      }      if (        input.command === "az" &&        input.args.join(" ") === "account show --query user.name -o tsv"      ) {        return Effect.succeed(processOutput("azure-user@example.com\n"));      }      return Effect.fail(        new VcsProcessSpawnError({          operation: input.operation,          command: input.command,          cwd: input.cwd,          cause: new Error(`${input.command} not found`),        }),      );    },  } satisfies Partial<VcsProcess.VcsProcess["Service"]>;  const testLayer = SourceControlDiscovery.layer.pipe(    Layer.provide(      ServerConfig.layerTest(process.cwd(), {        prefix: "t3-source-control-auth-discovery-",      }),    ),    Layer.provide(Layer.mock(VcsProcess.VcsProcess)(processMock)),    Layer.provide(      sourceControlProviderRegistryTestLayer({        process: processMock,        bitbucket: {          probeAuth: Effect.succeed({            status: "authenticated",            account: Option.some("bitbucket-user"),            host: Option.some("bitbucket.org"),            detail: Option.none(),          }),        },      }),    ),    Layer.provideMerge(NodeServices.layer),  );   return Effect.gen(function* () {    const discovery = yield* SourceControlDiscovery.SourceControlDiscovery;    const result = yield* discovery.discover;     assert.deepStrictEqual(      result.sourceControlProviders.map((item) => ({        kind: item.kind,        auth: item.auth.status,        account: item.auth.account,        detail: item.auth.detail,      })),      [        {          kind: "github",          auth: "authenticated",          account: Option.some("octocat"),          detail: Option.none(),        },        {          kind: "gitlab",          auth: "authenticated",          account: Option.some("gitlab-user"),          detail: Option.none(),        },        {          kind: "azure-devops",          auth: "authenticated",          account: Option.some("azure-user@example.com"),          detail: Option.none(),        },        {          kind: "bitbucket",          auth: "authenticated",          account: Option.some("bitbucket-user"),          detail: Option.none(),        },      ],    );  }).pipe(Effect.provide(testLayer));});