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 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 calculate_hash(content: &[u8]) -> Vec<u8>

Calculate Merkle hash for content

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 list_recent_sessions(&self, limit: usize) -> Result<Vec<SessionRecord>>

List recent sessions (newest first)

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 count_all_llm_requests(&self) -> Result<i64>

Count all LLM requests in the database (for debugging)

pub fn get_all_llm_requests( &self, limit: usize, ) -> Result<Vec<LlmRequestRecord>>

Get all LLM requests (for debugging)

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 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 get_children_of_node( &self, session_id: &str, parent_node_id: &str, ) -> Result<Vec<String>>

Get child node IDs for a parent in a session’s task graph

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