Method get_session_turns

atomic-core/src/pristine/txn/read.rs:587–613

Read all indexed turns for an external session ID in turn order.

(
        &self,
        session_id: &str,
    )

    /// Read all indexed turns for an external session ID in turn order.
    pub fn get_session_turns(
        &self,
        session_id: &str,
    ) -> PristineResult<Vec<crate::change::session::SessionTurn>> {
        use crate::change::session::{session_turn_namespace, SessionTurn};

        let table = self.txn.open_table(SESSION_TURNS)?;
        let namespace = session_turn_namespace(session_id);
        let start = crate::change::session::encode_session_turn_key(namespace, 0);
        let end = crate::change::session::encode_session_turn_key(namespace, u32::MAX);
        let mut turns = Vec::new();

        for result in table.range::<&[u8; 40]>(&start..=&end)? {
            let (_key, value) = result?;
            let turn = SessionTurn::from_bytes(value.value()).map_err(|e| {
                PristineError::Serialization {
                    message: format!("session turn decode: {}", e),
                }
            })?;
            if turn.session_id == session_id {
                turns.push(turn);
            }
        }

        turns.sort_by_key(|turn| turn.turn_number);
        Ok(turns)
    }

    /// Load an immutable session manifest by content hash.
    pub fn get_session_manifest(