Struct AcpSessionStore 

pub struct AcpSessionStore { /* private fields */ }

Deterministic ACP session state map used by protocol handlers.

Implementations

impl AcpSessionStore

pub fn new() -> Self

Create an empty store.

pub fn next_id(&mut self) -> String

Generate a deterministic opaque ACP session id.

pub fn create_session( &mut self, local_session_id: impl Into<String>, workspace_root: &Path, requested_cwd: Option<&Path>, ) -> Result<String, AcpSessionError>

Create a new ACP session and attach local session metadata placeholders.

Returns Err when the local session id already exists.

pub fn attach_existing_session( &mut self, acp_session_id: impl Into<String>, local_session_id: impl Into<String>, cwd: &Path, session_writer: Option<SessionWriter>, ) -> Result<String, AcpSessionError>

Attach an existing local session to a caller-supplied ACP session id.

Used by session/load and session/resume, where the client names a persisted session returned from session/list.

pub fn acp_session_id_for_local(&self, local_session_id: &str) -> Option<&str>

Return the opaque ACP session id for a local session id.

pub fn local_session_id(&self, acp_session_id: &str) -> Option<&str>

Return the local session id for an ACP session id.

pub fn session(&self, acp_session_id: &str) -> Option<&AcpServerSession>

Return a snapshot of one ACP session.

pub fn sessions(&self) -> Vec<&AcpServerSession>

Return snapshots of all active ACP sessions sorted by ACP id.

pub fn begin_turn( &mut self, acp_session_id: &str, ) -> Result<(), AcpSessionError>

Mark a turn as active for this ACP session.

This is a strict guard: only one active turn is allowed per session.

pub fn end_turn(&mut self, acp_session_id: &str) -> Result<(), AcpSessionError>

Mark a turn as complete for this ACP session.

pub fn update_session_metadata( &mut self, acp_session_id: &str, model: Option<String>, websearch: Option<WebSearchMode>, ) -> Result<(), AcpSessionError>

Update local metadata placeholders for a session.

pub fn update_session_reasoning( &mut self, acp_session_id: &str, effort: Option<ReasoningEffort>, summary: Option<ReasoningSummary>, ) -> Result<(), AcpSessionError>

Update reasoning controls without changing model or web-search metadata.

pub fn attach_session_writer( &mut self, acp_session_id: &str, session_writer: SessionWriter, ) -> Result<(), AcpSessionError>

Attach a local session writer for persistence.

pub fn attach_mcp_config( &mut self, acp_session_id: &str, mcp_config: McpConfig, ) -> Result<(), AcpSessionError>

Attach ACP-provided MCP server config to a session.

pub fn session_writer(&self, acp_session_id: &str) -> Option<&SessionWriter>

Return the active session writer when persistence is enabled.

pub fn session_writer_mut( &mut self, acp_session_id: &str, ) -> Option<&mut SessionWriter>

Return a mutable session writer when persistence is enabled.

pub fn remove_session(&mut self, acp_session_id: &str) -> Option<String>

Drop a stored session and return its local session id when present.

pub fn is_turn_active(&self, acp_session_id: &str) -> bool

Return true when the ACP session currently has an active turn.

pub fn clear_turns_for_test(&mut self)

Force clear all active turns in store state. Intended for tests only.

Trait Implementations

impl Debug for AcpSessionStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for AcpSessionStore

fn default() -> AcpSessionStore

Returns the “default value” for a type.