diff --git a/WatcherAgent/src/main.rs b/WatcherAgent/src/main.rs index b2c0da0..a7595a0 100644 --- a/WatcherAgent/src/main.rs +++ b/WatcherAgent/src/main.rs @@ -166,16 +166,22 @@ async fn get_server_id_by_ip(base_url: &str, ip: &str) -> Result<(i32, String), return Ok((id_resp.id, id_resp.ip_address)); } Ok(resp) if resp.status() == StatusCode::NOT_FOUND => { - eprintln!("❌ Server with IP {} not found in database", ip); - return Err("Server not registered in database".into()); + println!( + "🔄 Server with IP {} not found in database (will retry in 30 seconds)", + ip + ); + sleep(Duration::from_secs(30)).await; } Ok(resp) => { - println!("⚠️ Server responded with status: {}", resp.status()); - sleep(Duration::from_secs(3)).await; + println!( + "⚠️ Server responded with status: {} (will retry in 30 seconds)", + resp.status() + ); + sleep(Duration::from_secs(30)).await; } Err(err) => { - println!("❌ Request failed: {}", err); - sleep(Duration::from_secs(3)).await; + println!("⚠️ Request failed: {} (will retry in 30 seconds)", err); + sleep(Duration::from_secs(30)).await; } } } @@ -185,18 +191,18 @@ async fn register_with_server(base_url: &str) -> Result<(i32, String), Box Result<(i32, String), Box { + println!("✅ Successfully registered with server."); + return Ok((server_id, registered_ip)); + } + Ok(resp) => { + let status = resp.status(); + let text = resp.text().await.unwrap_or_default(); + println!( + "⚠️ Registration failed ({}): {} (will retry in 30 seconds)", + status, text + ); + } + Err(err) => { + println!("⚠️ Registration error: {} (will retry in 30 seconds)", err); + } + } + sleep(Duration::from_secs(30)).await; } }