X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Ftracking.rs;h=901339c3286ad22d156f5b5d85c486377d2027b4;hb=4c20eda0cf43a80d27bbcb66423225c7c072753a;hp=c8d6bac888bf5f292ad624d6e521cc3623dfd561;hpb=a9e129c3dcd0ce5b036fe6dd7e170450627be705;p=rapid-gossip-sync-server diff --git a/src/tracking.rs b/src/tracking.rs index c8d6bac..901339c 100644 --- a/src/tracking.rs +++ b/src/tracking.rs @@ -5,8 +5,8 @@ use std::ops::Deref; use std::sync::Arc; use std::time::{Duration, Instant}; -use bitcoin::hashes::hex::ToHex; use bitcoin::secp256k1::PublicKey; +use hex_conservative::display::DisplayHex; use lightning::ln::peer_handler::{ ErroringMessageHandler, IgnoringMessageHandler, MessageHandler, PeerManager, }; @@ -167,7 +167,8 @@ async fn connect_peer(current_peer: (P // we seek to find out if the first connection attempt was successful let (sender, mut receiver) = mpsc::channel::(1); tokio::spawn(async move { - log_info!(logger, "Connecting to peer {}@{}...", current_peer.0.to_hex(), current_peer.1.to_string()); + let current_peer_pubkey_hex = current_peer.0.serialize().to_lower_hex_string(); + log_info!(logger, "Connecting to peer {}@{}...", current_peer_pubkey_hex, current_peer.1); let mut is_first_iteration = true; loop { if let Some(disconnection_future) = lightning_net_tokio::connect_outbound( @@ -175,21 +176,21 @@ async fn connect_peer(current_peer: (P current_peer.0, current_peer.1, ).await { - log_info!(logger, "Connected to peer {}@{}!", current_peer.0.to_hex(), current_peer.1.to_string()); + log_info!(logger, "Connected to peer {}@{}!", current_peer_pubkey_hex, current_peer.1); if is_first_iteration { sender.send(true).await.unwrap(); } disconnection_future.await; - log_warn!(logger, "Disconnected from peer {}@{}", current_peer.0.to_hex(), current_peer.1.to_string()); + log_warn!(logger, "Disconnected from peer {}@{}", current_peer_pubkey_hex, current_peer.1); } else { - log_warn!(logger, "Failed to connect to peer {}@{}!", current_peer.0.to_hex(), current_peer.1.to_string()); + log_warn!(logger, "Failed to connect to peer {}@{}!", current_peer_pubkey_hex, current_peer.1); if is_first_iteration { sender.send(false).await.unwrap(); } } is_first_iteration = false; tokio::time::sleep(Duration::from_secs(10)).await; - log_warn!(logger, "Reconnecting to peer {}@{}...", current_peer.0.to_hex(), current_peer.1.to_string()); + log_warn!(logger, "Reconnecting to peer {}@{}...", current_peer_pubkey_hex, current_peer.1); } });