Function RegisterMCPTools

tools/mcp.go:204–254

(registry *ToolRegistry, cwd string, execCtx ExecutionContext)

			in.URI,
			in.ServerName,
			err,
		), nil
	}
	return output, nil
}

func RegisterMCPTools(registry *ToolRegistry, cwd string, execCtx ExecutionContext) error {
	if registry == nil {
		return nil
	}
	configs := trustedMCPConfigs(cwd, execCtx)
	if len(configs) == 0 {
		return nil
	}
	clients := map[string]*mcp.McpClient{}
	execCtx["mcp_clients"] = clients
	var clientOrder []string
	registeredCount := 0
	for _, cfg := range configs {
		client := mcp.NewMcpClient(cfg)
		if !client.Connect(context.Background()) {
			continue
		}
		discovered, err := client.DiscoverTools(context.Background())
		if err != nil {
			client.Disconnect(context.Background())
			continue
		}
		clients[cfg.Name] = client
		clientOrder = append(clientOrder, cfg.Name)
		for _, toolDef := range discovered {
			toolName := stringValueFromMap(toolDef, "name", "")
			if toolName == "" {
				continue
			}
			safeName := SanitizeMCPToolName(cfg.Name, toolName)
			schema, _ := toolDef["inputSchema"].(map[string]any)
			description := stringValueFromMap(toolDef, "description", "MCP tool: "+toolName)
			registry.Register(NewMCPDynamicTool(
				safeName,
				cfg.Name,
				toolName,
				fmt.Sprintf("[MCP Server: %s] %s", cfg.Name, description),
				schema,
				fmt.Sprintf("mcp %s %s %s", cfg.Name, toolName, description),
			))
			registeredCount++
		}
	}
	if len(clients) > 0 {
		execCtx["mcp_client_order"] = clientOrder
		registry.Register(NewListMCPResourcesTool())
		registry.Register(NewReadMCPResourceTool())
	}