Struct SessionManager 

pub struct SessionManager { /* private fields */ }

Manager for session persistence operations

Implementations

impl SessionManager

pub fn new(sessions_dir: PathBuf) -> Result<Self>

Create a new SessionManager with the specified sessions directory. Tries to open SQLite DB at sessions_dir/sessions.db with auto-migration from JSON files if present.

pub fn default_location() -> Result<Self>

Create a SessionManager using the default location (~/.deepseek/sessions)

pub fn save_session(&self, session: &SavedSession) -> Result<PathBuf>

Save a session to disk using SQLite (or atomic write JSON if no DB).

pub fn load_compaction_artifacts( &self, session_id: &str, ) -> Result<Vec<CompactionArtifact>>

Load compaction artifacts for a session from SQLite (empty when JSON-only mode).

pub fn save_checkpoint(&self, session: &SavedSession) -> Result<PathBuf>

Save a crash-recovery checkpoint for in-flight turns.

pub fn load_checkpoint(&self) -> Result<Option<SavedSession>>

Load the most recent crash-recovery checkpoint if present.

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

Clear any crash-recovery checkpoint.

pub fn save_offline_queue_state( &self, state: &OfflineQueueState, session_id: Option<&str>, ) -> Result<PathBuf>

Save offline queue state (queued + draft messages).

pub fn load_offline_queue_state(&self) -> Result<Option<OfflineQueueState>>

Load offline queue state if present.

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

Remove persisted offline queue state.

pub fn find_session_id_by_runtime_thread_id( &self, runtime_thread_id: &str, ) -> Result<Option<String>>

Find a persisted session id linked to a runtime thread (most recent first).

pub fn load_session(&self, id: &str) -> Result<SavedSession>

Load a session by ID (SQLite first, then JSON fallback)

pub fn load_session_by_prefix(&self, prefix: &str) -> Result<SavedSession>

Load a session by partial ID prefix

pub fn list_sessions(&self) -> Result<Vec<SessionMetadata>>

List all saved sessions (SQLite indexed, then JSON fallback)

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

Delete a session by ID

pub fn prune_sessions_older_than(&self, max_age: Duration) -> Result<usize>

Remove session files whose updated_at is older than max_age from the persisted-sessions directory. Returns the number of records pruned. Building block for #406’s phase-2 auto-archive on boot; today the user-facing entry point is the /sessions prune <days> slash command.

Crash-recovery safety: skips the running checkpoint (checkpoints/latest.json) and any file under checkpoints/ — those are owned by the checkpoint subsystem and live with stricter durability rules. Only top-level <session_id>.json files are candidates.

max_age is checked against the metadata’s updated_at timestamp embedded in the JSON, not the filesystem mtime — the user may have rsynced their ~/.deepseek between machines and fs mtimes can lie.

pub fn get_latest_session_for_workspace( &self, workspace: &Path, ) -> Result<Option<SessionMetadata>>

Get the most recent session scoped to the current workspace.

pub fn search_sessions(&self, query: &str) -> Result<Vec<SessionMetadata>>

Search sessions by title