Struct SessionStore 

pub struct SessionStore { /* private fields */ }

Session store for SRBN persistence

Implementations

impl SessionStore

pub fn new() -> Result<SessionStore, Error>

Create a new session store with default path

pub fn open(path: &PathBuf) -> Result<SessionStore, Error>

Open a session store at the given path

pub fn open_read_only(path: &Path) -> Result<SessionStore, Error>

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, Error>

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

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

Create a new session

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

Update session merkle root

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

Record node state

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

Record energy measurement

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

Get session by ID

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

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

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

Ensure a session directory exists and return the path

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

Get energy history for a node (query)

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

Get all energy history for a session (all nodes)

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

List recent sessions (newest first)

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

List sessions with pagination (most recent first).

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

Count total number of sessions.

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

Get all node states for a session

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

Update session status

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

Record an LLM request/response

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

Get LLM requests for a session

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

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<(), Error>

Record a structural digest

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

Get structural digests for a session and node

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

Record context provenance for a node

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

Get context provenance for a session and node

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

Record an escalation report

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

Get escalation reports for a session

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

Record a local graph rewrite

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

Get rewrite records for a session

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

Record a sheaf validation result

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

Get sheaf validation results for a session and node

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

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

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

Record a new provisional branch

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

Update a provisional branch state

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

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>, Error>

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>, Error>

Mark all live branches for a parent as flushed

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

Record a branch lineage edge

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

Get child branch IDs for a parent branch

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

Record an interface seal

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

Get all interface seals for a node

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

Check whether a node has any interface seals

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

Record a branch flush decision

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

Get all branch flush records for a session

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

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<(), Error>

Record a task graph edge (parent→child dependency)

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

Get all task graph edges for a session

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

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

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

Get all review outcomes for a node

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

Get the most recent review outcome for a node

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

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

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

Record a verification result snapshot for a node

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

Get the latest verification result for a node

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

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

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

Record an artifact bundle snapshot for a node

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

Get the latest artifact bundle for a node

impl SessionStore

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

Record a feature charter for a session.

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

Get the feature charter for a session.

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

Record a plan revision.

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

Get the active plan revision for a session.

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

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

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

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

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

Record a repair footprint.

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

Get repair footprints for a node, ordered by attempt.

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

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

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

Mark a repair footprint as resolved.

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

Record or update a budget envelope for a session.

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

Get the budget envelope for a session.

impl SessionStore

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

Record an orchestration step transition.

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

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

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

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

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

Record a correction attempt within a convergence loop.

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

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

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

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