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 store_message_with_tx( &self, tx: &mut Connection, session_id: &str, role: &str, content: &str, message_index: i32, tokens: i32, importance_score: f32, ) -> 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: Option<String>, metadata: Option<SessionMetadata>, ) -> Result<Session>

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

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

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