Method get_session_events

atomic-core/src/pristine/txn/read.rs:551–578

Get all session events for a provenance graph. Returns events in sequence order. Empty if the provenance is not Sherpa or has no session data.

(
        &self,
        provenance_id: u64,
    )

    /// Returns events in sequence order. Empty if the provenance is not Sherpa
    /// or has no session data.
    pub fn get_session_events(
        &self,
        provenance_id: u64,
    ) -> PristineResult<Vec<crate::change::session::SessionEvent>> {
        use crate::change::session::{encode_session_prefix, SessionEvent};

        let table = self.txn.open_table(SESSION_EVENTS)?;
        let mut events = Vec::new();

        // Use a bounded prefix range instead of a full-table scan.
        // All keys for `provenance_id` lie in [prefix(id), prefix(id+1)).
        let start = encode_session_prefix(provenance_id);
        let end = encode_session_prefix(provenance_id.saturating_add(1));
        for result in table.range::<&[u8; 16]>(&start..&end)? {
            let (_key, value) = result?;
            match SessionEvent::from_bytes(value.value()) {
                Ok(event) => events.push(event),
                Err(e) => {
                    log::warn!("Failed to deserialize session event: {}", e);
                }
            }
        }

        // Events are already in seq order because keys encode (provenance_id,
        // seq) with the same byte layout, but sort explicitly to be safe.
        events.sort_by_key(|e| e.seq);
        Ok(events)
    }

    /// Get all todos for a provenance graph.
    ///