Function execute_tool

src/apps/desktop/src/api/tool_api.rs:334–414

(request: ToolExecutionRequest)

#[tauri::command]
pub async fn execute_tool(request: ToolExecutionRequest) -> Result<ToolExecutionResponse, String> {
    let start_time = std::time::Instant::now();

    let tools = get_all_tools().await;

    for tool in tools {
        if tool.name() == request.tool_name {
            ensure_workspace_requirement(
                &request.tool_name,
                &request.input,
                request.workspace_path.as_deref(),
            )?;

            let context = build_tool_context(request.workspace_path.as_deref()).await;

            let validation_result = tool.validate_input(&request.input, Some(&context)).await;
            if !validation_result.result {
                return Ok(ToolExecutionResponse {
                    tool_name: request.tool_name,
                    success: false,
                    result: None,
                    error: None,
                    validation_error: validation_result.message,
                    duration_ms: elapsed_ms_u64(start_time),
                });
            }

            match tool.call(&request.input, &context).await {
                Ok(results) => {
                    let combined_result = if results.len() == 1 {
                        match &results[0] {
                            bitfun_core::agentic::tools::framework::ToolResult::Result {
                                data,
                                ..
                            } => Some(data.clone()),
                            bitfun_core::agentic::tools::framework::ToolResult::Progress {
                                content,
                                ..
                            } => Some(content.clone()),
                            bitfun_core::agentic::tools::framework::ToolResult::StreamChunk {
                                data,
                                ..
                            } => Some(data.clone()),
                        }
                    } else {
                        Some(serde_json::json!({
                                        "results": results.iter().map(|r| match r {
                        bitfun_core::agentic::tools::framework::ToolResult::Result { data, .. } => {
                            data.clone()
                        }
                        bitfun_core::agentic::tools::framework::ToolResult::Progress { content, .. } => content.clone(),
                        bitfun_core::agentic::tools::framework::ToolResult::StreamChunk { data, .. } => data.clone(),
                                        }).collect::<Vec<_>>()
                                    }))
                    };

                    return Ok(ToolExecutionResponse {
                        tool_name: request.tool_name,