From cab92df37eb3c9ad21f1ffb901d67a55d6a7f6ea Mon Sep 17 00:00:00 2001 From: donpat1to Date: Sat, 9 Aug 2025 22:08:04 +0200 Subject: [PATCH] removed drecks loop --- WatcherAgent/src/api.rs | 25 ++++++++++--------------- 1 file changed, 10 insertions(+), 15 deletions(-) diff --git a/WatcherAgent/src/api.rs b/WatcherAgent/src/api.rs index 87234aa..7374da2 100644 --- a/WatcherAgent/src/api.rs +++ b/WatcherAgent/src/api.rs @@ -124,7 +124,7 @@ pub async fn heartbeat_loop(base_url: &str, ip: &str) -> Result<(), Box { - println!("Heartbeat sent successfully."); + println!("✅ Heartbeat sent successfully."); } Ok(res) => eprintln!("Server responded with status: {}", res.status()), Err(e) => eprintln!("Heartbeat error: {}", e), @@ -140,20 +140,15 @@ pub async fn send_metrics( ) -> Result<(), Box> { let client = Client::new(); let url = format!("{}/monitoring/metric", base_url); - let mut interval = interval(Duration::from_secs(20)); - loop { - interval.tick().await; - let metric = metrics; - eprintln!("Sending metrics: {:?}", metric); - - match client.post(&url).json(&metric).send().await { - Ok(res) => println!( - "✅ Sent metrics for server {} | Status: {}", - metric.server_id, - res.status() - ), - Err(err) => eprintln!("❌ Failed to send metrics: {}", err), - } + match client.post(&url).json(&metrics).send().await { + Ok(res) => println!( + "✅ Sent metrics for server {} | Status: {}", + metrics.server_id, + res.status() + ), + Err(err) => eprintln!("❌ Failed to send metrics: {}", err), } + + Ok(()) }