Struct DatabaseWorker 

pub struct DatabaseWorker { /* private fields */ }

Implementations

impl DatabaseWorker

pub fn new(shared_state: Arc<SharedState>) -> Self

pub async fn store_messages( &self, session_id: String, messages: Vec<Message>, ) -> Result<()>

Store messages in database

pub async fn get_conversation( &self, session_id: &str, ) -> Result<Vec<StoredMessage>>

Retrieve conversation from database

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

Update conversation title

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

Delete conversation

pub async fn begin_transaction(&self) -> Result<Transaction<'_>>

Begin database transaction

pub async fn get_stats(&self) -> Result<DatabaseStats>

Get database statistics

pub async fn cleanup_old_data(&self, older_than_days: i32) -> Result<usize>

Cleanup old data