Struct UserInteractionRegistry 

pub struct UserInteractionRegistry { /* private fields */ }

Registry for managing pending user interactions.

This registry tracks tools that are blocked waiting for user input and provides methods for the UI to query and respond to these interactions.

Implementations

impl UserInteractionRegistry

pub fn new(event_tx: Sender<ControllerEvent>) -> Self

Create a new UserInteractionRegistry.

Arguments

• event_tx - Channel to send events when interactions are registered.

pub async fn register( &self, tool_use_id: String, session_id: i64, request: AskUserQuestionsRequest, turn_id: Option<TurnId>, ) -> Result<Receiver<AskUserQuestionsResponse>, UserInteractionError>

Register a pending interaction and get a receiver to await on.

This is called by the AskUserQuestionsTool when it starts executing. The tool will await on the returned receiver until the UI responds.

Arguments

• tool_use_id - Unique ID for this tool use request.
• session_id - Session that requested the interaction.
• request - The questions to ask the user.
• turn_id - Optional turn ID for this interaction.

Returns

A oneshot receiver that will receive the user’s response.

pub async fn respond( &self, tool_use_id: &str, response: AskUserQuestionsResponse, ) -> Result<(), UserInteractionError>

Respond to a pending interaction.

This is called by the UI when the user has answered the questions.

Arguments

• tool_use_id - ID of the tool use to respond to.
• response - The user’s answers.

Returns

Ok(()) if the response was sent successfully, or an error.

pub async fn cancel( &self, tool_use_id: &str, ) -> Result<(), UserInteractionError>

Cancel a pending interaction (user declined to answer).

This is called by the UI when the user presses Escape to close the question panel without answering.

Arguments

• tool_use_id - ID of the tool use to cancel.

Returns

Ok(()) if the interaction was found and cancelled, or NotFound error.

pub async fn pending_for_session( &self, session_id: i64, ) -> Vec<PendingQuestionInfo>

Get all pending interactions for a session.

This is called by the UI when switching sessions to display any pending questions for that session.

Arguments

• session_id - Session ID to query.

Returns

List of pending question information for the session.

pub async fn cancel_session(&self, session_id: i64)

Cancel all pending interactions for a session.

This is called when a session is destroyed. It drops the senders, which will cause the awaiting tools to receive a RecvError.

Arguments

• session_id - Session ID to cancel.

pub async fn has_pending(&self, session_id: i64) -> bool

Check if there are any pending interactions for a session.

Arguments

• session_id - Session ID to check.

Returns

True if there are pending interactions.

pub async fn pending_count(&self) -> usize

Get the count of pending interactions.