runtimeprotocol

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

type ClientMCPClosedParams struct {
	StreamID string `json:"stream_id"`
	Error    string `json:"error,omitempty"`
}

type ClientMCPConnectParams struct {
	StreamID string `json:"stream_id"`
	ServerID string `json:"server_id"`
}

type ClientMCPDisconnectParams struct {
	StreamID string `json:"stream_id"`
}

type ClientMCPMessageParams struct {
	StreamID string          `json:"stream_id"`
	Message  json.RawMessage `json:"message"`
}

type CompactContextResult struct {
	TurnID defs.TurnID `json:"turn_id"`
}

type ConversationParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
}

type ConversationResult struct {
	Conversation defs.Conversation `json:"conversation"`
}

type ConversationTitleUpdatedParams struct {
	NotificationTarget
	Title string `json:"title"`
}

type CreateConversationParams struct {
	AgentName string              `json:"agent_name"`
	Model     defs.ModelSelection `json:"model,omitzero"`
	// ExecutorSettings 里没有 local 目录时使用 local 的默认目录（server.workspace_directory，没配时是 serve 的工作目录）。
	ExecutorSettings defs.ExecutorSettings `json:"executor_settings"`
	// Environment 为空时本机命令继承 serve 进程的环境。
	Environment []string `json:"environment,omitempty"`
	// Ephemeral 是否建临时对话？临时对话不装配，没有 Executor 和 Skill，executor_settings 原样记下但不生效，environment 忽略。
	Ephemeral bool `json:"ephemeral,omitempty"`
}

type EmptyParams struct{}

type EmptyResult struct{}

type ForkConversationParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	// BeforeTurnID 复制到这一轮之前（不含），LastTurnID 复制到这一轮（含）；最多给一个，都不给时复制全部已结束的轮次。
	BeforeTurnID defs.TurnID `json:"before_turn_id,omitempty"`
	LastTurnID   defs.TurnID `json:"last_turn_id,omitempty"`
	// Model 省略时照抄来源根 Session 的模型。
	Model defs.ModelSelection `json:"model,omitzero"`
	// ExecutorSettings 是新对话的完整设置，和 Environment 一起按 conversation/create 的规则装配。
	ExecutorSettings defs.ExecutorSettings `json:"executor_settings"`
	Environment      []string              `json:"environment,omitempty"`
}

type GetSessionParams struct {
	SessionID defs.SessionID `json:"session_id"`
}

type GetTurnsParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	SessionID      defs.SessionID      `json:"session_id"`
	TurnIDs        []defs.TurnID       `json:"turn_ids"`
}

type GetTurnsResult struct {
	Turns []defs.Turn `json:"turns"`
}

type HookRunParams struct {
	NotificationTarget
	TurnID  defs.TurnID   `json:"turn_id"`
	HookRun *defs.HookRun `json:"hook_run"`
}

type InitializeParams struct {
	ClientInfo      ClientInfo `json:"client_info"`
	ProtocolVersion string     `json:"protocol_version"`
}

type InitializeResult struct {
	ServerInfo      ServerInfo `json:"server_info"`
	ProtocolVersion string     `json:"protocol_version"`
	// ServerID 标识这台机器上的 serve；客户端读到的本机 server_id 与它一致，就说明两边用的是同一个文件系统。
	ServerID string `json:"server_id"`
}

type InterruptTurnResult struct {
	TurnID defs.TurnID `json:"turn_id,omitempty"`
}

type InterruptTurnWithInputParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	ItemID         defs.ItemID         `json:"item_id"`
	TurnID         defs.TurnID         `json:"turn_id"`
}

type ItemEventParams struct {
	NotificationTarget
	TurnID       defs.TurnID              `json:"turn_id"`
	ItemIndex    int                      `json:"item_index"`
	Item         *defs.Item               `json:"item,omitempty"`
	Delta        *agent.AgentItemDelta    `json:"delta,omitempty"`
	ToolProgress *agent.AgentToolProgress `json:"tool_progress,omitempty"`
}

type ItemsSavedParams struct {
	NotificationTarget
	TurnID defs.TurnID  `json:"turn_id"`
	Items  []LoggedItem `json:"items"`
}

type JSONRPCError struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type JSONRPCMessage struct {
	ID     json.RawMessage `json:"id,omitempty"`
	Method string          `json:"method,omitempty"`
	Params any             `json:"params,omitempty"`
	Result any             `json:"result,omitempty"`
	Error  *JSONRPCError   `json:"error,omitempty"`
}

type JSONRPCRequest struct {
	ID     json.RawMessage `json:"id"`
	Method string          `json:"method"`
	Params json.RawMessage `json:"params"`
}

type ListAgentsResult struct {
	Agents []runtime.AgentInfo `json:"agents"`
}

type ListCatalogProvidersResult struct {
	Providers []defs.CatalogProvider `json:"providers"`
}

type ListConversationsParams struct {
	Directories []string                              `json:"directories,omitempty"`
	SearchTerm  string                                `json:"search_term,omitempty"`
	Order       storage.Order                         `json:"order,omitzero"`
	Cursor      dao.RecordCursor[defs.ConversationID] `json:"cursor,omitzero"`
	Limit       int                                   `json:"limit,omitempty"`
	Archived    bool                                  `json:"archived,omitempty"`
}

type ListConversationsResult struct {
	Conversations []dao.ConversationListEntry           `json:"conversations"`
	NextCursor    dao.RecordCursor[defs.ConversationID] `json:"next_cursor,omitzero"`
}

type ListDirectoriesParams struct {
	ExecutorID    string `json:"executor_id"`
	Directory     string `json:"directory"`
	BaseDirectory string `json:"base_directory,omitempty"`
}

type ListExecutorsResult struct {
	Executors []conversation.ExecutorDetails `json:"executors"`
}

type ListHooksResult struct {
	Hooks []*hook.HookInfo `json:"hooks"`
}

type ListItemsParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	SessionID      defs.SessionID      `json:"session_id"`
	Order          storage.Direction   `json:"order,omitempty"`
	Cursor         storage.Ordinal     `json:"cursor,omitempty"`
	Limit          int                 `json:"limit,omitempty"`
}

type ListItemsResult struct {
	Items      []LoggedItem    `json:"items"`
	NextCursor storage.Ordinal `json:"next_cursor,omitempty"`
}

type ListMCPServersResult struct {
	Servers []conversation.MCPServerInfo `json:"servers"`
}

type ListModelsParams struct {
	AgentName string `json:"agent_name"`
}

type ListProvidersResult struct {
	Providers    []defs.ProviderConfig `json:"providers"`
	DefaultModel string                `json:"default_model"`
	Defaults     defs.ModelDefaults    `json:"defaults"`
}

type ListSessionsParams struct {
	ConversationID defs.ConversationID              `json:"conversation_id"`
	Order          storage.Order                    `json:"order,omitzero"`
	Cursor         dao.RecordCursor[defs.SessionID] `json:"cursor,omitzero"`
	Limit          int                              `json:"limit,omitempty"`
}

type ListSessionsResult struct {
	Sessions   []defs.Session                   `json:"sessions"`
	NextCursor dao.RecordCursor[defs.SessionID] `json:"next_cursor,omitzero"`
}

type ListSkillsParams struct {
	ConversationID   defs.ConversationID   `json:"conversation_id,omitempty"`
	AgentName        string                `json:"agent_name,omitempty"`
	ExecutorSettings defs.ExecutorSettings `json:"executor_settings,omitzero"`
}

type ListTurnsParams struct {
	ConversationID defs.ConversationID           `json:"conversation_id"`
	SessionID      defs.SessionID                `json:"session_id"`
	Order          storage.Order                 `json:"order,omitzero"`
	Cursor         dao.RecordCursor[defs.TurnID] `json:"cursor,omitzero"`
	Limit          int                           `json:"limit,omitempty"`
}

type ListTurnsResult struct {
	Turns      []defs.Turn                   `json:"turns"`
	NextCursor dao.RecordCursor[defs.TurnID] `json:"next_cursor,omitzero"`
}

type LoggedItem struct {
	Ordinal storage.Ordinal `json:"ordinal"`
	Item    *defs.Item      `json:"item"`
}

type Method struct {
	Name   string
	Params reflect.Type
	Result reflect.Type
}

type Notification struct {
	Name   string
	Params reflect.Type
}

type NotificationTarget struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	SessionID      defs.SessionID      `json:"session_id"`
	// Subscription 是 SubscriptionKindSession 或 SubscriptionKindConversation；客户端据此把通知分别交给内容与状态显示。
	Subscription SubscriptionKind `json:"subscription"`
}

type OpenConversationParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	Environment    []string            `json:"environment,omitempty"`
}

type ProviderIDParams struct {
	ProviderID string `json:"provider_id"`
}

type ProviderModelsResult struct {
	Models map[string]*defs.ProviderModelConfig `json:"models"`
}

type ProviderParams struct {
	Provider defs.ProviderConfig `json:"provider"`
}

type ResolveDirectoryParams struct {
	ExecutorID    string `json:"executor_id"`
	Directory     string `json:"directory"`
	BaseDirectory string `json:"base_directory,omitempty"`
}

type ResolveDirectoryResult struct {
	WorkspaceDirectory string `json:"workspace_directory"`
}

type RunningConversationsClosedParams struct {
	Reason string `json:"reason"`
}

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

type SessionParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	SessionID      defs.SessionID      `json:"session_id"`
}

type SessionPendingInputsUpdatedParams struct {
	NotificationTarget
	PendingInputs session.SessionPendingInputs `json:"pending_inputs"`
}

type SessionResult struct {
	Session defs.Session `json:"session"`
}

type SessionStartedParams struct {
	NotificationTarget
	Session          defs.Session    `json:"session"`
	LastSavedOrdinal storage.Ordinal `json:"last_saved_ordinal"`
}

type SessionStatusUpdatedParams struct {
	NotificationTarget
	Info runtime.SessionRuntimeInfo `json:"info"`
}

type SessionStoppedParams struct {
	NotificationTarget
	Error string `json:"error,omitempty"`
}

type SetClientMCPServersParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	ServerIDs      []string            `json:"server_ids"`
}

type SetConversationArchivedParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	Archived       bool                `json:"archived"`
}

type SetConversationTitleParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	Title          string              `json:"title"`
}

type SetDefaultModelParams struct {
	Model string `json:"model"`
}

type SetExecutorSettingsParams struct {
	ConversationID   defs.ConversationID   `json:"conversation_id"`
	ExecutorSettings defs.ExecutorSettings `json:"executor_settings"`
}

type SetProviderParams struct {
	Provider     defs.ProviderConfig `json:"provider"`
	DefaultModel string              `json:"default_model,omitempty"`
}

type SetSessionModelParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	SessionID      defs.SessionID      `json:"session_id"`
	Model          defs.ModelSelection `json:"model"`
}

type SteerInputParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	ItemID         defs.ItemID         `json:"item_id"`
	TurnID         defs.TurnID         `json:"turn_id"`
}

type StreamingItem struct {
	ItemIndex int        `json:"item_index"`
	Item      *defs.Item `json:"item"`
}

type SubmitInputParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	InputID        defs.InputID        `json:"input_id,omitempty"`
	// Mode 省略时使用普通模式。
	Mode session.SessionInputMode `json:"mode,omitempty"`
	// Content 原样交给 Runtime；Session 拒绝空内容、空条目、未知类型和缺少载荷的内容，图片的 data URL 格式不检查。
	Content []*defs.Content `json:"content"`
}

type SubmitInputResult struct {
	ItemID defs.ItemID `json:"item_id"`
}

type SubscribeConversationResult struct {
	Title    string                       `json:"title"`
	Sessions []runtime.SessionRuntimeInfo `json:"sessions"`
}

type SubscribeSessionResult struct {
	// LastSavedOrdinal 及之前的日志用 session/items/list 补齐。
	LastSavedOrdinal storage.Ordinal `json:"last_saved_ordinal"`
	// StreamingItems 是正在生成的 Item，后续 item/delta 按 item_index 接上。
	StreamingItems []StreamingItem              `json:"streaming_items"`
	PendingInputs  session.SessionPendingInputs `json:"pending_inputs"`
}

type SubscriptionClosedParams struct {
	NotificationTarget
	Reason string `json:"reason"`
}

type SubscriptionKind string

type TerminalExitedParams struct {
	TerminalID string `json:"terminal_id"`
	ExitCode   int    `json:"exit_code"`
	// Error 是进程没能取得退出码的原因（如远端连接断开），正常结束或被关闭时省略。
	Error string `json:"error,omitempty"`
}

type TerminalInputParams struct {
	TerminalID string `json:"terminal_id"`
	Data       []byte `json:"data"`
}

type TerminalOpenParams struct {
	// ExecutorID 为空时用 local Executor；virtual Executor 不支持终端。
	ExecutorID string `json:"executor_id"`
	// Directory 为空时用该 Executor 的默认工作目录；相对路径接在默认工作目录后面，~ 按 Executor 所在机器的主目录展开。
	Directory string `json:"directory"`
	// Rows、Cols 是终端初始行列数，为零时按 24×80。
	Rows uint16 `json:"rows"`
	Cols uint16 `json:"cols"`
	// Environment 是客户端的环境变量（格式同 os.Environ），只给 local Executor 的 shell 用；为空时继承 serve 进程的环境。
	Environment []string `json:"environment,omitempty"`
}

type TerminalOpenResult struct {
	TerminalID string `json:"terminal_id"`
	ExecutorID string `json:"executor_id"`
	Directory  string `json:"directory"`
}

type TerminalOutputParams struct {
	TerminalID string `json:"terminal_id"`
	Data       []byte `json:"data"`
}

type TerminalParams struct {
	TerminalID string `json:"terminal_id"`
}

type TerminalResizeParams struct {
	TerminalID string `json:"terminal_id"`
	Rows       uint16 `json:"rows"`
	Cols       uint16 `json:"cols"`
}

type TurnFinishedParams struct {
	NotificationTarget
	TurnID           defs.TurnID      `json:"turn_id"`
	Status           defs.TurnStatus  `json:"status,omitempty"`
	InputItemIDs     []defs.ItemID    `json:"input_item_ids"`
	FinalModelCallID defs.ModelCallID `json:"final_model_call_id,omitempty"`
	Error            string           `json:"error,omitempty"`
}

type TurnStartedParams struct {
	NotificationTarget
	TurnID defs.TurnID `json:"turn_id"`
}

type WithdrawInputParams struct {
	ConversationID defs.ConversationID `json:"conversation_id"`
	ItemID         defs.ItemID         `json:"item_id"`
	ReturnContent  bool                `json:"return_content"`
}

type WithdrawInputResult struct {
	Content []*defs.Content `json:"content,omitempty"`
}