Method load_session_turns_for_write

atomic-core/src/pristine/txn/write/mod.rs:310–337

(
        &self,
        session_id: &str,
    )

    }

    fn load_session_turns_for_write(
        &self,
        session_id: &str,
    ) -> PristineResult<Vec<crate::change::session::SessionTurn>> {
        use crate::change::session::{
            encode_session_turn_key, session_turn_namespace, SessionTurn,
        };

        let turns = self.txn.open_table(SESSION_TURNS)?;
        let namespace = session_turn_namespace(session_id);
        let scan_start = encode_session_turn_key(namespace, 0);
        let scan_end = encode_session_turn_key(namespace, u32::MAX);
        let mut result = Vec::new();

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

    fn session_ledger_schema_key(session_id: &str) -> String {
        format!(