Struct ConfirmationManager 

pub struct ConfirmationManager { /* private fields */ }

Manages confirmation requests for a session

Implementations

impl ConfirmationManager

pub fn new(policy: ConfirmationPolicy, event_tx: Sender<AgentEvent>) -> Self

Create a new confirmation manager

pub async fn policy(&self) -> ConfirmationPolicy

Get the current policy

pub async fn set_policy(&self, policy: ConfirmationPolicy)

Update the confirmation policy

pub async fn requires_confirmation(&self, tool_name: &str) -> bool

Check if a tool requires confirmation

pub async fn request_confirmation( &self, tool_id: &str, tool_name: &str, args: &Value, ) -> Receiver<ConfirmationResponse>

Request confirmation for a tool execution

Returns a receiver that will receive the confirmation response. Emits a ConfirmationRequired event.

pub async fn confirm( &self, tool_id: &str, approved: bool, reason: Option<String>, ) -> Result<bool, String>

Handle a confirmation response from the user

Returns Ok(true) if the confirmation was found and processed, Ok(false) if no pending confirmation was found.

pub async fn check_timeouts(&self) -> usize

Check for and handle timed out confirmations

Returns the number of confirmations that timed out.

pub async fn pending_count(&self) -> usize

Get the number of pending confirmations

pub async fn pending_confirmations(&self) -> Vec<(String, String, u64)>

Get pending confirmation details (for debugging/status)

pub async fn cancel(&self, tool_id: &str) -> bool

Cancel a pending confirmation

pub async fn cancel_all(&self) -> usize

Cancel all pending confirmations

Trait Implementations

impl ConfirmationProvider for ConfirmationManager

fn requires_confirmation<'life0, 'life1, 'async_trait>( &'life0 self, tool_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

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

Check if a tool requires confirmation

fn request_confirmation<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tool_id: &'life1 str, tool_name: &'life2 str, args: &'life3 Value, ) -> Pin<Box<dyn Future<Output = Receiver<ConfirmationResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Request confirmation for a tool execution

fn confirm<'life0, 'life1, 'async_trait>( &'life0 self, tool_id: &'life1 str, approved: bool, reason: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<bool, String>> + Send + 'async_trait>>

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

Handle a confirmation response from the user

fn policy<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ConfirmationPolicy> + Send + 'async_trait>>

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

Get the current policy

fn set_policy<'life0, 'async_trait>( &'life0 self, policy: ConfirmationPolicy, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Update the confirmation policy

fn check_timeouts<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

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

Check for and handle timed out confirmations

fn cancel_all<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

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

Cancel all pending confirmations