Struct SeaOrmSessionStore 

pub struct SeaOrmSessionStore { /* private fields */ }

SeaORM-backed session store using the session_qa_entries table.

Works with any SeaORM-supported database (SQLite, PostgreSQL, MySQL). Runs its own schema migration on creation so the table is only created when this backend is actually used (not as part of the generic database init).

Implementations

impl SeaOrmSessionStore

pub async fn new( db: Arc<DatabaseConnection>, ) -> Result<SeaOrmSessionStore, SessionError>

Create a new store and run the session schema migration.

Trait Implementations

impl SessionStore for SeaOrmSessionStore

fn create_qa_entry<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, session_id: &'life1 str, user_id: Option<&'life2 str>, question: &'life3 str, answer: &'life4 str, context: Option<&'life5 str>, ) -> Pin<Box<dyn Future<Output = Result<String, SessionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, SeaOrmSessionStore: 'async_trait,

Store a Q&A entry in the session. Returns the generated qa_id.

fn get_latest_qa_entries<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, user_id: Option<&'life2 str>, last_n: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<SessionQAEntry>, SessionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, SeaOrmSessionStore: 'async_trait,

Retrieve the most recent last_n Q&A entries for a session, ordered oldest-first.

fn get_all_qa_entries<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, user_id: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<Vec<SessionQAEntry>, SessionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, SeaOrmSessionStore: 'async_trait,

Retrieve all Q&A entries for a session, ordered oldest-first.

fn delete_session<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, user_id: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<bool, SessionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, SeaOrmSessionStore: 'async_trait,

Delete all entries for a session. Returns true if the session existed.

fn delete_qa_entry<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session_id: &'life1 str, user_id: Option<&'life2 str>, qa_id: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<bool, SessionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, SeaOrmSessionStore: 'async_trait,

Delete a single Q&A entry by id. Returns true if found and deleted.

fn prune<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, SeaOrmSessionStore: 'async_trait,

Delete ALL session data across all users and sessions. Equivalent to Python’s CacheDBInterface.prune().

fn update_qa_entry<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session_id: &'life1 str, user_id: Option<&'life2 str>, qa_id: &'life3 str, updates: SessionQAUpdate, ) -> Pin<Box<dyn Future<Output = Result<bool, SessionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, SeaOrmSessionStore: 'async_trait,

Update fields on a QA entry. Only non-None fields in updates are applied. Returns true if the entry was found and updated.

fn get_graph_context<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, user_id: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, SessionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, SeaOrmSessionStore: 'async_trait,

Retrieve the graph knowledge snapshot for a session, or None.

fn set_graph_context<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session_id: &'life1 str, user_id: Option<&'life2 str>, context: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, SeaOrmSessionStore: 'async_trait,

Store (or overwrite) the graph knowledge snapshot for a session.

fn save_trace_step<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, user_id: &'life1 str, session_id: &'life2 str, step: SessionTraceStep, ) -> Pin<Box<dyn Future<Output = Result<String, SessionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, SeaOrmSessionStore: 'async_trait,

Append one agent-trace step to the session’s trace list.

fn read_trace_steps<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, user_id: &'life1 str, session_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<SessionTraceStep>, SessionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, SeaOrmSessionStore: 'async_trait,

Retrieve agent-trace steps for the given session (oldest-first).

fn latest_qa_id<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, user_id: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, SessionError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

Return the qa_id of the most-recent Q&A entry in the session, or None when the session has no entries yet.