domain

type CallResult struct {
	Content string
	IsError bool
}

type Client interface {
	// Discover checks the server is up and speaks our protocol version. It is
	// the liveness probe.
	Discover(ctx context.Context) error

	// ListTools returns every tool the server advertises.
	ListTools(ctx context.Context) ([]Tool, error)

	// CallTool runs a tool under its bare, un-namespaced name.
	CallTool(ctx context.Context, name string, args map[string]any) (CallResult, error)
}

type ServerStatus struct {
	TotalServers     int `json:"total_servers"`
	ConnectedServers int `json:"connected_servers"`
	TotalTools       int `json:"total_tools"`
}

type ServerStatusUpdateEvent struct {
	ServerName       string
	Connected        bool
	TotalServers     int
	ConnectedServers int
	TotalTools       int
	Tools            map[string]agentdomain.Tool
}

type Supervisor interface {
	// GetTotalServers returns the number of configured MCP servers.
	GetTotalServers() int

	// StartMonitoring begins background liveness probes, pushing every
	// ServerStatusUpdateEvent through the UI notifier injected at
	// construction. Idempotent; the initial status is emitted asynchronously.
	StartMonitoring(ctx context.Context)

	// DiscoverTools probes every server once and returns the agent tools of
	// those that answered, keyed by their namespaced name.
	DiscoverTools(ctx context.Context) map[string]agentdomain.Tool

	// StartServers starts all MCP servers that have run=true (non-fatal).
	StartServers(ctx context.Context) error

	// StopServers stops all running MCP server containers.
	StopServers(ctx context.Context) error

	// Close stops monitoring, stops containers, and cleans up resources.
	Close() error
}

type Tool struct {
	Server      string
	Name        string
	Description string
	InputSchema map[string]any
}

type ToolResult struct {
	ServerName string `json:"server_name"`
	ToolName   string `json:"tool_name"`
	Content    string `json:"content"`
	Error      string `json:"error,omitempty"`
}