Ollo/MqttRnvPublisher
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Interval in seconds between departure data fetches (default: 300)

Browse Source
This commit is contained in:
Ollo
2026-02-28 20:53:02 +01:00
parent 98b72736ee
commit b5fa9dd5ec
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
README.md
View File

@@ -25,6 +25,7 @@ Or run the binary directly:
- `broker`: MQTT broker address (default: `localhost`) - `broker`: MQTT broker address (default: `localhost`)
- `port`: MQTT broker port (default: `1883`) - `port`: MQTT broker port (default: `1883`)
- `interval`: Interval in seconds between departure data fetches (default: `300`)
## Configuration ## Configuration

6
src/main.rs
View File

@@ -13,7 +13,7 @@ struct Args {
#[arg(default_value_t = 1883)] #[arg(default_value_t = 1883)]
port: u16, port: u16,
#[arg(default_value_t = 30000)] #[arg(default_value_t = 300)]
interval: u32, interval: u32,
} }
@@ -33,7 +33,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
let mut last_request = Instant::now(); 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))) let mut departure_data = tokio::task::spawn_blocking(|| straba::fetch_data(Some(true)))
.await .await
.unwrap(); .unwrap();
@@ -44,7 +44,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
if now.duration_since(last_request) > interval { if now.duration_since(last_request) > interval {
data_published = false; data_published = false;
last_request = Instant::now(); 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 .await
.unwrap(); .unwrap();
if departure_data.failure { if departure_data.failure {