Struct AcpManager 

pub struct AcpManager { /* private fields */ }

Manages ACP agent sessions and process lifecycle.

Each session maps to a long-lived child process that communicates via stdio JSON-RPC. Notifications are forwarded to subscribers via broadcast.

Implementations

impl AcpManager

pub fn rewrite_notification_session_id( session_id: &str, notification: Value, ) -> Value

pub fn new() -> AcpManager

pub async fn list_sessions(&self) -> Vec<AcpSessionRecord>

List all session records.

pub async fn get_session(&self, session_id: &str) -> Option<AcpSessionRecord>

Get a session record by ID.

pub async fn rename_session(&self, session_id: &str, name: &str) -> Option<()>

Rename a session. Returns Some(()) if the session was found and renamed, None if not found.

pub async fn set_routa_agent_id( &self, session_id: &str, routa_agent_id: &str, ) -> Option<()>

Attach a ROUTA agent ID to an existing session record. Returns Some(()) if the session was found, None if not found.

pub async fn delete_session(&self, session_id: &str) -> Option<()>

Delete a session. Returns Some(()) if the session was found and deleted, None if not found.

pub async fn get_session_history(&self, session_id: &str) -> Option<Vec<Value>>

Get session message history. Returns Some(history) if the session exists, None if not found.

pub async fn push_to_history(&self, session_id: &str, notification: Value)

Add a notification to session history. Child agent notifications (those with childAgentId) are NOT stored in the parent session’s history — they would flood out the ROUTA coordinator’s own messages. Child messages are persisted in their own child session’s history.

pub async fn emit_session_update( &self, session_id: &str, update: Value, ) -> Result<(), String>

Broadcast a synthetic session/update event and persist it into in-memory history.

pub async fn mark_first_prompt_sent(&self, session_id: &str)

Mark a session as having had its first prompt dispatched.

pub async fn create_session( &self, session_id: String, cwd: String, workspace_id: String, provider: Option<String>, role: Option<String>, model: Option<String>, parent_session_id: Option<String>, tool_mode: Option<String>, mcp_profile: Option<String>, ) -> Result<(String, String), String>

Create a new ACP session: spawn agent process, initialize, create session. Supports both static presets and registry-based agents. Claude uses stream-json protocol instead of ACP.

Returns (our_session_id, agent_session_id).

pub async fn load_session_with_options( &self, session_id: String, cwd: String, workspace_id: String, provider: Option<String>, role: Option<String>, model: Option<String>, parent_session_id: Option<String>, tool_mode: Option<String>, mcp_profile: Option<String>, provider_session_id: Option<String>, options: SessionLaunchOptions, ) -> Result<(String, String), String>

Resume a persisted ACP session using the provider’s native session/load path.

Returns (our_session_id, agent_session_id).

pub async fn load_session( &self, session_id: String, cwd: String, workspace_id: String, provider: Option<String>, role: Option<String>, model: Option<String>, parent_session_id: Option<String>, tool_mode: Option<String>, mcp_profile: Option<String>, provider_session_id: Option<String>, ) -> Result<(String, String), String>

pub async fn create_session_from_inline( &self, session_id: String, cwd: String, workspace_id: String, provider_name: String, role: Option<String>, model: Option<String>, parent_session_id: Option<String>, command: String, args: Vec<String>, options: SessionLaunchOptions, ) -> Result<(String, String), String>

pub async fn load_session_from_inline( &self, session_id: String, cwd: String, workspace_id: String, provider_name: String, role: Option<String>, model: Option<String>, parent_session_id: Option<String>, command: String, args: Vec<String>, provider_session_id: Option<String>, options: SessionLaunchOptions, ) -> Result<(String, String), String>

pub async fn create_session_with_options( &self, session_id: String, cwd: String, workspace_id: String, provider: Option<String>, role: Option<String>, model: Option<String>, parent_session_id: Option<String>, tool_mode: Option<String>, mcp_profile: Option<String>, options: SessionLaunchOptions, ) -> Result<(String, String), String>

pub async fn prompt( &self, session_id: &str, text: &str, ) -> Result<Value, String>

Send a prompt to an existing session’s agent process.

pub async fn cancel(&self, session_id: &str)

Cancel the current prompt in a session.

pub async fn kill_session(&self, session_id: &str)

Kill a session’s agent process and remove it.

pub async fn subscribe(&self, session_id: &str) -> Option<Receiver<Value>>

Subscribe to SSE notifications for a session. Returns a broadcast receiver that yields session/update JSON-RPC messages.

pub async fn is_alive(&self, session_id: &str) -> bool

Check if a session’s agent process is alive.

pub async fn get_acp_session_id(&self, session_id: &str) -> Option<String>

Get the managed ACP session id for a live session.

pub async fn get_preset_id(&self, session_id: &str) -> Option<String>

Get the preset ID for a session.

pub async fn is_claude_session(&self, session_id: &str) -> bool

Check if a session uses Claude (stream-json protocol, not ACP).

pub async fn prompt_claude_async( &self, session_id: &str, text: &str, ) -> Result<(), String>

Send a prompt to Claude session and return immediately. The actual response is streamed via the broadcast channel. Use subscribe() to receive notifications.

Trait Implementations

impl Clone for AcpManager

fn clone(&self) -> AcpManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for AcpManager

fn default() -> AcpManager

Returns the “default value” for a type.