mcp

type CallToolResult struct {
	Content []ContentItem `json:"content"`
	IsError bool          `json:"isError"`
}

type ClientInfo struct {
	Name    string `json:"name"`
	Version string `json:"version"`
}

type ContentItem struct {
	Type string `json:"type"`
	Text string `json:"text,omitempty"`
}

type Dispatcher struct {
	// contains filtered or unexported fields
}

type DispatcherConfig struct {
	Provider        MCPProvider
	Sessions        *SessionStore
	Server          ServerConfig
	ProtocolVersion string
	RequireSession  bool
}

type HTTPConfig struct {
	// Path is the MCP endpoint path (default "/mcp").
	Path string
	// Metric is the base controller metric name (suffix " - mcp" is applied automatically).
	Metric string
	// Provider handles tools/list and tools/call.
	Provider MCPProvider
	// AuthFunc authenticates MCP requests when IsSecured is true.
	AuthFunc func(ctx *server.Context) error
	// IsSecured enables AuthFunc on the MCP endpoint.
	IsSecured bool
	// Server identifies this MCP server in initialize responses.
	Server ServerConfig
	// ProtocolVersion is the default MCP protocol version (default "2025-06-18").
	ProtocolVersion string
	// RequireSession requires a valid Mcp-Session-Id header for tools/list and tools/call.
	RequireSession bool
	// EnforceProtocolHeader rejects requests when MCP-Protocol-Version header is missing
	// or does not match ProtocolVersion.
	EnforceProtocolHeader bool
}

type HTTPProvider struct {
	// contains filtered or unexported fields
}

type InitializeParams struct {
	ProtocolVersion string                 `json:"protocolVersion"`
	Capabilities    map[string]interface{} `json:"capabilities"`
	ClientInfo      *ClientInfo            `json:"clientInfo"`
}

type InitializeResult struct {
	ProtocolVersion string                 `json:"protocolVersion"`
	Capabilities    map[string]interface{} `json:"capabilities"`
	ServerInfo      ServerInfo             `json:"serverInfo"`
}

type JSONRPCRequest struct {
	JSONRPC string                 `json:"jsonrpc"`
	ID      interface{}            `json:"id"`
	Method  string                 `json:"method"`
	Params  map[string]interface{} `json:"params,omitempty"`
	// contains filtered or unexported fields
}

type ListToolsResult struct {
	Tools      []Tool `json:"tools"`
	NextCursor string `json:"nextCursor,omitempty"`
}

type MCPProvider interface {
	ListTools(ctx *server.Context, cursor string) ([]Tool, string)
	CallTool(ctx *server.Context, name string, arguments map[string]interface{}) (CallToolResult, error)
}

type ProviderFunc struct {
	ListToolsFunc func(ctx *server.Context, cursor string) ([]Tool, string)
	CallToolFunc  func(ctx *server.Context, name string, arguments map[string]interface{}) (CallToolResult, error)
}

type ServerConfig struct {
	Name    string
	Version string
}

type ServerInfo struct {
	Name    string `json:"name"`
	Version string `json:"version"`
}

type Session struct {
	ID              string
	ProtocolVersion string
	ClientInfo      *ClientInfo
	CreatedAt       time.Time
}

type SessionStore struct {
	// contains filtered or unexported fields
}

type Tool struct {
	Name        string      `json:"name"`
	Description string      `json:"description"`
	InputSchema interface{} `json:"inputSchema"`
}

type ToolsCallParams struct {
	Name      string                 `json:"name"`
	Arguments map[string]interface{} `json:"arguments"`
}