diff --git a/README.md b/README.md index 4743fec..75afbc9 100644 --- a/README.md +++ b/README.md @@ -25,6 +25,7 @@ Or run the binary directly: - `broker`: MQTT broker address (default: `localhost`) - `port`: MQTT broker port (default: `1883`) +- `interval`: Interval in seconds between departure data fetches (default: `300`) ## Configuration diff --git a/src/main.rs b/src/main.rs index 433e251..62f2588 100644 --- a/src/main.rs +++ b/src/main.rs @@ -13,7 +13,7 @@ struct Args { #[arg(default_value_t = 1883)] port: u16, - #[arg(default_value_t = 30000)] + #[arg(default_value_t = 300)] interval: u32, } @@ -33,7 +33,7 @@ async fn main() -> Result<(), Box> { let mut last_request = Instant::now(); - let interval = Duration::from_millis(args.interval as u64); + let interval = Duration::from_secs(args.interval as u64); let mut departure_data = tokio::task::spawn_blocking(|| straba::fetch_data(Some(true))) .await .unwrap(); @@ -44,7 +44,7 @@ async fn main() -> Result<(), Box> { if now.duration_since(last_request) > interval { data_published = false; last_request = Instant::now(); - let mut departure_data = tokio::task::spawn_blocking(|| straba::fetch_data(Some(false))) + departure_data = tokio::task::spawn_blocking(|| straba::fetch_data(Some(false))) .await .unwrap(); if departure_data.failure {