Function calculate_push_delta

atomic-cli/src/commands/push/helpers.rs:66–107

Calculate which changes need to be pushed to the remote. Compares local and remote changelists to determine which local changes are missing from the remote. Changes are returned in dependency order (earliest first) so they can be uploaded correctly. # Arguments `repo` - The local repository (for loading change metadata) `local_entries` - Local history entries in forward order `remote_entries` -

(
    repo: &Repository,
    local_entries: &[HistoryEntry],
    remote_entries: &[ChangelistEntry],
    graph_hashes: &HashSet<String>,
    push_all: bool,
)

/// println!("Need to push {} changes", to_push.len());
/// ```
pub fn calculate_push_delta(
    repo: &Repository,
    local_entries: &[HistoryEntry],
    remote_entries: &[ChangelistEntry],
    graph_hashes: &HashSet<String>,
    push_all: bool,
) -> CliResult<Vec<PushChange>> {
    // Build set of remote hashes for quick lookup (changes already in this view)
    let remote_hashes: HashSet<String> = remote_entries.iter().map(|e| e.hash.clone()).collect();

    let mut to_upload = Vec::new();

    for entry in local_entries {
        let hash_str = entry.hash.to_base32();

        // Skip if already on this view on the remote (unless pushing all)
        if !push_all && remote_hashes.contains(&hash_str) {
            continue;
        }

        // Try to load the change header to get the message
        let message = load_change_message(repo, &entry.hash);

        // Check if the change is already in the remote graph (via another view).
        // If so, only view adoption is needed — no data transfer.
        let already_in_graph = graph_hashes.contains(&hash_str);

        let push_change = PushChange::new(entry.hash, entry.sequence, entry.state)
            .with_tagged(entry.is_tagged)
            .with_in_graph(already_in_graph);

        let push_change = if let Some(msg) = message {
            push_change.with_message(msg)
        } else {
            push_change
        };

        to_upload.push(push_change);
    }

    Ok(to_upload)
}

/// Load the message from a change, returning None if it fails.
fn load_change_message(repo: &Repository, hash: &Hash) -> Option<String> {