Struct Database 

pub struct Database { /* private fields */ }

Database connection pool (simple Arc wrapper for SQLite)

Implementations

impl Database

pub fn new<P: AsRef<Path>>(path: P) -> Result<Self>

Create a new database connection

Arguments

• path - Path to SQLite database file (or “:memory:” for in-memory)

pub fn initialize_schema(&self) -> Result<()>

Initialize database schema

pub fn create_conversation( &self, id: Uuid, metadata: Option<String>, ) -> Result<()>

Create a new conversation

pub fn get_conversation(&self, id: Uuid) -> Result<Conversation>

Get conversation by ID

pub fn end_conversation(&self, id: Uuid) -> Result<()>

End a conversation

pub fn increment_turn_count(&self, conversation_id: Uuid) -> Result<()>

Increment conversation turn count

pub fn store_event( &self, id: Uuid, conversation_id: Uuid, event_type: &str, content: &str, metadata: Option<String>, ) -> Result<()>

Store an event

pub fn get_conversation_events( &self, conversation_id: Uuid, ) -> Result<Vec<StoredEvent>>

Get all events for a conversation

pub fn get_recent_events_by_type( &self, event_type: &str, limit: usize, ) -> Result<Vec<StoredEvent>>

Get recent events by type

pub fn delete_old_events(&self, before: DateTime<Utc>) -> Result<usize>

Delete old events (for cleanup)

pub fn store_event_with_embedding( &self, id: Uuid, conversation_id: Uuid, event_type: &str, content: &str, metadata: Option<String>, embedding: &[f32], ) -> Result<()>

Store an event with its embedding for conversation memory

pub fn search_conversation_history( &self, conversation_id: Uuid, query_embedding: &[f32], top_k: usize, ) -> Result<Vec<(StoredEvent, f32)>>

Search conversation history by semantic similarity

Arguments

• conversation_id - Conversation to search within
• query_embedding - Embedding vector of the query
• top_k - Number of results to return

Returns

Vector of (event, similarity_score) tuples, sorted by similarity (highest first)

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

Get database statistics

impl Database

pub fn conn(&self) -> Arc<Mutex<Connection>>

Get a clone of the internal connection (for IdentityStore)

pub fn get_thought_count(&self) -> Result<usize>

Get thought count from thoughtchain table

pub fn get_identity_count(&self) -> Result<usize>

Get identity count from identities table

pub fn get_relationship_count(&self) -> Result<usize>

Get relationship count from relationships table

pub fn get_session_count(&self) -> Result<usize>

Get session count from sessions table

pub fn store_chat_message( &self, id: String, instance_id: String, role: String, content: String, timestamp: String, ) -> Result<()>

Store a chat message

pub fn get_chat_messages( &self, instance_id: &str, limit: usize, ) -> Result<Vec<ChatMessage>>

Get chat messages for a specific instance

Trait Implementations

impl Clone for Database

fn clone(&self) -> Database

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.