import { describe, expect, it } from "@effect/vitest";
import { Effect, Layer } from "effect";
import {
  HttpClient,
  HttpClientError,
  HttpClientRequest,
  HttpClientResponse,
} from "effect/unstable/http";

import { createMcpConnector } from "./connection";

const endpoint = "https://internal.example/mcp";

describe("MCP remote transport failures", () => {
  it.effect("surfaces TLS verification failures without retrying SSE", () =>
    Effect.gen(function* () {
      const requests: string[] = [];
      const httpClientLayer = Layer.succeed(HttpClient.HttpClient)(
        HttpClient.make((request: HttpClientRequest.HttpClientRequest) => {
          requests.push(request.url);
          return Effect.fail(
            new HttpClientError.HttpClientError({
              reason: new HttpClientError.TransportError({
                request,
                cause: {
                  code: "SELF_SIGNED_CERT_IN_CHAIN",
                  message: "do-not-leak: internal certificate detail",
                },
              }),
            }),
          );
        }),
      );

      const failure = yield* createMcpConnector({
        transport: "remote",
        endpoint,
        remoteTransport: "auto",
        httpClientLayer,
      }).pipe(Effect.flip);

      expect(failure).toMatchObject({
        _tag: "McpConnectionError",
        transport: "streamable-http",
        failureKind: "tls",
        message:
          "MCP HTTPS connection failed: TLS certificate verification failed. Check the server certificate and Executor's CA trust configuration.",
      });
      expect(failure.message).not.toContain("do-not-leak");
      expect(requests).toEqual([endpoint]);
    }),
  );

  it.effect("reports both attempts when a protocol mismatch falls back to SSE", () =>
    Effect.gen(function* () {
      const requests: string[] = [];
      const httpClientLayer = Layer.succeed(HttpClient.HttpClient)(
        HttpClient.make((request: HttpClientRequest.HttpClientRequest) => {
          requests.push(`${request.method} ${request.url}`);
          return Effect.succeed(
            HttpClientResponse.fromWeb(
              request,
              new Response("unsupported MCP transport", { status: 405 }),
            ),
          );
        }),
      );

      const failure = yield* createMcpConnector({
        transport: "remote",
        endpoint,
        remoteTransport: "auto",
        httpClientLayer,
      }).pipe(Effect.flip);

      expect(failure).toMatchObject({
        _tag: "McpConnectionError",
        transport: "auto",
        failureKind: "protocol",
        message: "MCP auto transport failed. Streamable HTTP: HTTP 405. SSE fallback: HTTP 405.",
      });
      expect(requests.length).toBeGreaterThanOrEqual(2);
    }),
  );
});