Method upsert_session_lifecycle

atomic-core/src/pristine/txn/write/mod.rs:689–739

Reconcile lifecycle metadata for a session record. Called from agent session start/end hooks. Creates the record if the session has no ledger entries yet; otherwise updates only the fields supplied, preserving ledger data (provenance links, turn count). `ended_at: None` on a re-entered (resumed) session clears a prior end.

(
        &mut self,
        session_id: &str,
        json_path: &str,
        view_name: Option<String>,
        parent_view: Option<String>,
        ended_at: Option<i64>,
    )

    /// supplied, preserving ledger data (provenance links, turn count).
    /// `ended_at: None` on a re-entered (resumed) session clears a prior end.
    pub fn upsert_session_lifecycle(
        &mut self,
        session_id: &str,
        json_path: &str,
        view_name: Option<String>,
        parent_view: Option<String>,
        ended_at: Option<i64>,
    ) -> PristineResult<()> {
        use crate::change::session::SessionRecord;

        let mut sessions = self.txn.open_table(SESSIONS)?;
        let mut record = match sessions.get(session_id)? {
            Some(value) => SessionRecord::from_bytes(value.value()).map_err(|e| {
                PristineError::Serialization {
                    message: format!("session record decode: {}", e),
                }
            })?,
            None => SessionRecord {
                session_id: session_id.to_string(),
                json_path: json_path.to_string(),
                view_name: None,
                parent_view: None,
                first_provenance: None,
                latest_provenance: None,
                turn_count: 0,
                started_at: chrono::Utc::now().timestamp(),
                ended_at: None,
            },
        };

        if record.json_path.is_empty() {
            record.json_path = json_path.to_string();
        }
        if view_name.is_some() {
            record.view_name = view_name;
        }
        if parent_view.is_some() {
            record.parent_view = parent_view;
        }
        // Explicit assignment: Some(ts) ends the session, None clears a
        // stale end marker when a session is re-entered.
        record.ended_at = ended_at;

        let bytes = record.to_bytes();
        sessions.insert(session_id, bytes.as_slice())?;

        // Refresh the session node's lifecycle metadata (ATOM-16).
        drop(sessions);
        self.emit_session_node(&record)?;
        Ok(())
    }

    /// Store an immutable session manifest and advance its convenience head.
    pub fn save_session_manifest(