Struct ChatDatabase 

pub struct ChatDatabase {
    pub conn: Connection,
}

Universal Chat Database manager

Fields

conn: Connection

Implementations

impl ChatDatabase

pub fn open(path: &Path) -> Result<Self>

Open or create a database at the given path

pub fn open_in_memory() -> Result<Self>

Open an in-memory database (for testing)

pub fn connection(&self) -> &Connection

Get access to the underlying connection

pub fn get_version(&self) -> Result<String>

Get schema version

pub fn upsert_workspace(&self, workspace: &Workspace) -> Result<()>

Insert or update a workspace

pub fn get_workspace(&self, id: &str) -> Result<Option<Workspace>>

Get a workspace by ID

pub fn list_workspaces(&self) -> Result<Vec<Workspace>>

List all workspaces

pub fn upsert_session(&self, session: &Session) -> Result<bool>

Insert or update a session

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

Get a session by ID

pub fn list_sessions( &self, workspace_id: Option<&str>, provider: Option<&str>, limit: usize, ) -> Result<Vec<Session>>

List sessions with optional filters

pub fn count_sessions_by_provider(&self) -> Result<Vec<(String, i64)>>

Count sessions by provider

pub fn insert_message(&self, message: &Message) -> Result<()>

Insert a message

pub fn get_messages(&self, session_id: &str) -> Result<Vec<Message>>

Get messages for a session

pub fn create_checkpoint( &self, session_id: &str, name: &str, description: Option<&str>, git_commit: Option<&str>, ) -> Result<Checkpoint>

Create a checkpoint for a session

pub fn list_checkpoints(&self, session_id: &str) -> Result<Vec<Checkpoint>>

List checkpoints for a session

pub fn add_share_link(&self, link: &ShareLink) -> Result<()>

Add a share link

pub fn get_share_link_by_url(&self, url: &str) -> Result<Option<ShareLink>>

Get share link by URL

pub fn list_share_links(&self, imported_only: bool) -> Result<Vec<ShareLink>>

List all share links

pub fn mark_share_link_imported( &self, url: &str, session_id: &str, ) -> Result<()>

Mark a share link as imported

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

Get database statistics