Struct Computer 

pub struct Computer<S: Session> { /* private fields */ }

Computer核心结构体 / Core Computer struct

Implementations

impl<S: Session> Computer<S>

pub fn new( name: impl Into<String>, session: S, inputs: Option<HashMap<String, MCPServerInput>>, mcp_servers: Option<HashMap<String, MCPServerConfig>>, auto_connect: bool, auto_reconnect: bool, ) -> Self

创建新的Computer实例 / Create new Computer instance

pub fn with_confirm_callback<F>(self, callback: F) -> Self

where F: Fn(&str, &str, &str, &Value) -> bool + Send + Sync + 'static,

设置确认回调函数 / Set confirmation callback function

pub fn name(&self) -> &str

获取计算机名称 / Get computer name

pub fn get_socketio_client( &self, ) -> Arc<RwLock<Option<Arc<SmcpComputerClient>>>>

获取 Socket.IO 客户端引用 / Get Socket.IO client reference 返回 Arc 包装的客户端，确保其生命周期 Returns Arc-wrapped client, ensuring its lifetime

pub async fn boot_up(&self) -> ComputerResult<()>

启动Computer / Boot up the computer

pub async fn add_or_update_server( &self, server: MCPServerConfig, ) -> ComputerResult<()>

动态添加或更新服务器配置 / Add or update server configuration dynamically

pub async fn remove_server(&self, server_name: &str) -> ComputerResult<()>

移除服务器配置 / Remove server configuration

pub async fn update_inputs( &self, inputs: HashMap<String, MCPServerInput>, ) -> ComputerResult<()>

更新inputs定义 / Update inputs definition

pub async fn add_or_update_input( &self, input: MCPServerInput, ) -> ComputerResult<()>

添加或更新单个input / Add or update single input

pub async fn remove_input(&self, input_id: &str) -> ComputerResult<bool>

移除input / Remove input

pub async fn get_input( &self, input_id: &str, ) -> ComputerResult<Option<MCPServerInput>>

获取input定义 / Get input definition

pub async fn list_inputs(&self) -> ComputerResult<Vec<MCPServerInput>>

列出所有inputs / List all inputs

pub async fn get_input_value( &self, input_id: &str, ) -> ComputerResult<Option<Value>>

获取输入值 / Get input value

pub async fn set_input_value( &self, input_id: &str, value: Value, ) -> ComputerResult<bool>

设置输入值 / Set input value

pub async fn remove_input_value(&self, input_id: &str) -> ComputerResult<bool>

移除输入值 / Remove input value

pub async fn list_input_values(&self) -> ComputerResult<HashMap<String, Value>>

列出所有输入值 / List all input values

pub async fn clear_input_values( &self, input_id: Option<&str>, ) -> ComputerResult<()>

清空输入值缓存 / Clear input value cache

pub async fn get_available_tools(&self) -> ComputerResult<Vec<Tool>>

获取可用工具列表 / Get available tools list

pub async fn execute_tool( &self, req_id: &str, tool_name: &str, parameters: Value, timeout: Option<f64>, ) -> ComputerResult<CallToolResult>

执行工具调用 / Execute tool call

pub async fn get_tool_history(&self) -> ComputerResult<Vec<ToolCallRecord>>

获取工具调用历史 / Get tool call history

pub async fn get_server_status(&self) -> Vec<(String, bool, String)>

获取服务器状态列表 / Get server status list

pub async fn list_mcp_servers(&self) -> Vec<MCPServerConfig>

列出 MCP 服务器配置 / List MCP server configurations

pub async fn start_mcp_client(&self, server_name: &str) -> ComputerResult<()>

启动 MCP 客户端 / Start MCP client

pub async fn stop_mcp_client(&self, server_name: &str) -> ComputerResult<()>

停止 MCP 客户端 / Stop MCP client

pub async fn is_mcp_manager_initialized(&self) -> bool

检查 MCP Manager 是否已初始化 / Check if MCP Manager is initialized

pub async fn set_socketio_client(&self, client: Arc<SmcpComputerClient>)

设置Socket.IO客户端 / Set Socket.IO client 此方法会替换现有的 client（如果有）并保持强引用 This method replaces existing client (if any) and keeps strong reference

pub async fn connect_socketio( &self, url: &str, _namespace: &str, auth: &Option<String>, _headers: &Option<String>, ) -> ComputerResult<()>

连接Socket.IO服务器 / Connect to Socket.IO server

pub async fn disconnect_socketio(&self) -> ComputerResult<()>

断开Socket.IO连接 / Disconnect Socket.IO

pub async fn join_office( &self, office_id: &str, _computer_name: &str, ) -> ComputerResult<()>

加入办公室 / Join office

pub async fn leave_office(&self) -> ComputerResult<()>

离开办公室 / Leave office

pub async fn emit_update_config(&self) -> ComputerResult<()>

发送配置更新通知 / Emit config update notification

pub async fn shutdown(&self) -> ComputerResult<()>

关闭Computer / Shutdown computer

Trait Implementations

impl<S: Session + Clone> Clone for Computer<S>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S: Session> ManagerChangeHandler for Computer<S>

fn on_change<'life0, 'async_trait>( &'life0 self, message: ManagerChangeMessage, ) -> Pin<Box<dyn Future<Output = ComputerResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

处理管理器变更 / Handle manager change