Struct SessionStore 

pub struct SessionStore { /* private fields */ }

Session store for SRBN persistence

Implementations

impl SessionStore

pub fn new() -> Result<Self>

Create a new session store with default path

pub fn open(path: &PathBuf) -> Result<Self>

Open a session store at the given path

pub fn open_read_only(path: &Path) -> Result<Self>

Open a session store in read-only mode for concurrent dashboard reads.

Uses AccessMode::ReadOnly so the dashboard can read alongside the agent’s write lock. Does not call init_schema() (a write op). The database file must already exist.

pub fn default_db_path() -> Result<PathBuf>

Get the default database path (~/.local/share/perspt/perspt.db or similar)

pub fn create_session(&self, session: &SessionRecord) -> Result<()>

Create a new session

pub fn update_merkle_root( &self, session_id: &str, merkle_root: &[u8], ) -> Result<()>

Update session merkle root

pub fn record_node_state(&self, record: &NodeStateRecord) -> Result<()>

Record node state

pub fn record_energy(&self, record: &EnergyRecord) -> Result<()>

Record energy measurement

pub fn get_session(&self, session_id: &str) -> Result<Option<SessionRecord>>

Get session by ID

pub fn get_session_dir(&self, session_id: &str) -> Result<PathBuf>

Get the directory for session artifacts (~/.local/share/perspt/sessions/<id>)

pub fn create_session_dir(&self, session_id: &str) -> Result<PathBuf>

Ensure a session directory exists and return the path

pub fn get_energy_history( &self, session_id: &str, node_id: &str, ) -> Result<Vec<EnergyRecord>>

Get energy history for a node (query)

pub fn get_session_energy_history( &self, session_id: &str, ) -> Result<Vec<EnergyRecord>>

Get all energy history for a session (all nodes)

pub fn list_recent_sessions(&self, limit: usize) -> Result<Vec<SessionRecord>>

List recent sessions (newest first)

pub fn list_sessions_paginated( &self, limit: usize, offset: usize, ) -> Result<Vec<SessionRecord>>

List sessions with pagination (most recent first).

pub fn count_sessions(&self) -> Result<usize>

Count total number of sessions.

pub fn get_node_states(&self, session_id: &str) -> Result<Vec<NodeStateRecord>>

Get all node states for a session

pub fn update_session_status( &self, session_id: &str, status: &str, ) -> Result<()>

Update session status

pub fn record_llm_request(&self, record: &LlmRequestRecord) -> Result<()>

Record an LLM request/response

pub fn get_llm_requests( &self, session_id: &str, ) -> Result<Vec<LlmRequestRecord>>

Get LLM requests for a session

pub fn get_global_llm_summary(&self) -> Result<(i64, i64, i64, i64)>

Aggregate LLM statistics across all sessions: (count, sum_tokens_in, sum_tokens_out, sum_latency_ms)

pub fn record_structural_digest( &self, record: &StructuralDigestRecord, ) -> Result<()>

Record a structural digest

pub fn get_structural_digests( &self, session_id: &str, node_id: &str, ) -> Result<Vec<StructuralDigestRecord>>

Get structural digests for a session and node

pub fn record_context_provenance( &self, record: &ContextProvenanceRecord, ) -> Result<()>

Record context provenance for a node

pub fn get_context_provenance( &self, session_id: &str, node_id: &str, ) -> Result<Option<ContextProvenanceRecord>>

Get context provenance for a session and node

pub fn record_escalation_report( &self, record: &EscalationReportRecord, ) -> Result<()>

Record an escalation report

pub fn get_escalation_reports( &self, session_id: &str, ) -> Result<Vec<EscalationReportRecord>>

Get escalation reports for a session

pub fn record_rewrite(&self, record: &RewriteRecordRow) -> Result<()>

Record a local graph rewrite

pub fn get_rewrite_records( &self, session_id: &str, ) -> Result<Vec<RewriteRecordRow>>

Get rewrite records for a session

pub fn record_sheaf_validation(&self, record: &SheafValidationRow) -> Result<()>

Record a sheaf validation result

pub fn get_sheaf_validations( &self, session_id: &str, node_id: &str, ) -> Result<Vec<SheafValidationRow>>

Get sheaf validation results for a session and node

pub fn get_all_sheaf_validations( &self, session_id: &str, ) -> Result<Vec<SheafValidationRow>>

Get all sheaf validations for a session (all nodes).

pub fn record_provisional_branch( &self, record: &ProvisionalBranchRow, ) -> Result<()>

Record a new provisional branch

pub fn update_branch_state( &self, branch_id: &str, new_state: &str, ) -> Result<()>

Update a provisional branch state

pub fn get_provisional_branches( &self, session_id: &str, ) -> Result<Vec<ProvisionalBranchRow>>

Get all provisional branches for a session

pub fn get_live_branches_for_parent( &self, session_id: &str, parent_node_id: &str, ) -> Result<Vec<ProvisionalBranchRow>>

Get live (active/sealed) provisional branches depending on a parent node

pub fn flush_branches_for_parent( &self, session_id: &str, parent_node_id: &str, ) -> Result<Vec<String>>

Mark all live branches for a parent as flushed

pub fn record_branch_lineage(&self, record: &BranchLineageRow) -> Result<()>

Record a branch lineage edge

pub fn get_child_branches(&self, parent_branch_id: &str) -> Result<Vec<String>>

Get child branch IDs for a parent branch

pub fn record_interface_seal(&self, record: &InterfaceSealRow) -> Result<()>

Record an interface seal

pub fn get_interface_seals( &self, session_id: &str, node_id: &str, ) -> Result<Vec<InterfaceSealRow>>

Get all interface seals for a node

pub fn has_interface_seals( &self, session_id: &str, node_id: &str, ) -> Result<bool>

Check whether a node has any interface seals

pub fn record_branch_flush(&self, record: &BranchFlushRow) -> Result<()>

Record a branch flush decision

pub fn get_branch_flushes( &self, session_id: &str, ) -> Result<Vec<BranchFlushRow>>

Get all branch flush records for a session

pub fn get_latest_node_states( &self, session_id: &str, ) -> Result<Vec<NodeStateRecord>>

Get the latest node state snapshot per node for a session (for resume reconstruction).

Returns at most one record per node_id, picking the most recently created row.

pub fn record_task_graph_edge(&self, record: &TaskGraphEdgeRow) -> Result<()>

Record a task graph edge (parent→child dependency)

pub fn get_task_graph_edges( &self, session_id: &str, ) -> Result<Vec<TaskGraphEdgeRow>>

Get all task graph edges for a session

pub fn record_review_outcome(&self, record: &ReviewOutcomeRow) -> Result<()>

Record a review outcome (approval, rejection, edit request)

pub fn get_review_outcomes( &self, session_id: &str, node_id: &str, ) -> Result<Vec<ReviewOutcomeRow>>

Get all review outcomes for a node

pub fn get_latest_review_outcome( &self, session_id: &str, node_id: &str, ) -> Result<Option<ReviewOutcomeRow>>

Get the most recent review outcome for a node

pub fn get_all_review_outcomes( &self, session_id: &str, ) -> Result<Vec<ReviewOutcomeRow>>

Get all review outcomes for a session (across all nodes).

pub fn record_verification_result( &self, record: &VerificationResultRow, ) -> Result<()>

Record a verification result snapshot for a node

pub fn get_verification_result( &self, session_id: &str, node_id: &str, ) -> Result<Option<VerificationResultRow>>

Get the latest verification result for a node

pub fn get_all_verification_results( &self, session_id: &str, ) -> Result<Vec<VerificationResultRow>>

Get all verification results for a session (for status display)

pub fn record_artifact_bundle(&self, record: &ArtifactBundleRow) -> Result<()>

Record an artifact bundle snapshot for a node

pub fn get_artifact_bundle( &self, session_id: &str, node_id: &str, ) -> Result<Option<ArtifactBundleRow>>

Get the latest artifact bundle for a node

impl SessionStore

pub fn record_feature_charter(&self, row: &FeatureCharterRow) -> Result<()>

Record a feature charter for a session.

pub fn get_feature_charter( &self, session_id: &str, ) -> Result<Option<FeatureCharterRow>>

Get the feature charter for a session.

pub fn record_plan_revision(&self, row: &PlanRevisionRow) -> Result<()>

Record a plan revision.

pub fn get_active_plan_revision( &self, session_id: &str, ) -> Result<Option<PlanRevisionRow>>

Get the active plan revision for a session.

pub fn get_plan_revisions( &self, session_id: &str, ) -> Result<Vec<PlanRevisionRow>>

Get all plan revisions for a session, ordered by sequence.

pub fn supersede_plan_revision(&self, revision_id: &str) -> Result<()>

Supersede a plan revision (set status to ‘superseded’).

pub fn record_repair_footprint(&self, row: &RepairFootprintRow) -> Result<()>

Record a repair footprint.

pub fn get_repair_footprints( &self, session_id: &str, node_id: &str, ) -> Result<Vec<RepairFootprintRow>>

Get repair footprints for a node, ordered by attempt.

pub fn get_all_repair_footprints( &self, session_id: &str, ) -> Result<Vec<RepairFootprintRow>>

Get all repair footprints for a session (all nodes).

pub fn resolve_repair_footprint(&self, footprint_id: &str) -> Result<()>

Mark a repair footprint as resolved.

pub fn upsert_budget_envelope(&self, row: &BudgetEnvelopeRow) -> Result<()>

Record or update a budget envelope for a session.

pub fn get_budget_envelope( &self, session_id: &str, ) -> Result<Option<BudgetEnvelopeRow>>

Get the budget envelope for a session.

impl SessionStore

pub fn record_step(&self, record: &SrbnStepRecord) -> Result<()>

Record an orchestration step transition.

pub fn get_step_timeline( &self, session_id: &str, node_id: &str, ) -> Result<Vec<SrbnStepRecord>>

Retrieve the step timeline for a given node in chronological order.

pub fn get_session_steps(&self, session_id: &str) -> Result<Vec<SrbnStepRecord>>

Retrieve all step records for a session, ordered by id.

pub fn record_correction_attempt( &self, record: &CorrectionAttemptRow, ) -> Result<()>

Record a correction attempt within a convergence loop.

pub fn get_correction_attempts( &self, session_id: &str, node_id: &str, ) -> Result<Vec<CorrectionAttemptRow>>

Retrieve all correction attempts for a node, ordered by attempt number.

pub fn get_session_correction_attempts( &self, session_id: &str, ) -> Result<Vec<CorrectionAttemptRow>>

Retrieve all correction attempts for a session, ordered by node then attempt.