From 10b77f8635d2713a2b03b921721d19fa03bd6c65 Mon Sep 17 00:00:00 2001 From: Tiago Batista Cardoso Date: Sun, 25 Jan 2026 03:25:54 +0100 Subject: [PATCH] tidy --- client-gui/src/main.rs | 2 +- client-network/src/lib.rs | 28 ++++++++++------------------ 2 files changed, 11 insertions(+), 19 deletions(-) diff --git a/client-gui/src/main.rs b/client-gui/src/main.rs index ed372a1..5384f17 100644 --- a/client-gui/src/main.rs +++ b/client-gui/src/main.rs @@ -32,7 +32,7 @@ async fn main() -> eframe::Result<()> { eframe::run_native( "p2p-merkle client", options, - Box::new(|cc| { + Box::new(|_| { let app = P2PClientApp::new(network_cmd_tx, network_event_rx); Ok(Box::new(app)) }), diff --git a/client-network/src/lib.rs b/client-network/src/lib.rs index 9edbb55..a5b928f 100644 --- a/client-network/src/lib.rs +++ b/client-network/src/lib.rs @@ -576,14 +576,21 @@ pub fn start_p2p_executor( current.push(i); } } - let res = - event_tx.send(NetworkEvent::PeerListUpdated(peers)); + match event_tx.send(NetworkEvent::PeerListUpdated(peers)) { + Ok(_) => {} + Err(err) => { + println!( + "Network Event Error : {}", + err.to_string() + ); + } + }; } Err(e) => { eprintln!("invalid UTF-8 in socket address bytes: {}", e); } }, - Err(e) => println!("error"), + Err(e) => println!("error : {}", e), } } } @@ -595,25 +602,10 @@ pub fn start_p2p_executor( if let Some(sd) = shared_data.as_ref() { let id = generate_id(); sd.add_message(id, EventType::Ping); - let pingrequest = - construct_message(PING, Vec::new(), id, sd.cryptopair_ref()); let peer_address = get_socket_address(str.to_owned(), ip, shared_data.as_ref()).await; match peer_address { Ok(addr) => { - //if let Some(ping) = pingrequest { - // sd.senders_ref().add_message_to_retry_queue( - // ping.clone(), - // addr.to_string(), - // false, - // ); - // sd.senders_ref().send_dispatch( - // ping, - // addr.to_string(), - // false, - // sd.messages_list(), - // ); - //} match event_tx.send(NetworkEvent::Success( format!( "Successfully sent ping message to {}.",