Method Initialize

pkg/tools/mcp/remote.go:80–135

(ctx context.Context, _ *gomcp.InitializeRequest)

}

func (c *remoteMCPClient) Initialize(ctx context.Context, _ *gomcp.InitializeRequest) (*gomcp.InitializeResult, error) {
	// Create HTTP client with OAuth support. We keep a reference to the
	// oauthTransport so we can enrich Connect errors with the server's own
	// explanation — without this, a plain `Bad Request` bubbles up and the
	// user has no idea that, say, the Slack app hasn't been enabled for MCP.
	httpClient, oauthT, err := c.createHTTPClient()
	if err != nil {
		return nil, fmt.Errorf("creating HTTP client: %w", err)
	}

	var transport gomcp.Transport

	switch c.transportType {
	case "sse":
		transport = &gomcp.SSEClientTransport{
			Endpoint:   c.url,
			HTTPClient: httpClient,
		}
	case "streamable", "streamable-http":
		transport = &gomcp.StreamableClientTransport{
			Endpoint:             c.url,
			HTTPClient:           httpClient,
			DisableStandaloneSSE: true,
		}
	default:
		return nil, fmt.Errorf("unsupported transport type: %s", c.transportType)
	}

	// Create an MCP client with elicitation support
	impl := &gomcp.Implementation{
		Name:    "docker agent",
		Version: "1.0.0",
	}

	toolChanged, promptChanged := c.notificationHandlers()

	opts := &gomcp.ClientOptions{
		ElicitationHandler:       c.handleElicitationRequest,
		CreateMessageHandler:     c.handleSamplingRequest,
		ToolListChangedHandler:   toolChanged,
		PromptListChangedHandler: promptChanged,
	}

	client := gomcp.NewClient(impl, opts)

	// Connect to the MCP server
	session, err := client.Connect(ctx, transport, nil)
	if err != nil {
		return nil, enrichConnectError(err, oauthT)
	}

	c.setSession(session)

	slog.DebugContext(ctx, "Remote MCP client connected successfully")
	return session.InitializeResult(), nil
}

// enrichConnectError wraps the error returned by client.Connect with any