Struct ToolExecutor 

pub struct ToolExecutor { /* private fields */ }

Manages tool execution with support for parallel batch execution.

Implementations

impl ToolExecutor

pub fn new( registry: Arc<ToolRegistry>, permission_registry: Arc<PermissionRegistry>, tool_result_tx: Sender<ToolResult>, batch_result_tx: Sender<ToolBatchResult>, ) -> Self

Create a new tool executor.

Arguments

• registry - Tool registry for looking up tools
• permission_registry - Permission registry for batch permission requests
• tool_result_tx - Channel for individual tool results (UI feedback)
• batch_result_tx - Channel for batch results (sending to LLM)

pub async fn execute_batch( &self, session_id: i64, turn_id: Option<TurnId>, requests: Vec<ToolRequest>, cancel_token: CancellationToken, ) -> i64

Execute a batch of tools in parallel.

This method implements batch permission handling:

1. Collects required permissions from all tools via required_permissions()
2. Requests batch approval from the permission registry (single UI prompt)
3. If approved: executes all tools with permissions_pre_approved: true
4. If denied: returns error results for all tools

Tools that handle their own permissions (handles_own_permissions() -> true) are always executed regardless of batch permission status.

Results are emitted individually to tool_result_tx for UI feedback, and the complete batch is sent to batch_result_tx when all tools finish.

Returns the batch ID.

pub async fn execute( &self, session_id: i64, turn_id: Option<TurnId>, request: ToolRequest, cancel_token: CancellationToken, ) -> i64

Execute a single tool (convenience method that creates a batch of 1).