Struct ConversationStore 

pub struct ConversationStore { /* private fields */ }

Manages conversation storage and retrieval using a connection pool

Implementations

impl ConversationStore

pub fn new(pool: Arc<Pool<SqliteConnectionManager>>) -> Self

Create a new conversation store with a shared connection pool

pub fn get_conn_public( &self, ) -> Result<PooledConnection<SqliteConnectionManager>>

Public connection accessor for cross-module queries (e.g., search_api)

pub fn store_message_with_tx( &self, tx: &mut Connection, params: MessageParams<'_>, ) -> Result<StoredMessage>

Store a message using an external transaction

pub fn store_messages_batch( &self, session_id: &str, messages: &[(String, String, i32, i32, f32)], ) -> Result<Vec<StoredMessage>>

Store multiple messages in batch

pub fn store_details_batch( &self, details: &[(&str, i64, &str, &str, &str, f32)], ) -> Result<()>

Store details in batch

pub fn create_session( &self, metadata: Option<SessionMetadata>, ) -> Result<Session>

pub fn create_session_with_id( &self, session_id: &str, metadata: Option<SessionMetadata>, ) -> Result<Session>

Chat persistence: Create session with frontend-provided ID to maintain ID consistency across frontend and backend

pub fn update_session_title(&self, session_id: &str, title: &str) -> Result<()>

Chat persistence: Update session title after auto-generation, also refresh last_accessed. Handles the race condition where title update arrives before the session is created by the streaming endpoint, using INSERT OR IGNORE to avoid UNIQUE constraint failures.

pub fn update_session_pinned( &self, session_id: &str, pinned: bool, ) -> Result<()>

pub fn get_session(&self, session_id: &str) -> Result<Option<Session>>

pub fn get_all_sessions(&self) -> Result<Vec<Session>>

Chat persistence: Retrieve all sessions for sidebar display, ordered by recency

pub fn get_session_messages( &self, session_id: &str, limit: Option<i32>, offset: Option<i32>, ) -> Result<Vec<StoredMessage>>

pub fn get_session_message_count(&self, session_id: &str) -> Result<usize>

pub fn mark_embedding_generated(&self, message_id: i64) -> Result<()>

pub fn delete_session(&self, session_id: &str) -> Result<usize>

pub async fn search_messages_by_keywords( &self, session_id: &str, keywords: &[String], limit: usize, ) -> Result<Vec<StoredMessage>>

Search messages by keywords

pub async fn search_messages_by_topic_across_sessions( &self, topic_keywords: &[String], limit: usize, session_id_filter: Option<&str>, ) -> Result<Vec<StoredMessage>>

Search messages by topic keywords across sessions