Function createTransport

coderd/x/chatd/mcpclient/mcpclient.go:284–318

createTransport builds the appropriate mcp-go transport based on the server's configured transport type.

(
	cfg database.MCPServerConfig,
	headers map[string]string,
)

// createTransport builds the appropriate mcp-go transport based
// on the server's configured transport type.
func createTransport(
	cfg database.MCPServerConfig,
	headers map[string]string,
) (transport.Interface, error) {
	// Each connection gets its own HTTP client with a dedicated
	// transport so that httptest.Server.Close() (which calls
	// CloseIdleConnections on http.DefaultTransport) does not
	// disrupt unrelated connections during parallel tests.
	var httpClient *http.Client
	if dt, ok := http.DefaultTransport.(*http.Transport); ok {
		httpClient = &http.Client{Transport: dt.Clone()}
	} else {
		httpClient = &http.Client{}
	}

	switch cfg.Transport {
	case "sse":
		return transport.NewSSE(
			cfg.Url,
			transport.WithHeaders(headers),
			transport.WithHTTPClient(httpClient),
		)
	case "", "streamable_http":
		// Default to streamable HTTP, the newer transport.
		return transport.NewStreamableHTTP(
			cfg.Url,
			transport.WithHTTPHeaders(headers),
			transport.WithHTTPBasicClient(httpClient),
		)
	default:
		return nil, xerrors.Errorf(
			"unsupported transport %q", cfg.Transport,
		)
	}
}

// buildAuthHeaders constructs HTTP headers for authenticating
// with the MCP server based on the configured auth type.