Struct SqliteSessionBackend 

pub struct SqliteSessionBackend { /* private fields */ }

SQLite-backed session store with FTS5 and WAL mode.

Implementations

impl SqliteSessionBackend

pub fn new(workspace_dir: &Path) -> Result<Self>

Open or create the sessions database.

pub fn migrate_from_jsonl(&self, workspace_dir: &Path) -> Result<usize>

Migrate JSONL session files into SQLite. Renames migrated files to .jsonl.migrated.

Trait Implementations

impl SessionBackend for SqliteSessionBackend

fn load(&self, session_key: &str) -> Vec<ChatMessage>

Load all messages for a session. Returns empty vec if session doesn’t exist.

fn append(&self, session_key: &str, message: &ChatMessage) -> Result<()>

Append a single message to a session.

fn remove_last(&self, session_key: &str) -> Result<bool>

Remove the last message from a session. Returns true if a message was removed.

fn list_sessions(&self) -> Vec<String>

List all session keys.

fn list_sessions_with_metadata(&self) -> Vec<SessionMetadata>

List sessions with metadata.

fn cleanup_stale(&self, ttl_hours: u32) -> Result<usize>

Remove sessions that haven’t been active within the given TTL hours.

fn delete_session(&self, session_key: &str) -> Result<bool>

Delete all messages for a session. Returns true if the session existed.

fn set_session_name(&self, session_key: &str, name: &str) -> Result<()>

Set or update the human-readable name for a session.

fn get_session_name(&self, session_key: &str) -> Result<Option<String>>

Get the human-readable name for a session (if set).

fn set_session_state( &self, session_key: &str, state: &str, turn_id: Option<&str>, ) -> Result<()>

Set the session state (e.g. “idle”, “running”, “error”). turn_id identifies the current turn (set when running, cleared on idle).

fn get_session_state(&self, session_key: &str) -> Result<Option<SessionState>>

Get the current session state. Returns None if the backend doesn’t track state.

fn list_running_sessions(&self) -> Vec<SessionMetadata>

List sessions currently in “running” state.

fn list_stuck_sessions(&self, threshold_secs: u64) -> Vec<SessionMetadata>

List sessions stuck in “running” state longer than threshold_secs.

fn search(&self, query: &SessionQuery) -> Vec<SessionMetadata>

Search sessions by keyword. Default returns empty (backends with FTS override).

fn compact(&self, _session_key: &str) -> Result<()>

Compact a session file (remove duplicates/corruption). No-op by default.