From 5e1226a2b55125d0d8e087413c013dccba5f2c07 Mon Sep 17 00:00:00 2001 From: Yoo1tic <137816438+Yoo1tic@users.noreply.github.com> Date: Mon, 11 Aug 2025 02:30:02 +0800 Subject: [PATCH] refactor: update dependencies and improve logging in validation service --- Cargo.toml | 6 +++--- release.sh | 0 src/main.rs | 7 ++++++- src/validation/validation_service.rs | 3 --- 4 files changed, 9 insertions(+), 7 deletions(-) mode change 100644 => 100755 release.sh diff --git a/Cargo.toml b/Cargo.toml index 0247194..f20c083 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -21,9 +21,9 @@ url = { version = "2.5", features = ["serde"] } async-stream = "0.3" figment = { version = "0.10", features = ["env", "toml"] } serde = { version = "1.0", features = ["derive"] } -toml = "0.9.5" +toml = "0.9" thiserror = "2.0" tracing = "0.1" tracing-subscriber = { version = "0.3", features = ["env-filter", "fmt"] } -tracing-indicatif = "0.3.12" -indicatif = "0.18.0" +tracing-indicatif = "0.3" +indicatif = "0.18" diff --git a/release.sh b/release.sh old mode 100644 new mode 100755 diff --git a/src/main.rs b/src/main.rs index ce7c052..bc5b42d 100644 --- a/src/main.rs +++ b/src/main.rs @@ -21,7 +21,12 @@ async fn main() -> Result<(), ValidatorError> { tracing_subscriber::registry() .with(env_filter) - .with(tracing_subscriber::fmt::layer().with_writer(indicatif_layer.get_stderr_writer())) + .with( + tracing_subscriber::fmt::layer() + .with_writer(indicatif_layer.get_stderr_writer()) + .with_level(true) + .with_target(false), + ) .with(indicatif_layer) .init(); diff --git a/src/validation/validation_service.rs b/src/validation/validation_service.rs index 56642a2..fe692ec 100644 --- a/src/validation/validation_service.rs +++ b/src/validation/validation_service.rs @@ -8,7 +8,6 @@ use async_stream::stream; use futures::{pin_mut, stream::StreamExt}; use indicatif::ProgressStyle; use reqwest::Client; -use std::time::Instant; use tokio::{fs, io::AsyncWriteExt, sync::mpsc}; use tracing::{Span, error, info_span}; use tracing_indicatif::span_ext::IndicatifSpanExt; @@ -30,7 +29,6 @@ impl ValidationService { } pub async fn validate_keys(&self, keys: Vec) -> Result<(), ValidatorError> { - let start_time = Instant::now(); let total_keys = keys.len(); // Create channel for streaming keys from producer to consumer let (tx, mut rx) = mpsc::unbounded_channel::(); @@ -113,7 +111,6 @@ impl ValidationService { std::mem::drop(progress_span_enter); std::mem::drop(progress_span); - println!("Total Elapsed Time: {:?}", start_time.elapsed()); Ok(()) } }