Struct SessionStore 

pub struct SessionStore { /* private fields */ }

Append-only JSONL session store for channel conversations.

Implementations

impl SessionStore

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

Create a new session store, ensuring the sessions directory exists.

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

Load all messages for a session from its JSONL file. Returns an empty vec if the file does not exist or is unreadable.

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

Append a single message to the session JSONL file.

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

Remove the last message from a session’s JSONL file.

Rewrite approach: load all messages, drop the last, rewrite. This is O(n) but rollbacks are rare.

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

Compact a session file by rewriting only valid messages (removes corrupt lines).

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

Delete a session’s JSONL file. Returns true if the file existed.

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

List all session keys that have files on disk.

Trait Implementations

impl SessionBackend for SessionStore

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 compact(&self, session_key: &str) -> Result<()>

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

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

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

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 search(&self, _query: &SessionQuery) -> Vec<SessionMetadata>

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

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.