Struct Database 

pub struct Database { /* private fields */ }

Wrapper around the SQLite connection pool.

Implementations

impl Database

pub async fn init(koda_config_dir: &Path) -> Result<Self>

Initialize the database, run migrations, and enable WAL mode.

koda_config_dir is the koda configuration directory (e.g. ~/.config/koda). The database lives in <koda_config_dir>/db/koda.db.

Production callers should pass db::config_dir()?; tests pass a temp dir.

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

Open a database at a specific path (used by tests and init).

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.

impl Debug for Database

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Persistence for Database

fn create_session<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, agent_name: &'life1 str, project_root: &'life2 Path, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Create a new session, returning the generated session ID.

fn insert_message<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'life6, 'async_trait>( &'life0 self, session_id: &'life1 str, role: &'life2 Role, content: Option<&'life3 str>, tool_calls: Option<&'life4 str>, tool_call_id: Option<&'life5 str>, usage: Option<&'life6 TokenUsage>, ) -> Pin<Box<dyn Future<Output = Result<i64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, 'life6: 'async_trait,

Insert a message into the conversation log.

fn insert_message_with_agent<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'life6, 'life7, 'async_trait>( &'life0 self, session_id: &'life1 str, role: &'life2 Role, content: Option<&'life3 str>, tool_calls: Option<&'life4 str>, tool_call_id: Option<&'life5 str>, usage: Option<&'life6 TokenUsage>, agent_name: Option<&'life7 str>, ) -> Pin<Box<dyn Future<Output = Result<i64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, 'life6: 'async_trait, 'life7: 'async_trait,

Insert a message with an optional agent name for cost tracking.

fn load_context<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load active (non-compacted) messages for a session.

Returns messages in chronological order. Compacted messages (archived by /compact) are excluded — their summary replaces them. Mismatched tool_use/tool_result pairs are pruned (#428).

fn load_all_messages<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load ALL messages for a session (for RecallContext search). Returns messages in chronological order, no truncation.

fn recent_user_messages<'life0, 'async_trait>( &'life0 self, limit: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Load recent user messages across all sessions (for the startup banner). Returns up to limit messages, newest first.

fn session_token_usage<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<SessionUsage>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get token usage totals for a session.

fn session_usage_by_agent<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, SessionUsage)>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get token usage broken down by agent name.

fn list_sessions<'life0, 'life1, 'async_trait>( &'life0 self, limit: i64, project_root: &'life1 Path, ) -> Pin<Box<dyn Future<Output = Result<Vec<SessionInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List recent sessions for a specific project.

fn last_assistant_message<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get the last assistant text response for a session (for headless JSON output).

fn last_user_message<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get the last user message in a session.

fn delete_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete a session and all its messages/metadata atomically.

fn compact_session<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, summary: &'life2 str, preserve_count: usize, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Compact a session: summarize old messages while preserving the most recent ones.

Keeps the last preserve_count messages intact, deletes the rest, and inserts a summary (as a system message) plus a continuation hint (as an assistant message) before the preserved tail.

Returns the number of messages that were deleted/replaced.

fn has_pending_tool_calls<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check if the last message in a session is a tool call awaiting a response. Used to defer compaction during active tool execution.

fn compacted_stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<CompactedStats>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stats about compacted (archived) messages across all sessions.

fn purge_compacted<'life0, 'async_trait>( &'life0 self, min_age_days: u32, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Permanently delete compacted messages older than min_age_days. Pass 0 to delete all compacted messages regardless of age.

fn get_metadata<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Get a session metadata value by key.

fn set_metadata<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session_id: &'life1 str, key: &'life2 str, value: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Set a session metadata value (upsert).

fn get_todo<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get the todo list for a session (convenience wrapper).

fn set_todo<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, content: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Set the todo list for a session (convenience wrapper).