Method constructSseTransport

core/context/mcp/MCPConnection.ts:500–531

(
    options: InternalSseMcpOptions,
  )

  }

  private constructSseTransport(
    options: InternalSseMcpOptions,
  ): SSEClientTransport {
    const sseAgent =
      options.requestOptions?.verifySsl === false
        ? new HttpsAgent({ rejectUnauthorized: false })
        : undefined;

    // Merge apiKey into headers if provided
    const headers = {
      ...options.requestOptions?.headers,
      ...(options.apiKey && { Authorization: `Bearer ${options.apiKey}` }),
    };

    return new SSEClientTransport(new URL(options.url), {
      eventSourceInit: {
        fetch: (input, init) =>
          fetch(input, {
            ...init,
            headers: {
              ...init?.headers,
              ...headers,
            },
            ...(sseAgent && { agent: sseAgent }),
          }),
      },
      requestInit: {
        headers,
        ...(sseAgent && { agent: sseAgent }),
      },
    });
  }

  private constructHttpTransport(
    options: InternalStreamableHttpMcpOptions,