Function get_changes_up_to_seq

atomic-repository/src/apply/queries.rs:94–123

Get changes up to a specific sequence number. # Arguments `txn` - Read transaction `view` - The view to query `max_sequence` - Maximum sequence (inclusive) # Returns Vector of hashes up to and including the specified sequence.

(
    txn: &T,
    view: &ViewState,
    max_sequence: u64,
)

///
/// Vector of hashes up to and including the specified sequence.
pub fn get_changes_up_to_seq<T: ViewTxnT>(
    txn: &T,
    view: &ViewState,
    max_sequence: u64,
) -> InsertResult<Vec<Hash>> {
    let mut changes = Vec::new();

    let iter = txn
        .iter_changes(view, 0)
        .map_err(|e| InsertError::Database(e.to_string()))?;

    for result in iter {
        let (seq, node_id, _merkle) = result.map_err(|e| InsertError::Database(e.to_string()))?;

        if seq > max_sequence {
            break;
        }

        let hash = txn
            .get_external(node_id)
            .map_err(|e| InsertError::Database(e.to_string()))?
            .ok_or_else(|| {
                InsertError::Internal(format!("Change {} has no external hash", node_id.0))
            })?;

        changes.push(hash);
    }

    Ok(changes)
}

/// Find which changes from a list are missing in a view.
///