use indicatif::ProgressBar;

        let progress = ProgressBar::new(c.len() as u64);
        progress.println("Downloading changes");

            progress.inc(1);

                progress.abandon();

        }
        if !progress.is_finished() {
            progress.finish();

        let progress = indicatif::ProgressBar::new_spinner();
        progress.set_style(
            indicatif::ProgressStyle::default_spinner().template("{spinner} Cloning channel"),
        );
        progress.enable_steady_tick(100);

        progress.finish();

use log::debug;

use log::{debug, info};

        let progress = if do_apply {
            let p = indicatif::ProgressBar::new(to_download.len() as u64);
            p.println("Applying changes");
            Some(p)
        } else {
            None
        };

                    if let Some(ref progress) = progress {
                        progress.abandon();
                    }

            if do_apply {
                println!("Applying {:?}", h.to_base32());
                debug!("applying {:?}", h);

            if let Some(ref progress) = progress {
                info!("Applying {:?}", h);
                progress.inc(1);

        if let Some(progress) = progress {
            if !progress.is_finished() {
                progress.finish()
            }
        }

use libpijul::pristine::Base32;

use indicatif::ProgressBar;
use libpijul::pristine::Base32;

        let progress = ProgressBar::new(hashes.len() as u64);
        progress.println("Downloading changes");

            progress.inc(1);

                progress.abandon();

        if !progress.is_finished() {
            progress.finish();
        }

        let progress = indicatif::ProgressBar::new_spinner();
        progress.set_style(
            indicatif::ProgressStyle::default_spinner()
                .template("{spinner} Updating remote changelist"),
        );
        progress.enable_steady_tick(100);

        progress.finish();

            let progress = indicatif::ProgressBar::new_spinner();
            progress.set_style(
                indicatif::ProgressStyle::default_spinner()
                    .template("{spinner} Updating remote changelist"),
            );
            progress.enable_steady_tick(100);

            progress.finish();

            let mut stderr = std::io::stderr();
            writeln!(stderr, "Nothing to pull")?;

        now_.insert(*n);
        result.push(*n)

        if now_.insert(*n) {
            result.push(*n)
        }

use std::io::Write;

        let progress = indicatif::ProgressBar::new_spinner();
        progress.set_style(
            indicatif::ProgressStyle::default_spinner().template("{spinner} Outputting repository"),
        );
        progress.enable_steady_tick(100);

        progress.finish();

        std::fs::rename(&temp.into_path(), &path)?;

        let temp = temp.into_path();
        if let Err(e) = std::fs::rename(&temp, &path) {
            let mut stderr = std::io::stderr();
            writeln!(stderr, "{}", e)?;
            std::fs::remove_dir_all(temp).unwrap_or(());
        }

indicatif = "0.15"

    Ok(())
}
/// Test that `record` notices the deletion of a file.
#[test]
fn del_obsolete_test() -> Result<(), anyhow::Error> {
    env_logger::try_init().unwrap_or(());
    let mut repo = working_copy::memory::Memory::new();
    let changes = changestore::memory::Memory::new();
    let env = pristine::sanakirja::Pristine::new_anon()?;
    let mut txn = env.mut_txn_begin();
    txn.add_file("a/b/c/d/e")?;
    let mut channel = txn.open_or_create_channel("main")?;
    repo.add_file("a/b/c/d/e", b"a\nb\nc\nd\ne\nf\n".to_vec());
    record_all_output(&mut repo, &changes, &mut txn, &mut channel, "")?;
    debug_to_file(&txn, &channel, "debug0").unwrap();
    let files: Vec<_> = crate::fs::iter_working_copy(&txn, Inode::ROOT)
        .map(|(_, file)| file)
        .collect();
    assert_eq!(files, vec!["a", "a/b", "a/b/c", "a/b/c/d", "a/b/c/d/e"]);
    repo.remove_path("a/b/c")?;
    debug!("Recording the deletion");
    record_all_output(&mut repo, &changes, &mut txn, &mut channel, "")?;
    debug_to_file(&txn, &channel, "debug").unwrap();
    let mut repo2 = working_copy::memory::Memory::new();
    output::output_repository_no_pending(&mut repo2, &changes, &mut txn, &mut channel, "", true)?;
    assert_eq!(repo2.list_files(), vec!["a", "a/b"]);
    let files: Vec<_> = crate::fs::iter_working_copy(&txn, Inode::ROOT)
        .map(|(_, name)| name)
        .collect();
    debug!("files = {:?}", files);
    assert_eq!(files, vec!["a", "a/b"]);

                    debug!("edit {:?}", h);

                    debug!("inconsistent change: {:?} {:?}", s, offsets);

]
[[package]]
name = "console"
version = "0.13.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a50aab2529019abfabfa93f1e6c41ef392f91fbf179b347a7e96abb524884a08"
dependencies = [
 "encode_unicode",
 "lazy_static",
 "libc",
 "regex",
 "terminal_size",
 "unicode-width",
 "winapi 0.3.9",
 "winapi-util",

name = "encode_unicode"
version = "0.3.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a357d28ed41a50f9c765dbfe56cbc04a64e53e5fc58ba79fbc34c10ef3df831f"
[[package]]

name = "indicatif"
version = "0.15.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "7baab56125e25686df467fe470785512329883aab42696d661247aca2a2896e4"
dependencies = [
 "console",
 "lazy_static",
 "number_prefix",
 "regex",
]
[[package]]

name = "number_prefix"
version = "0.3.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "17b02fc0ff9a9e4b35b3342880f48e896ebf69f2967921fe8646bf5b7125956a"
[[package]]

 "indicatif",

]
[[package]]
name = "terminal_size"
version = "0.1.15"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "4bd2d183bd3fac5f5fe38ddbeb4dc9aec4a39a9d7d59e7491d900302da01cbe1"
dependencies = [
 "libc",
 "winapi 0.3.9",