Function openSse

e2e/cloud/mcp-protocol.test.ts:524–533

()

    const sessionId = yield* Effect.promise(() => openSession(target.mcpUrl, bearer));

    const openSse = () =>
      fetch(target.mcpUrl, {
        method: "GET",
        headers: {
          accept: "text/event-stream",
          authorization: `Bearer ${bearer}`,
          "mcp-protocol-version": PROTOCOL_VERSION,
          "mcp-session-id": sessionId,
        },
      });

    const first = yield* Effect.promise(openSse);
    expect(first.status, "the standalone SSE stream opens").toBe(200);