diff options
| author | jakka <jakkadoujin@gmail.com> | 2025-06-19 16:34:13 +0300 |
|---|---|---|
| committer | jakka <jakkadoujin@gmail.com> | 2025-06-19 16:34:13 +0300 |
| commit | 7187a175c9e54ffcb3444ca9c343b86bdb7d7224 (patch) | |
| tree | 923fb373925be3c4593d452fa462d735d88ffe93 /src/files.rs | |
| parent | fda50928e2e2f46c1dea45527c1277906a208c2a (diff) | |
added conditial compilation configuration for tests
Diffstat (limited to 'src/files.rs')
| -rw-r--r-- | src/files.rs | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/files.rs b/src/files.rs index 171b866..fd0a167 100644 --- a/src/files.rs +++ b/src/files.rs @@ -1,5 +1,6 @@ use anyhow::{Result, anyhow}; use futures_util::StreamExt; +#[allow(unused_imports)] use indicatif::{ProgressBar, ProgressStyle}; use pin_utils::pin_mut; use std::{ @@ -13,6 +14,7 @@ use walkdir::WalkDir; use crate::{db::Database, flac::encode_file}; +#[allow(dead_code)] const BAR_TEMPLATE: &str = "{msg} [{wide_bar:.green/cyan}] Elapsed: {elapsed} {pos:>7}/{len:7}"; #[derive(Debug)] @@ -79,6 +81,7 @@ pub async fn index_files_recursively(path: impl AsRef<Path>, conn: &Database) -> let mut tasks = JoinSet::new(); + #[cfg(not(test))] let bar = ProgressBar::new(0) .with_style(ProgressStyle::with_template(BAR_TEMPLATE)?.progress_chars("#>-")) .with_message("Indexing"); @@ -92,6 +95,7 @@ pub async fn index_files_recursively(path: impl AsRef<Path>, conn: &Database) -> if ext == "flac" { let newconn = conn.clone(); tasks.spawn(async move { handle_file(path, newconn).await }); + #[cfg(not(test))] bar.inc_length(1); } } @@ -104,11 +108,13 @@ pub async fn index_files_recursively(path: impl AsRef<Path>, conn: &Database) -> Ok(Err(error)) => eprintln!("{error}"), Err(error) => eprintln!("Error encountered:\t{}", error), _ => { + #[cfg(not(test))] bar.inc(1); } } } + #[cfg(not(test))] bar.finish_with_message("Finished indexing"); Ok(()) } @@ -119,6 +125,7 @@ pub async fn reencode_files(conn: &Database) -> Result<()> { let mut tasks = JoinSet::new(); + #[cfg(not(test))] let bar = ProgressBar::new(conn.get_toencode_number().await?) .with_style(ProgressStyle::with_template(BAR_TEMPLATE)?.progress_chars("#>-")) .with_message("Reencoding"); @@ -147,11 +154,13 @@ pub async fn reencode_files(conn: &Database) -> Result<()> { Ok(Err(error)) => eprintln!("Error encountered:\t{error}"), Err(error) => eprintln!("Error encountered:\t{error}"), _ => { + #[cfg(not(test))] bar.inc(1); } } } + #[cfg(not(test))] bar.finish_with_message("Finished encoding"); Ok(()) |
