f

Author: tnull

src/gossip.rs

@@ -1,4 +1,4 @@
-use crate::logger::{log_error, log_info, FilesystemLogger, Logger};
+use crate::logger::{log_trace, FilesystemLogger, Logger};
 use crate::types::{GossipSync, NetworkGraph, P2PGossipSync, RapidGossipSync};
 use crate::Error;
 
@@ -60,23 +60,26 @@ impl GossipSource {
 			Self::RapidGossipSync { gossip_sync, server_url, latest_sync_timestamp, logger } => {
 				let query_timestamp = latest_sync_timestamp.load(Ordering::Acquire);
 				let query_url = format!("{}/{}", server_url, query_timestamp);
-				let response =
-					reqwest::get(query_url).await.map_err(|_| Error::GossipUpdateFailed)?;
+				let response = reqwest::get(query_url).await.map_err(|e| {
+					log_trace!(logger, "Failed to retrieve RGS gossip update: {}", e);
+					Error::GossipUpdateFailed
+				})?;
 
 				match response.error_for_status() {
 					Ok(res) => {
-						let update_data =
-							res.bytes().await.map_err(|_| Error::GossipUpdateFailed)?;
+						let update_data = res.bytes().await.map_err(|e| {
+							log_trace!(logger, "Failed to retrieve RGS gossip update: {}", e);
+							Error::GossipUpdateFailed
+						})?;
 
 						let new_latest_sync_timestamp = gossip_sync
 							.update_network_graph(&update_data)
 							.map_err(|_| Error::GossipUpdateFailed)?;
 						latest_sync_timestamp.store(new_latest_sync_timestamp, Ordering::Release);
-						log_info!(logger, "Successfully retrieved latest gossip update.");
 						Ok(())
 					}
 					Err(e) => {
-						log_error!(logger, "Failed to retrieve RGS gossip update: {}", e);
+						log_trace!(logger, "Failed to retrieve RGS gossip update: {}", e);
 						Err(Error::GossipUpdateFailed)
 					}
 				}