import { expect, it } from "@effect/vitest";import { Effect, Layer } from "effect";import { HttpClient, HttpClientRequest, HttpClientResponse } from "effect/unstable/http";import { structuralSplit } from "@executor-js/plugin-openapi"; import { previewSpecTextStreaming } from "../../sdk/preview";import { microsoftGraphAdapter } from "./spec-format-adapter";import { MICROSOFT_GRAPH_OPENAPI_URL } from "./presets";import { microsoftGraphSliceUrl } from "./slices"; const graphFixture = `openapi: 3.0.4info:  title: Microsoft Graph Fixture  version: v1.0servers:  - url: https://graph.microsoft.com/v1.0paths:  /me:    get:      operationId: me.GetUser      security:        - azureAdDelegated:            - User.Read      responses:        "200":          description: OK  /irrelevant:    get:      operationId: irrelevant.Get      security:        - azureAdDelegated:            - Directory.Read.All      responses:        "200":          description: OKcomponents:  securitySchemes:    azureAdDelegated:      type: oauth2      flows:        authorizationCode:          authorizationUrl: https://login.microsoftonline.com/common/oauth2/v2.0/authorize          tokenUrl: https://login.microsoftonline.com/common/oauth2/v2.0/token          scopes:            User.Read: Read user profile`; const graphHttpClientLayer = Layer.succeed(HttpClient.HttpClient)(  HttpClient.make((request: HttpClientRequest.HttpClientRequest) =>    Effect.succeed(      HttpClientResponse.fromWeb(        request,        new Response(request.url === MICROSOFT_GRAPH_OPENAPI_URL ? graphFixture : "not found", {          status: request.url === MICROSOFT_GRAPH_OPENAPI_URL ? 200 : 404,          headers: { "content-type": "application/yaml" },        }),      ),    ),  ),); it.effect("wraps Microsoft Graph structural split with a streaming keep filter", () =>  Effect.gen(function* () {    const converted = yield* microsoftGraphAdapter.fetch({      urls: [MICROSOFT_GRAPH_OPENAPI_URL],      httpClientLayer: graphHttpClientLayer,    });    const structure = structuralSplit(converted.specText);    expect(structure).not.toBeNull();    const keepPathItem = converted.keepPathItem!;     expect(keepPathItem("/me", { get: { operationId: "me.GetUser" } })).toEqual({      get: { operationId: "me.GetUser" },    });    expect(keepPathItem("/irrelevant", { get: { operationId: "irrelevant.Get" } })).toBeNull();    expect(structure!.pathItems.length).toBe(2);  }),); it.effect("uses catalog URL fragments to select one Graph workload", () =>  Effect.gen(function* () {    const converted = yield* microsoftGraphAdapter.fetch({      urls: [`${MICROSOFT_GRAPH_OPENAPI_URL}#preset=profile`],      httpClientLayer: graphHttpClientLayer,    });    const keepPathItem = converted.keepPathItem!;     expect(keepPathItem("/me", { get: { operationId: "me.GetUser" } })).toEqual({      get: { operationId: "me.GetUser" },    });    expect(keepPathItem("/irrelevant", { get: { operationId: "irrelevant.Get" } })).toBeNull();  }),); // Distinct content at the slice URL so tests can tell which source was read.const sliceFixture = `openapi: 3.0.4info:  title: Microsoft Graph Slice Fixture  version: v1.0servers:  - url: https://graph.microsoft.com/v1.0paths:  /me:    get:      operationId: me.GetUser      security:        - azureAdDelegated:            - User.Read      responses:        "200":          description: OKcomponents:  securitySchemes:    azureAdDelegated:      type: oauth2      flows:        authorizationCode:          authorizationUrl: https://login.microsoftonline.com/common/oauth2/v2.0/authorize          tokenUrl: https://login.microsoftonline.com/common/oauth2/v2.0/token          scopes:            User.Read: Read user profile`; const sliceAwareHttpClientLayer = Layer.succeed(HttpClient.HttpClient)(  HttpClient.make((request: HttpClientRequest.HttpClientRequest) => {    const body =      request.url === microsoftGraphSliceUrl("profile")        ? sliceFixture        : request.url === MICROSOFT_GRAPH_OPENAPI_URL          ? graphFixture          : null;    return Effect.succeed(      HttpClientResponse.fromWeb(        request,        new Response(body ?? "not found", { status: body === null ? 404 : 200 }),      ),    );  }),); it.effect("fetches a slice URL as the byte source and derives its selection from the asset", () =>  Effect.gen(function* () {    const converted = yield* microsoftGraphAdapter.fetch({      urls: [microsoftGraphSliceUrl("profile")],      httpClientLayer: sliceAwareHttpClientLayer,    });     expect(converted.specText).toBe(sliceFixture);    // What is stored is what was fetched — no source substitution.    expect(converted.specUrl).toBe(microsoftGraphSliceUrl("profile"));    // The asset name carries the selection even with no fragment.    const keepPathItem = converted.keepPathItem!;    expect(keepPathItem("/me", { get: { operationId: "me.GetUser" } })).toEqual({      get: { operationId: "me.GetUser" },    });    expect(keepPathItem("/irrelevant", { get: { operationId: "irrelevant.Get" } })).toBeNull();  }),); it.effect("narrows within a slice via the URL fragment", () =>  Effect.gen(function* () {    const layer = Layer.succeed(HttpClient.HttpClient)(      HttpClient.make((request: HttpClientRequest.HttpClientRequest) =>        Effect.succeed(          HttpClientResponse.fromWeb(            request,            new Response(              request.url === microsoftGraphSliceUrl("default") ? sliceFixture : "not found",              { status: request.url === microsoftGraphSliceUrl("default") ? 200 : 404 },            ),          ),        ),      ),    );    const converted = yield* microsoftGraphAdapter.fetch({      urls: [`${microsoftGraphSliceUrl("default")}#preset=profile`],      httpClientLayer: layer,    });     expect(converted.specText).toBe(sliceFixture);    expect(converted.specUrl).toBe(microsoftGraphSliceUrl("default"));    const keepPathItem = converted.keepPathItem!;    // Profile keeps /me; a mail-only path from the default bundle is dropped.    expect(keepPathItem("/me", { get: { operationId: "me.GetUser" } })).toEqual({      get: { operationId: "me.GetUser" },    });    expect(keepPathItem("/me/messages", { post: { operationId: "me.CreateMessage" } })).toBeNull();  }),); it.effect("fetches the monolith URL as given — no silent slice substitution", () =>  Effect.gen(function* () {    // sliceAwareHttpClientLayer serves both URLs; requesting the monolith with    // a preset fragment must read the monolith bytes.    const converted = yield* microsoftGraphAdapter.fetch({      urls: [`${MICROSOFT_GRAPH_OPENAPI_URL}#preset=profile`],      httpClientLayer: sliceAwareHttpClientLayer,    });     expect(converted.specText).toBe(graphFixture);    expect(converted.specUrl).toBe(MICROSOFT_GRAPH_OPENAPI_URL);  }),); it.effect("stream-previews a Graph selection without a whole-document parse", () =>  Effect.gen(function* () {    const converted = yield* microsoftGraphAdapter.fetch({      urls: [`${MICROSOFT_GRAPH_OPENAPI_URL}#preset=profile`],      httpClientLayer: graphHttpClientLayer,    });    const preview = yield* previewSpecTextStreaming(converted.specText, converted.keepPathItem);     expect(preview.operationCount).toBe(1);    expect(preview.operations.map((operation) => operation.operationId)).toEqual(["me.GetUser"]);    expect(preview.healthCheckCandidates).toHaveLength(1);    expect(preview.healthCheckCandidates[0]?.method).toBe("get");    expect(preview.oauth2Presets).toHaveLength(1);    expect(preview.servers.map((server) => server.url)).toEqual([      "https://graph.microsoft.com/v1.0",    ]);  }),);