From c44acbb50c7c2d5f1d6289dce0b3d70670f9e082 Mon Sep 17 00:00:00 2001 From: yggverse Date: Wed, 13 Aug 2025 15:39:07 +0300 Subject: [PATCH] require `sleep` timer value --- src/config.rs | 4 ++-- src/main.rs | 8 +++----- 2 files changed, 5 insertions(+), 7 deletions(-) diff --git a/src/config.rs b/src/config.rs index 5d14f49..d8ccb35 100644 --- a/src/config.rs +++ b/src/config.rs @@ -99,8 +99,8 @@ pub struct Config { pub add_torrent_timeout: u64, /// Crawl loop delay in seconds - #[arg(long)] - pub sleep: Option, + #[arg(long, default_value_t = 900)] + pub sleep: u64, /// Ban unresolvable info-hashes for `n` seconds #[arg(long, default_value_t = 3600)] diff --git a/src/main.rs b/src/main.rs index 1c80928..5439e50 100644 --- a/src/main.rs +++ b/src/main.rs @@ -232,7 +232,7 @@ async fn main() -> Result<()> { } } log::debug!( - "queue completed at {time_queue} (time: {} / uptime: {} / banned: {})", + "queue completed at {time_queue} (time: {} / uptime: {} / banned: {}) await {} seconds to continue...", Local::now() .signed_duration_since(time_queue) .as_seconds_f32(), @@ -240,11 +240,9 @@ async fn main() -> Result<()> { .signed_duration_since(time_init) .as_seconds_f32(), ban.len(), + config.sleep ); - if let Some(sleep) = config.sleep { - log::debug!("await {sleep} seconds to continue..."); - std::thread::sleep(Duration::from_secs(sleep)) - } + std::thread::sleep(Duration::from_secs(config.sleep)) } }