Struct AcpSessionStore 

pub struct AcpSessionStore { /* private fields */ }

Implementations

impl AcpSessionStore

pub fn new(db: Database) -> AcpSessionStore

pub async fn get( &self, session_id: &str, ) -> Result<Option<AcpSessionRow>, ServerError>

Load a session by ID.

pub async fn get_history( &self, session_id: &str, ) -> Result<Vec<Value>, ServerError>

Load session history from the database.

pub async fn list( &self, workspace_id: Option<&str>, limit: Option<usize>, ) -> Result<Vec<AcpSessionRow>, ServerError>

List sessions, optionally filtered by workspace.

pub async fn append_history( &self, session_id: &str, notification: Value, ) -> Result<(), ServerError>

Append a notification to session history.

pub async fn create( &self, params: CreateAcpSessionParams<'_>, ) -> Result<(), ServerError>

Persist a newly created session to the database.

Called immediately after AcpManager::create_session so the session survives server restarts and is visible in the session list.

pub async fn rename( &self, session_id: &str, name: &str, ) -> Result<(), ServerError>

Rename a session in the database.

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

Persist or update the ROUTA agent mapping for a session.

pub async fn set_provider_session_id( &self, session_id: &str, provider_session_id: Option<&str>, ) -> Result<(), ServerError>

Persist or update the provider-native session id for a session.

pub async fn delete(&self, session_id: &str) -> Result<(), ServerError>

Delete a session (and its history) from the database.

pub async fn set_first_prompt_sent( &self, session_id: &str, ) -> Result<(), ServerError>

Mark a session’s first_prompt_sent flag as true.

Called after the user sends the first real prompt so the session is no longer treated as “empty” in context views.

pub async fn save_history( &self, session_id: &str, history: &[Value], ) -> Result<(), ServerError>

Overwrite the full message history for a session.

Called after a prompt turn completes to flush the in-memory history accumulated by AcpManager::push_to_history into the database.