tidy

client-gui/src/gui_app.rs

@@ -1,18 +1,16 @@
 use client_network::{
     ChunkNode, MerkleNode, MerkleTree, NetworkCommand, NetworkEvent, NodeHash,
-    big_or_chunk_to_file, filename_to_string, generate_base_tree, node_hash_to_hex_string,
+    big_or_chunk_to_file, generate_base_tree, node_hash_to_hex_string, remove_null_bytes,
-    node_to_file, remove_null_bytes,
 };
 use crossbeam_channel::{Receiver, Sender};
 use egui::{
-    Align, CentralPanel, CollapsingHeader, Color32, Context, CornerRadius, Frame, Layout,
+    Align, CentralPanel, CollapsingHeader, Color32, Context, CornerRadius, Frame, Id, Layout,
-    ProgressBar, Response, ScrollArea, SidePanel, Stroke, TopBottomPanel, Ui, Vec2,
+    ProgressBar, ScrollArea, SidePanel, Stroke, TopBottomPanel, Ui, ViewportCommand,
-    ViewportCommand,
 };
+use std::collections::HashMap;
 use std::collections::HashSet;
-use std::{collections::HashMap, fmt::format, io::Seek};
 
-use std::fs::{File, OpenOptions, create_dir};
+use std::fs::{OpenOptions, create_dir};
 
 enum ServerStatus {
     Loading,
@@ -21,24 +19,19 @@ enum ServerStatus {
     ConnectedHandshake,
 }
 
-// --- Main Application Struct ---
 pub struct P2PClientApp {
     remaining: std::time::Duration,  // temps restant
     last_update: std::time::Instant, // pour calculer delta
     timer_started: bool,
-    // Communication channels
     network_cmd_tx: Sender<NetworkCommand>,
     network_event_rx: Receiver<NetworkEvent>,
 
-    // GUI State
-    status_message: String,
     known_peers: Vec<(String, bool)>,
     loading_peers: Vec<String>,
     connect_address_input: String,
     connected_address: String,
     connect_name_input: String,
 
-    // Key: Parent Directory Hash (String), Value: List of children FileNode
     loaded_fs: HashMap<String, MerkleTree>,
     shared_tree: MerkleTree,
 
@@ -47,8 +40,6 @@ pub struct P2PClientApp {
 
     server_status: ServerStatus,
 
-    show_network_popup: bool, // gérer selon besoin
-
     error_message: Option<(String, String)>, // Some(message) -> afficher, None -> rien
     success_message: Option<(String, String)>, // Some(message) -> afficher, None -> rien
     active_server: String,
@@ -63,16 +54,14 @@ pub struct P2PClientApp {
     current_received_chunks: usize,
 
     root_downloading_file: String,
+    show_network_window: bool,
+    show_choose_server_window: bool,
 }
 
 impl P2PClientApp {
     pub fn new(cmd_tx: Sender<NetworkCommand>, event_rx: Receiver<NetworkEvent>) -> Self {
-        //let (root_hash, tree_content) = MerkleNode::generate_base_tree();
+        let loaded_fs = HashMap::new();
-
+        let current_downloading_file_map = MerkleTree::new(HashMap::new(), [0; 32]);
-        let mut loaded_fs = HashMap::new();
-        let mut current_downloading_file_map = MerkleTree::new(HashMap::new(), [0; 32]);
-        //let tree = MerkleTree::new(tree_content, root_hash);
-        //loaded_fs.insert("bob".to_string(), tree);
 
         Self {
             remaining: std::time::Duration::from_secs(0),
@@ -80,7 +69,6 @@ impl P2PClientApp {
             last_update: std::time::Instant::now(),
             network_cmd_tx: cmd_tx,
             network_event_rx: event_rx,
-            status_message: "Client Initialized. Awaiting network status...".to_string(),
             known_peers: Vec::new(),
             loading_peers: Vec::new(),
             connect_address_input: "https://jch.irif.fr:8443".to_string(),
@@ -88,7 +76,6 @@ impl P2PClientApp {
             loaded_fs,
             active_peer: None,
             server_status: ServerStatus::NotConnected,
-            show_network_popup: false,
             error_message: None,
             success_message: None,
             connect_name_input: "bob".to_string(),
@@ -99,6 +86,8 @@ impl P2PClientApp {
             current_received_chunks: 0,
             root_downloading_file: "".to_string(),
             remaining_chunks: HashSet::new(),
+            show_network_window: false,
+            show_choose_server_window: false,
         }
     }
     pub fn show_error(&mut self, msg: impl Into<String>, peer_username: impl Into<String>) {
@@ -113,18 +102,8 @@ impl P2PClientApp {
     pub fn clear_success(&mut self) {
         self.success_message = None;
     }
-
-    fn set_current_total_chunks(&mut self, len: Option<usize>) {
-        self.current_total_chunks = len
-    }
-
-    fn set_current_received_chunks(&mut self, arg: usize) {
-        self.current_received_chunks = arg
-    }
 }
 
-// --- eframe::App Trait Implementation ---
-
 impl eframe::App for P2PClientApp {
     fn update(&mut self, ctx: &Context, _frame: &mut eframe::Frame) {
         if matches!(self.server_status, ServerStatus::Connected) && !self.timer_started {
@@ -133,7 +112,6 @@ impl eframe::App for P2PClientApp {
             self.timer_started = true;
         }
 
-        // in update (every frame)
         let now = std::time::Instant::now();
         let delta = now.saturating_duration_since(self.last_update);
         self.last_update = now;
@@ -144,18 +122,8 @@ impl eframe::App for P2PClientApp {
             self.remaining = self.remaining.saturating_sub(delta);
         }
 
-        // 1. Process incoming Network Events
-        // We poll the channel and update the GUI state for every event received.
         while let Ok(event) = self.network_event_rx.try_recv() {
             match event {
-                NetworkEvent::PeerConnected(addr) => {
-                    todo!();
-
-                    self.status_message = format!("✅ Peer connected: {}", addr);
-                    if !self.known_peers.contains(&(addr, true)) {
-                        self.known_peers.push((addr, true));
-                    }
-                }
                 NetworkEvent::RootRequest(addr) => {
                     let root = self.shared_tree.root;
                     let _ = self
@@ -181,8 +149,6 @@ impl eframe::App for P2PClientApp {
                     }
                 }
                 NetworkEvent::PeerListUpdated(peers) => {
-                    //todo!();
-
                     self.known_peers = peers;
                 }
 
@@ -222,14 +188,6 @@ impl eframe::App for P2PClientApp {
                     }
                 }
                 NetworkEvent::FileTreeRootReceived(peer_id, root_hash) => {
-                    // todo!();
-
-                    /*self.status_message = format!(
-                        "🔄 Received Merkle Root from {}: {}",
-                        peer_id,
-                        &root_hash[..8]
-                    );*/
-
                     if let Ok(chunknode) = ChunkNode::new(Vec::new()) {
                         let data_map: HashMap<NodeHash, MerkleNode> = HashMap::new();
                         //data_map.insert(root_hash, MerkleNode::Chunk(chunknode));
@@ -248,17 +206,11 @@ impl eframe::App for P2PClientApp {
 
                         println!("tree created");
                     }
-
-                    //self.active_peer_id = Some(peer_id.clone());
-
-                    // Request the content of the root directory immediately
-                    /*let _ = self
-                    .network_cmd_tx
-                    .send(NetworkCommand::RequestDirectoryContent(peer_id, root_hash));*/
                 }
                 NetworkEvent::Connected(ip) => {
                     self.server_status = ServerStatus::Connected;
                     self.connected_address = ip.clone();
+                    self.show_choose_server_window = true;
                     let _ = self.network_cmd_tx.send(NetworkCommand::FetchPeerList(
                         self.connected_address.clone(),
                     ));
@@ -309,11 +261,11 @@ impl eframe::App for P2PClientApp {
                                     true,
                                 ));
                                 self.remaining_chunks.insert(entry);
-                                self.set_current_total_chunks(Some(self.remaining_chunks.len()));
+                                self.current_total_chunks = Some(self.remaining_chunks.len());
                             }
                             self.remaining_chunks.remove(&hash);
                         }
-                        MerkleNode::Chunk(chunk) => {
+                        MerkleNode::Chunk(_) => {
                             self.remaining_chunks.remove(&hash);
                         }
                         _ => {}
@@ -326,29 +278,6 @@ impl eframe::App for P2PClientApp {
                     }
 
                     if self.remaining_chunks.is_empty() {
-                        /*let file = OpenOptions::new()
-                            .append(true)
-                            .create(true)
-                            .open(self.root_downloading_file.clone());
-
-                        if let Some(current) = self
-                            .current_downloading_file_map
-                            .data
-                            .get(&self.current_downloading_file_map.root)
-                        {
-                            match file {
-                                Ok(mut fileok) => {
-                                    big_or_chunk_to_file(
-                                        &self.current_downloading_file_map,
-                                        current,
-                                        &mut fileok,
-                                    );
-                                }
-                                Err(e) => {
-                                    eprintln!("error creaation file: {}", e);
-                                }
-                            }
-                        }*/
                         self.current_total_chunks = None;
                         self.current_received_chunks = 0;
                         println!("bigfile téléchargé");
@@ -364,26 +293,115 @@ impl eframe::App for P2PClientApp {
                     self.server_status = ServerStatus::NotConnected;
                     let err_msg = format!("Failed to connect to the server: {}", err);
                     self.show_error(err_msg, "");
-                    let res = self.network_cmd_tx.send(NetworkCommand::ResetServerPeer());
+                    match self.network_cmd_tx.send(NetworkCommand::ResetServerPeer()) {
+                        Ok(_) => {}
+                        Err(err) => {
+                            println!("GUI Error : {}", err.to_string());
+                        }
+                    };
                 }
             }
         }
 
+        if self.show_choose_server_window {
+            let full_rect = ctx.input(|i| i.content_rect());
+            let modal_size = egui::vec2(400.0, 160.0);
+
+            egui::Area::new(Id::new("modal_blocker_bg"))
+                .order(egui::Order::Background)
+                .show(ctx, |ui| {
+                    let painter = ui.painter();
+                    painter.rect_filled(full_rect, 0.0, egui::Color32::from_black_alpha(160));
+
+                    let sense = egui::Sense::click_and_drag();
+                    ui.allocate_exact_size(full_rect.size(), sense);
+                });
+            egui::Window::new("Choose the server")
+                .resizable(false)
+                .collapsible(false)
+                .title_bar(true)
+                .anchor(egui::Align2::CENTER_CENTER, egui::Vec2::ZERO)
+                .fixed_size(modal_size)
+                .show(ctx, |ui| {
+                    ScrollArea::vertical()
+                        .auto_shrink([false; 2])
+                        .show(ui, |ui| {
+                            ui.style_mut().visuals.widgets.inactive.bg_fill =
+                                ui.style().visuals.widgets.inactive.bg_fill; // no-op to get mutable borrow
+                            if self.known_peers.is_empty() {
+                                ui.add_space(10.0);
+                                ui.label("No active peers.");
+                            } else {
+                                for peer in &self.known_peers {
+                                    let is_active =
+                                        self.active_peer.as_ref().map_or(false, |id| id == &peer.0); // if peer.id == self.active_peer_id
+
+                                    // place spinner to the right of the label
+                                    ui.horizontal(|ui| {
+                                        // Use same width for the label widget as the selectable we already created:
+                                        // Recreate selectable inline so both label and spinner share the same row.
+                                        let resp = if &self.active_server == &peer.0 {
+                                            // draw with frame inline
+                                            let frame = Frame {
+                                                fill: Color32::DARK_BLUE,
+                                                stroke: Stroke::default(),
+                                                corner_radius: CornerRadius::from(0.5),
+                                                ..Default::default()
+                                            };
+                                            frame
+                                                .show(ui, |ui| {
+                                                    ui.selectable_label(
+                                                        is_active,
+                                                        format!("{}", peer.0),
+                                                    )
+                                                })
+                                                .inner
+                                        } else {
+                                            ui.selectable_label(is_active, format!("{}", peer.0))
+                                        };
+
+                                        ui.add_space(4.0); // small gap
+
+                                        // use resp (click handling etc.)
+                                        if resp.clicked() {
+                                            self.active_server = peer.0.to_string();
+                                            match self.network_cmd_tx.send(
+                                                NetworkCommand::ServerHandshake(
+                                                    peer.0.to_string(),
+                                                    self.connected_address.clone(),
+                                                ),
+                                            ) {
+                                                Ok(_) => {}
+                                                Err(e) => {
+                                                    println!("GUI Error : {}", e.to_string());
+                                                }
+                                            };
+                                            ui.close();
+                                            self.show_choose_server_window = false;
+                                        }
+                                    });
+                                }
+                            }
+                        });
+                });
+        }
+
         // 2. Menu Bar
         TopBottomPanel::top("top_panel").show(ctx, |ui| {
             egui::MenuBar::new().ui(ui, |ui| {
                 ui.menu_button("File", |ui| {
-                    if ui.button("Settings").clicked() {
+                    if ui.button("Settings").clicked() {}
-                        //show settings
-                    }
 
                     if ui.button("Quit").clicked() {
-                        // Use ViewportCommand to request a close
                         ctx.send_viewport_cmd(ViewportCommand::Close);
                     }
                 });
 
-                ui.menu_button("Network", |ui| {
+                if ui.button("Network").clicked() {
+                    self.show_network_window = true;
+                }
+
+                if self.show_network_window {
                     match self.server_status {
                         ServerStatus::Connected | ServerStatus::ConnectedHandshake => {
                             let desired = egui::vec2(300.0, 0.0); // width 300, auto-height if 0
@@ -395,36 +413,42 @@ impl eframe::App for P2PClientApp {
                                     self.server_status = ServerStatus::NotConnected;
                                     self.remaining = std::time::Duration::from_secs(0);
                                     self.timer_started = false;
-                                    ui.close();
+                                    self.show_network_window = false;
                                 }
                             });
                         }
                         ServerStatus::NotConnected => {
-                            let desired = egui::vec2(0.0, 0.0); // width 300, auto-height if 0
+                            egui::Window::new("Network")
-                            ui.set_min_size(desired);
+                                .resizable(false)
-                            ui.vertical(|ui| {
+                                .show(ctx, |ui| {
-                                ui.horizontal(|ui| {
+                                    ui.horizontal(|ui| {
-                                    ui.label("Server IP:");
+                                        ui.label("Server IP:");
-                                    ui.text_edit_singleline(&mut self.connect_address_input);
+                                        ui.text_edit_singleline(&mut self.connect_address_input);
+                                    });
+                                    ui.horizontal(|ui| {
+                                        ui.label("Name:");
+                                        ui.text_edit_singleline(&mut self.connect_name_input);
+                                    });
+                                    if ui.button("Connect").clicked() {
+                                        let addr = self.connect_address_input.clone();
+                                        let name = self.connect_name_input.clone();
+                                        let _ = self.network_cmd_tx.send(
+                                            NetworkCommand::ConnectToServerPut(
+                                                addr,
+                                                name.to_string(),
+                                            ),
+                                        );
+                                        self.server_status = ServerStatus::Loading;
+                                        ui.close();
+                                        self.show_network_window = false;
+                                        self.loaded_fs
+                                            .insert(name.to_string(), self.shared_tree.clone());
+                                    }
                                 });
-                                ui.horizontal(|ui| {
-                                    ui.label("Name:");
-                                    ui.text_edit_singleline(&mut self.connect_name_input);
-                                });
-                                if ui.button("Connect").clicked() {
-                                    let addr = self.connect_address_input.clone();
-                                    let name = self.connect_name_input.clone();
-                                    let _ = self
-                                        .network_cmd_tx
-                                        .send(NetworkCommand::ConnectToServerPut(addr, name));
-                                    self.server_status = ServerStatus::Loading;
-                                    ui.close();
-                                }
-                            });
                         }
                         _ => {}
                     }
-                });
+                }
             });
         });
 
@@ -502,92 +526,69 @@ impl eframe::App for P2PClientApp {
                             for peer in &self.known_peers {
                                 let is_active =
                                     self.active_peer.as_ref().map_or(false, |id| id == &peer.0); // if peer.id == self.active_peer_id
-
+                                //
-                                let selectable: Response;
+                                if peer.0.eq(&self.connect_name_input) {
-                                // if &self.active_server == &peer.0 {
+                                    ui.horizontal(|ui| {
-                                //     // Create a frame with green background and render the selectable inside it.
+                                        let resp = ui.selectable_label(
-                                //     // Adjust rounding, padding and stroke as desired.
+                                            is_active,
-                                //     let frame = Frame {
+                                            format!("{} (you)", peer.0),
-                                //         fill: Color32::DARK_BLUE,
-                                //         stroke: Stroke::default(),
-                                //         corner_radius: CornerRadius::from(0.5),
-                                //         ..Default::default()
-                                //     };
-                                //     let internal = frame.show(ui, |ui| {
-                                //         // horizontal row: label on the left, spinner on the right
-                                //         ui.horizontal(|ui| {
-                                //             // let selectable label take remaining space
-                                //             ui.with_layout(Layout::left_to_right(Align::Center), |ui| {
-                                //                 ui.add_space(0.0); // ensure layout established
-                                //                 return ui.selectable_label(
-                                //                     is_active,
-                                //                     format!("{}", peer.0),
-                                //                 );
-                                //             })
-                                //             .inner // return Response from the inner closure if your egui version does so
-                                //         })
-                                //     });
-                                //     selectable = internal.inner.inner;
-                                // } else {
-                                //     selectable = ui.selectable_label(is_active, format!("{}", peer.0));
-                                // }
-
-                                // place spinner to the right of the label
-                                ui.horizontal(|ui| {
-                                    // Use same width for the label widget as the selectable we already created:
-                                    // Recreate selectable inline so both label and spinner share the same row.
-                                    let resp = if &self.active_server == &peer.0 {
-                                        // draw with frame inline
-                                        let frame = Frame {
-                                            fill: Color32::DARK_BLUE,
-                                            stroke: Stroke::default(),
-                                            corner_radius: CornerRadius::from(0.5),
-                                            ..Default::default()
-                                        };
-                                        frame
-                                            .show(ui, |ui| {
-                                                ui.selectable_label(
-                                                    is_active,
-                                                    format!("{}", peer.0),
-                                                )
-                                            })
-                                            .inner
-                                    } else {
-                                        ui.selectable_label(is_active, format!("{}", peer.0))
-                                    };
-
-                                    ui.add_space(4.0); // small gap
-
-                                    if self.loading_peers.contains(&peer.0) {
-                                        // push spinner to right by expanding a spacer before it
-                                        ui.with_layout(
-                                            Layout::right_to_left(Align::Center),
-                                            |ui| {
-                                                ui.spinner();
-                                            },
                                         );
-                                    }
 
-                                    // use resp (click handling etc.)
+                                        if resp.clicked() {
-                                    if resp.clicked() {
+                                            self.active_peer = Some(peer.0.clone());
-                                        // switch to displaying this peer's tree
-                                        self.active_peer = Some(peer.0.clone());
-                                        // Request root content if not loaded
-                                        if !self
-                                            .loaded_fs
-                                            .contains_key(self.active_peer.as_ref().unwrap())
-                                        {
-                                            //todo!();
-                                            let _ =
-                                                self.network_cmd_tx.send(NetworkCommand::Discover(
-                                                    peer.0.clone(),
-                                                    "root".to_string(),
-                                                    self.connected_address.clone(),
-                                                ));
                                         }
-                                    }
+                                    });
-                                    resp.context_menu(|ui| {
+                                } else {
-                                    // ... action
+                                    // place spinner to the right of the label
+                                    ui.horizontal(|ui| {
+                                        let resp = if &self.active_server == &peer.0 {
+                                            let frame = Frame {
+                                                fill: Color32::DARK_BLUE,
+                                                stroke: Stroke::default(),
+                                                corner_radius: CornerRadius::from(0.5),
+                                                ..Default::default()
+                                            };
+                                            frame
+                                                .show(ui, |ui| {
+                                                    ui.selectable_label(
+                                                        is_active,
+                                                        format!("{}", peer.0),
+                                                    )
+                                                })
+                                                .inner
+                                        } else {
+                                            ui.selectable_label(is_active, format!("{}", peer.0))
+                                        };
+
+                                        ui.add_space(4.0); // small gap
+
+                                        if self.loading_peers.contains(&peer.0) {
+                                            ui.with_layout(
+                                                Layout::right_to_left(Align::Center),
+                                                |ui| {
+                                                    ui.spinner();
+                                                },
+                                            );
+                                        }
+
+                                        if resp.clicked() {
+                                            self.active_peer = Some(peer.0.clone());
+                                            // Request root content if not loaded
+                                            if !self
+                                                .loaded_fs
+                                                .contains_key(self.active_peer.as_ref().unwrap())
+                                            {
+                                                //todo!();
+                                                let _ = self.network_cmd_tx.send(
+                                                    NetworkCommand::Discover(
+                                                        peer.0.clone(),
+                                                        "root".to_string(),
+                                                        self.connected_address.clone(),
+                                                    ),
+                                                );
+                                            }
+                                        }
+                                        resp.context_menu(|ui| {
                                     match self.server_status {
                                         ServerStatus::Connected => {
                                             if ui
@@ -595,12 +596,17 @@ impl eframe::App for P2PClientApp {
                                                 .clicked()
                                             {
                                                 self.active_server = peer.0.to_string();
-                                                let res = self.network_cmd_tx.send(
+                                                match self.network_cmd_tx.send(
                                                     NetworkCommand::ServerHandshake(
                                                         peer.0.to_string(),
                                                         self.connected_address.clone(),
                                                     ),
-                                                );
+                                                ) {
+                                                Ok(_) => {}
+                                                Err(e) => {
+                                                    println!("GUI Error : {}", e.to_string());
+                                                },
+                                                };
                                             }
                                         }
                                         _ => {}
@@ -637,75 +643,8 @@ impl eframe::App for P2PClientApp {
 
                                     // ... autres boutons
                                 });
-                                });
+                                    });
-
+                                }
-                                // if self.loading_peers.contains(&peer.0) {
-                                //     ui.spinner();
-                                // }
-
-                                //if selectable.clicked() {
-                                // switch to displaying this peer's tree
-                                //self.active_peer = Some(peer.0.clone());
-                                //// Request root content if not loaded
-                                //if !self
-                                //    .loaded_fs
-                                //    .contains_key(self.active_peer.as_ref().unwrap())
-                                //{
-                                //    //todo!();
-                                //    let _ = self.network_cmd_tx.send(NetworkCommand::Discover(
-                                //        peer.0.clone(),
-                                //        "root".to_string(),
-                                //        self.connected_address.clone(),
-                                //    ));
-                                //}
-                                //}
-                                //selectable.context_menu(|ui| {
-                                //    // ... action
-                                //    match self.server_status {
-                                //        ServerStatus::Connected => {
-                                //            if ui
-                                //                .button("Utiliser le peer en tant que serveur")
-                                //                .clicked()
-                                //            {
-                                //                self.active_server = peer.0.to_string();
-                                //                let res = self.network_cmd_tx.send(
-                                //                    NetworkCommand::ServerHandshake(
-                                //                        peer.0.to_string(),
-                                //                        self.connected_address.clone(),
-                                //                    ),
-                                //                );
-                                //            }
-                                //        }
-                                //        _ => {}
-                                //    }
-                                //    if ui.button("Send Ping").clicked() {
-                                //        let res = self.network_cmd_tx.send(NetworkCommand::Ping(
-                                //            peer.0.to_string(),
-                                //            self.connected_address.clone(),
-                                //        ));
-
-                                //        self.loading_peers.push(peer.0.to_owned());
-                                //    }
-                                //    if ui.button("Send Nat Traversal Request").clicked() {
-                                //        match self.network_cmd_tx.send(NetworkCommand::NatTraversal(
-                                //            peer.0.to_string(),
-                                //            self.connected_address.clone(),
-                                //        )) {
-                                //            Ok(_) => {
-                                //                print!("[+] successfully sent nat traversal request")
-                                //            }
-                                //            Err(_) => {
-                                //                print!("[-] failed to send nat traversal request")
-                                //            }
-                                //        }
-                                //    }
-                                //    if ui.button("Infos").clicked() {
-                                //        // action 3
-                                //        ui.close();
-                                //    }
-
-                                //    // ... autres boutons
-                                //});
                             }
                         }
                     });

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))
         }),

client-network/src/lib.rs

@@ -196,7 +196,6 @@ pub enum NetworkEvent {
     Disconnected(),
     Error(String, String),
     Success(String, String),
-    PeerConnected(String),
     PeerListUpdated(Vec<(String, bool)>),
     FileTreeReceived([u8; 32], MerkleNode, String), // peer_id, content
     DataReceived([u8; 32], MerkleNode, String),
@@ -577,14 +576,21 @@ pub fn start_p2p_executor(
                                                 current.push(i);
                                             }
                                         }
-                                        let res =
+                                        match event_tx.send(NetworkEvent::PeerListUpdated(peers)) {
-                                            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),
                             }
                         }
                     }
@@ -596,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 {}.",

rapport.txt

@@ -0,0 +1 @@
+https://docs.google.com/document/d/1emhrAfjJyJTWpBYx4IJGcCz0_iLVjDRAAdq2EZFchKo/edit?usp=sharing