Struct LocalStore 

pub struct LocalStore { /* private fields */ }

Local SQLite and file-store handle.

Implementations

impl LocalStore

pub fn replay_display_window( &self, session_id: &str, run_id: Option<&str>, cursor: Option<&ReplayCursor>, ) -> CliResult<DisplayReplayWindow>

Replay display messages as scoped replay events.

impl LocalStore

pub fn open(config: &CliConfig) -> CliResult<Self>

Open a local store and initialize schema.

pub fn create_session( &mut self, profile: &str, title: Option<String>, ) -> CliResult<SessionRecord>

Create or load a session.

pub fn load_session(&self, session_id: &str) -> CliResult<SessionRecord>

Load a session.

pub fn resolve_session_prefix( &self, session_id_or_prefix: &str, ) -> CliResult<String>

Resolve a session id or unique session id prefix.

pub fn delete_session(&mut self, session_id: &str) -> CliResult<bool>

Delete one session and its retained evidence.

pub fn load_run(&self, session_id: &str, run_id: &str) -> CliResult<RunRecord>

Load a run.

pub fn latest_session(&self) -> CliResult<Option<SessionRecord>>

Latest active session.

pub fn append_run( &mut self, session_id: &str, prompt: String, restore_from_run_id: Option<String>, profile: &str, ) -> CliResult<RunRecord>

Append a new queued run atomically and update session pointers.

pub fn complete_run( &mut self, run: &mut RunRecord, output: String, artifacts: RunArtifacts, ) -> CliResult<Vec<DisplayMessage>>

Complete or pause a run, persist display messages, archive stream blobs, and update pointers.

pub fn fail_run( &mut self, run: &mut RunRecord, message: String, ) -> CliResult<()>

Fail a run atomically.

pub fn fail_run_with_messages( &mut self, run: &mut RunRecord, message: String, messages: &[DisplayMessage], ) -> CliResult<()>

Fail a run and persist terminal display evidence.

pub fn load_restore_state( &self, session_id: &str, run_id: Option<&str>, ) -> CliResult<Option<ResumableState>>

Load the latest saved state for a run selected as continuation source.

pub fn list_sessions(&self, limit: usize) -> CliResult<Vec<SessionSummary>>

List session summaries.

pub fn list_runs( &self, session_id: &str, limit: usize, ) -> CliResult<Vec<RunSummary>>

List run summaries.

pub fn replay_display( &self, session_id: &str, run_id: Option<&str>, after: Option<usize>, ) -> CliResult<Vec<DisplayMessage>>

Replay display messages for a session or run.

pub fn trim( &mut self, sessions: Vec<String>, keep_runs: usize, dry_run: bool, ) -> CliResult<TrimReport>

Trim old runs for selected sessions.

pub fn trim_with_age( &mut self, sessions: Vec<String>, keep_runs: usize, older_than: Option<Duration>, dry_run: bool, ) -> CliResult<TrimReport>

Trim old runs for selected sessions and optional age horizon.

pub fn all_session_ids(&self) -> CliResult<Vec<String>>

Return all session ids.

pub fn list_approvals( &self, session_id: Option<&str>, run_id: Option<&str>, ) -> CliResult<Vec<ApprovalRecord>>

List persisted approval records.

pub fn load_approval(&self, approval_id: &str) -> CliResult<ApprovalRecord>

Load one approval record.

pub fn decide_approval( &mut self, approval_id: &str, status: ApprovalStatus, reason: Option<String>, ) -> CliResult<ApprovalRecord>

Record an approval decision.

pub fn list_deferred_tools( &self, session_id: Option<&str>, run_id: Option<&str>, ) -> CliResult<Vec<DeferredToolRecord>>

List persisted deferred tool records.

pub fn load_deferred_tool( &self, deferred_id: &str, ) -> CliResult<DeferredToolRecord>

Load one deferred tool record.

pub fn complete_deferred_tool( &mut self, deferred_id: &str, response: Value, ) -> CliResult<DeferredToolRecord>

Complete one deferred tool record.

pub fn fail_deferred_tool( &mut self, deferred_id: &str, error: &str, ) -> CliResult<DeferredToolRecord>

Fail one deferred tool record.