Struct ACPProtocol 

pub struct ACPProtocol { /* private fields */ }

ACP protocol handler for iFlow communication

Implements the Agent Client Protocol (ACP) which defines the interaction between GUI applications and AI agents.

Implementations

impl ACPProtocol

pub fn new( transport: WebSocketTransport, message_sender: UnboundedSender<Message>, timeout_secs: f64, ) -> Self

Initialize ACP protocol handler

Arguments

• transport - WebSocket transport for communication
• message_sender - Sender for messages to be processed by the client
• timeout_secs - Timeout in seconds for protocol operations

pub fn is_initialized(&self) -> bool

Check if the protocol has been initialized

Returns

True if initialized, False otherwise

pub fn is_authenticated(&self) -> bool

Check if the protocol has been authenticated

Returns

True if authenticated, False otherwise

pub fn set_permission_mode(&mut self, mode: PermissionMode)

Set the permission mode for tool calls

Arguments

• mode - The permission mode to use

pub async fn initialize(&mut self, options: &IFlowOptions) -> Result<()>

Initialize the protocol connection

Performs the ACP initialization handshake:

1. Wait for //ready signal
2. Send initialize request with optional configs
3. Process initialize response

Arguments

• options - Configuration options

Returns

• Ok(()) if initialization was successful
• Err(IFlowError) if initialization failed

pub async fn authenticate( &mut self, method_id: &str, method_info: Option<HashMap<String, String>>, ) -> Result<()>

Perform authentication if required

This method should be called if initialize() indicates that authentication is needed (isAuthenticated = False).

Arguments

• method_id - Authentication method ID
• method_info - Optional authentication info

Returns

• Ok(()) if authentication was successful
• Err(IFlowError) if authentication failed

pub async fn create_session( &mut self, cwd: &str, mcp_servers: Vec<Value>, ) -> Result<String>

Create a new session

Arguments

• cwd - Working directory for the session
• mcp_servers - MCP servers to connect to

Returns

• Ok(String) containing the session ID
• Err(IFlowError) if session creation failed

pub async fn send_prompt( &mut self, session_id: &str, prompt: &str, ) -> Result<u32>

Send a prompt to the session and wait for response

Arguments

• session_id - The session ID from create_session()
• prompt - The prompt text to send

Returns

• Ok(u32) containing the request ID for tracking the message
• Err(IFlowError) if sending failed

pub async fn close(&mut self) -> Result<()>

Close the protocol connection

pub fn is_connected(&self) -> bool

Check if the protocol is connected

Returns

True if connected, False otherwise