Struct RepositorySessionManager 

pub struct RepositorySessionManager { /* private fields */ }

Session manager that uses a repository for persistence.

This is the primary session manager for production use, providing agent initialization, message appending, and state synchronization.

Implementations

impl RepositorySessionManager

pub async fn new( session_id: impl Into<String>, session_repository: Arc<dyn SessionRepository>, ) -> Result<Self>

Create a new RepositorySessionManager.

If no session with the specified session_id exists, it will be created.

pub fn session_id(&self) -> &str

Get the session ID.

pub fn session(&self) -> &Session

Get the session.

pub async fn append_message( &self, message: Message, agent_id: &str, ) -> Result<()>

Append a message to the agent’s session.

pub async fn redact_latest_message( &self, redact_message: Message, agent_id: &str, ) -> Result<()>

Redact the latest message appended to the session.

pub async fn sync_agent(&self, agent: &SessionAgent) -> Result<()>

Sync an agent’s state to the session repository.

pub async fn initialize_agent( &self, agent_id: &str, ) -> Result<Option<SessionAgent>>

Initialize an agent with a session.

If the agent already exists in the session, its state will be restored. Otherwise, a new agent entry will be created.

pub async fn restore_messages( &self, agent_id: &str, offset: usize, ) -> Result<Vec<Message>>

Restore messages for an agent.

pub async fn sync_multi_agent( &self, multi_agent_id: &str, state: &Value, ) -> Result<()>

Sync multi-agent state to the session repository.

pub async fn initialize_multi_agent( &self, multi_agent_id: &str, ) -> Result<Option<Value>>

Initialize multi-agent state from the session repository.

pub fn fix_broken_tool_use(&self, messages: Vec<Message>) -> Vec<Message>

Fix broken tool use/result pairs in message history.