Method download_missing_changes

atomic-cli/src/commands/clone/command.rs:504–584

Download every change in `missing` and save it to the change store. Stops on the first download failure to maintain consistency (the manifest apply would fail on the missing change anyway).

(
        &self,
        repo: &Repository,
        change_objects: &HashMap<String, Vec<u8>>,
        missing: &[Hash],
        stats: &mut CloneStats,
        progress: &mut CloneProgress,
    )

    /// Stops on the first download failure to maintain consistency (the
    /// manifest apply would fail on the missing change anyway).
    fn download_missing_changes(
        &self,
        repo: &Repository,
        change_objects: &HashMap<String, Vec<u8>>,
        missing: &[Hash],
        stats: &mut CloneStats,
        progress: &mut CloneProgress,
    ) -> CliResult<()> {
        if missing.is_empty() {
            return Ok(());
        }

        print_blank();
        println!("Downloading {}:", format_count(missing.len(), "change"));
        print_blank();

        let progress_bar = create_progress_bar(missing.len() as u64, "Downloading changes");

        for (i, hash) in missing.iter().enumerate() {
            let hash_str = hash.to_base32();
            let hash_display = &hash_str[..12.min(hash_str.len())];

            match change_objects.get(&hash_str) {
                Some(data) => {
                    let data_len = data.len() as u64;

                    // Save to local change store
                    match save_downloaded_change(repo, hash, Bytes::from(data.clone())) {
                        Ok(()) => {
                            stats.record_change_downloaded(data_len);
                            progress.record_downloaded();
                            println!(
                                "  {} {}... ({}/{})",
                                success("✓"),
                                style_hash(hash_display),
                                i + 1,
                                missing.len()
                            );
                        }
                        Err(e) => {
                            stats.record_failed();
                            println!(
                                "  {} {}... ({}/{}) save failed: {}",
                                error("✗"),
                                hash_display,
                                i + 1,
                                missing.len(),
                                e
                            );
                        }
                    }
                }
                None => {
                    stats.record_failed();
                    println!(
                        "  {} {}... ({}/{}) not found on remote",
                        error("✗"),
                        hash_display,