Function send_mcp_app_message

src/apps/desktop/src/api/mcp_api.rs:725–797

(
    state: State<'_, AppState>,
    request: SendMCPAppMessageRequest,
)

#[tauri::command]
pub async fn send_mcp_app_message(
    state: State<'_, AppState>,
    request: SendMCPAppMessageRequest,
) -> Result<SendMCPAppMessageResponse, String> {
    let mcp_service = state
        .mcp_service
        .as_ref()
        .ok_or_else(|| "MCP service not initialized".to_string())?;

    let connection = mcp_service
        .server_manager()
        .get_connection(&request.server_id)
        .await
        .ok_or_else(|| format!("MCP server not connected: {}", request.server_id))?;

    let msg = &request.message;
    let method = msg
        .get("method")
        .and_then(|m| m.as_str())
        .ok_or_else(|| "Missing method".to_string())?;
    let id = msg.get("id").cloned();
    let params = msg
        .get("params")
        .cloned()
        .unwrap_or(serde_json::Value::Null);

    let result_value: serde_json::Value = match method {
        "tools/call" => {
            let name = params
                .get("name")
                .and_then(|n| n.as_str())
                .ok_or_else(|| "tools/call: missing name".to_string())?;
            let arguments = params.get("arguments").cloned();
            let result = connection
                .call_tool(name, arguments)
                .await
                .map_err(|e| e.to_string())?;
            serde_json::to_value(result).map_err(|e| e.to_string())?
        }
        "resources/read" => {
            let uri = params
                .get("uri")
                .and_then(|u| u.as_str())
                .ok_or_else(|| "resources/read: missing uri".to_string())?;
            let result = connection
                .read_resource(uri)
                .await
                .map_err(|e| e.to_string())?;
            serde_json::to_value(result).map_err(|e| e.to_string())?
        }
        "ping" => {
            connection.ping().await.map_err(|e| e.to_string())?;
            serde_json::json!({})
        }
        _ => {
            let code = -32601;
            let error_msg = format!("Method not found: {}", method);
            let response = serde_json::json!({