Method execute_tool

python/src/tools/registry.rs:251–307

Execute a tool by name with parameters

(
        &self,
        name: &str,
        params: &Bound<'_, PyDict>,
        py: Python<'_>,
    )

    /// Execute a tool by name with parameters
    pub fn execute_tool(
        &self,
        name: &str,
        params: &Bound<'_, PyDict>,
        py: Python<'_>,
    ) -> PyResult<ToolResult> {
        let start_time = Instant::now();

        // Get the tool function
        let function = {
            let tools = self.tools.read().map_err(|e| {
                PyErr::new::<pyo3::exceptions::PyRuntimeError, _>(format!(
                    "Failed to acquire tools lock: {}",
                    e
                ))
            })?;

            tools.get(name).map(|f| f.clone_ref(py)).ok_or_else(|| {
                PyErr::new::<pyo3::exceptions::PyKeyError, _>(format!("Tool '{}' not found", name))
            })?
        };

        // Convert parameters to string for logging
        let params_str = params.repr()?.to_string();

        // Execute the tool
        let result = match function.call(py, (), Some(params)) {
            Ok(result) => {
                let duration = start_time.elapsed().as_millis() as u64;
                let output = result.to_string();

                // Record execution in metadata
                self.record_tool_execution(name, duration)?;

                let tool_result = ToolResult::new(name.to_string(), params_str, output, duration);

                // Add to execution history
                self.add_to_history(tool_result.clone())?;

                tool_result
            }
            Err(e) => {
                let duration = start_time.elapsed().as_millis() as u64;
                let error_msg = format!("Tool execution failed: {}", e);

                let tool_result =
                    ToolResult::failure(name.to_string(), params_str, error_msg, duration);

                // Add to execution history even for failures
                self.add_to_history(tool_result.clone())?;

                tool_result
            }
        };

        Ok(result)
    }