donpat1to/watcheragent
1
0
Fork 0
Code Issues 8 Pull Requests Actions Packages Projects 1 Releases 1 Wiki Activity

fixed IpAddress matching Payload on Server

Browse Source
This commit is contained in:
Patrick Mahnke-Hartmann
2025-07-30 00:49:27 +02:00
parent ccf2f46abd
commit 5d99d33433
1 changed files with 16 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
WatcherAgent/src/main.rs
View File

@@ -159,7 +159,14 @@ async fn get_server_id_by_ip(base_url: &str, ip: &str) -> Result<(i32, String),
println!("Attempting to fetch server ID for IP {}...", ip);
match client.get(&url).send().await {
Ok(resp) if resp.status().is_success() => {
let id_resp: IdResponse = resp.json().await?;
let text = resp.text().await?;
println!("Raw response: {}", text); // Debug output
let id_resp: IdResponse = serde_json::from_str(&text).map_err(|e| {
println!("Failed to parse response: {}", e);
e
})?;
println!(
"✅ Received ID {} for IP {}",
id_resp.id, id_resp.ip_address
@@ -168,21 +175,23 @@ async fn get_server_id_by_ip(base_url: &str, ip: &str) -> Result<(i32, String),
}
Ok(resp) if resp.status() == StatusCode::NOT_FOUND => {
println!(
"🔄 Server with IP {} not found in database (will retry in 30 seconds)",
"❌ Server with IP {} not found in database (will retry in 30 seconds)",
ip
);
sleep(Duration::from_secs(30)).await;
sleep(Duration::from_secs(10)).await;
}
Ok(resp) => {
//let text = resp.text().await?;
println!(
"⚠️ Server responded with status: {} (will retry in 30 seconds)",
resp.status()
"⚠️ Server responded with status: {} - {}",
resp.status(),
resp.text().await?
);
sleep(Duration::from_secs(30)).await;
sleep(Duration::from_secs(10)).await;
}
Err(err) => {
println!("⚠️ Request failed: {} (will retry in 30 seconds)", err);
sleep(Duration::from_secs(30)).await;
sleep(Duration::from_secs(10)).await;
}
}
}