Function calculate_pull_delta

atomic-cli/src/commands/pull/helpers.rs:68–102

Calculate which changes need to be pulled from the remote. Compares remote and local changelists to determine which remote changes are missing locally. Changes are returned in dependency order (earliest first) so they can be downloaded and applied correctly. # Arguments `remote_entries` - Remote changelist entries (in sequence order) `local_entries` - Local history entries `pull_all` - Whether

(
    remote_entries: &[ChangelistEntry],
    local_entries: &[HistoryEntry],
    pull_all: bool,
)

/// println!("Need to pull {} changes", to_pull.len());
/// ```
pub fn calculate_pull_delta(
    remote_entries: &[ChangelistEntry],
    local_entries: &[HistoryEntry],
    pull_all: bool,
) -> Vec<PullChange> {
    // Build set of local hashes for quick lookup
    let local_hashes: HashSet<String> = local_entries.iter().map(|e| e.hash.to_base32()).collect();

    let mut to_download = Vec::new();

    for entry in remote_entries {
        // Skip if already have this change locally (unless pulling all)
        if !pull_all && local_hashes.contains(&entry.hash) {
            continue;
        }

        // Parse the hash from base32
        let hash = match Hash::from_base32(entry.hash.as_bytes()) {
            Some(h) => h,
            None => continue, // Skip invalid hashes
        };

        // Parse the merkle state from base32
        let state = match Merkle::from_base32(entry.merkle.as_bytes()) {
            Some(m) => m,
            None => continue, // Skip invalid merkle states
        };

        let pull_change = PullChange::new(hash, entry.sequence, state).with_tagged(entry.tagged);

        to_download.push(pull_change);
    }

    to_download
}

/// Check if there are local-only changes (changes not on the remote).
///