big download fixed

client-gui/src/gui_app.rs

@@ -262,6 +262,7 @@ impl eframe::App for P2PClientApp {
                     if let Some(addr) = &self.active_peer {
                         if let Some(roottree) = self.loaded_fs.get(addr) {
                             if let Some(root) = roottree.data.get(&hash) {
+                                self.current_downloading_file_map.root = hash;
                                 self.root_downloading_file = name;
                                 let _ = self
                                     .current_downloading_file_map
@@ -299,11 +300,12 @@ impl eframe::App for P2PClientApp {
                         }
                         _ => {}
                     }
+                    println!("remaining chunks size: {}", self.remaining_chunks.len());
                     if self.remaining_chunks.is_empty() {
-                        /*let file = OpenOptions::new()
-                            .append(true)
-                            .create(true)
-                            .open(self.root_downloading_file.clone());
+                        let file = OpenOptions::new().append(true).create(true).open(
+                            "./Download/".to_string()
+                                + &remove_null_bytes(&self.root_downloading_file.clone()),
+                        );
 
                         if let Some(current) = self
                             .current_downloading_file_map
@@ -322,8 +324,10 @@ impl eframe::App for P2PClientApp {
                                     eprintln!("error creaation file: {}", e);
                                 }
                             }
-                        }*/
-                        println!("bigfile téléchargé");
+                        } else {
+                            eprintln!("error root absent");
+                        }
+                        println!("bigfile téléchargé {}", self.root_downloading_file);
                     }
                 }
                 NetworkEvent::Success(msg, peer_username) => {

client-network/src/data.rs

@@ -473,8 +473,15 @@ pub fn big_or_chunk_to_file(tree: &MerkleTree, node: &MerkleNode, file: &mut Fil
             }
         }
         MerkleNode::Chunk(chunk) => {
-            println!("wrote data");
-            let _ = file.write_all(&chunk.data);
+            if !chunk.data.is_empty() {
+                // Enlève le premier élément
+                let mut data = chunk.data.clone(); // Clone pour éviter de modifier l'original
+                data.remove(0); // Enlève le premier élément
+                println!("wrote data {:?}", data);
+                let _ = file.write(&data);
+            } else {
+                println!("chunk.data is empty, nothing to write");
+            }
         }
         _ => {
             println!("invalid type of file");

client-network/src/datum_parsing.rs

@@ -11,84 +11,103 @@ pub fn parse_received_datum(
     datum_length: usize,
 ) -> Option<([u8; 32], MerkleNode)> {
     let hash_name: [u8; 32] = recevied_datum[..32].try_into().expect("error");
-    let value = &recevied_datum[32..recevied_datum.len()];
+    let value = &recevied_datum[32..datum_length];
     let value_slice = value.to_vec();
     println!("valueslice: {:?}, {}", value_slice, value_slice.len());
-    let datum_type = value_slice[0];
-    match datum_type {
-        CHUNK => Some((
-            hash_name,
-            MerkleNode::Chunk(crate::ChunkNode { data: value_slice }),
-        )),
-        DIRECTORY => {
-            let mut dir_entries = Vec::new();
-            let mut offset = 1 as usize;
-            for i in 0..((value_slice.len() - 1) / 64) as u8 {
-                offset = (1 + 64 * i as usize) as usize;
-                println!("offset:{}, i:{}", offset, i);
-                let name = &value_slice[offset..offset + 32];
-                let mut hash = [0u8; 32];
-                hash.copy_from_slice(&value_slice[offset + 32..offset + 64]);
-                let dp_name = String::from_utf8(name.to_vec()).expect("err");
-                println!("name:{}", dp_name);
 
-                // envoyer un datum request
-                dir_entries.push(DirectoryEntry {
-                    filename: name.try_into().expect("incorrect size"),
-                    content_hash: hash,
-                });
-            }
+    println!(
+        "((value_slice.len() - 1) / 32) {} ",
+        ((value_slice.len() - 1) / 32)
+    );
+    // Créer une instance de Sha256
+    let mut hasher = Sha256::new();
 
-            let current = DirectoryNode::new(dir_entries);
-            match current {
-                Ok(current_node) => Some((hash_name, MerkleNode::Directory(current_node))),
-                Err(e) => {
-                    println!("{}", e);
-                    None
-                }
-            }
-        }
-        BIG => {
-            let mut bigdir_entries: Vec<NodeHash> = Vec::new();
-            let mut offset = 1 as usize;
-            for i in 0..((value_slice.len() - 1) / 32) as u8 {
-                offset = (1 + 32 * i as usize) as usize;
-                println!("offset:{}, i:{}", offset, i);
-                let hash = &value_slice[offset..offset + 32];
+    // Alimenter le hasher avec les données
+    hasher.update(value_slice.clone());
 
-                // envoyer un datum request
-                bigdir_entries.push(hash.try_into().expect("incorrect size"));
-            }
-
-            println!("its a BIG bro");
-            Some((
+    // Obtention du résultat
+    let result = hasher.finalize();
+    if result.to_vec() != hash_name.to_vec() {
+        println!("{:?},{:?}", result.to_vec(), hash_name.to_vec());
+        None
+    } else {
+        println!("hashes equals!");
+        let datum_type = value_slice[0];
+        match datum_type {
+            CHUNK => Some((
                 hash_name,
-                MerkleNode::Big(crate::BigNode {
-                    children_hashes: bigdir_entries,
-                }),
-            ))
-        }
-        BIGDIRECTORY => {
-            let mut bigdir_entries: Vec<NodeHash> = Vec::new();
-            let mut offset = 1 as usize;
-            for i in 0..((value_slice.len() - 1) / 32) as u8 {
-                offset = (1 + 32 * i as usize) as usize;
-                println!("offset:{}, i:{}", offset, i);
-                let hash = &value_slice[offset..offset + 32];
+                MerkleNode::Chunk(crate::ChunkNode { data: value_slice }),
+            )),
+            DIRECTORY => {
+                let mut dir_entries = Vec::new();
+                let mut offset = 1 as usize;
+                for i in 0..((value_slice.len() - 1) / 64) as u8 {
+                    offset = (1 + 64 * i as usize) as usize;
+                    println!("offset:{}, i:{}", offset, i);
+                    let name = &value_slice[offset..offset + 32];
+                    let mut hash = [0u8; 32];
+                    hash.copy_from_slice(&value_slice[offset + 32..offset + 64]);
+                    let dp_name = String::from_utf8(name.to_vec()).expect("err");
+                    println!("name:{}", dp_name);
 
-                // envoyer un datum request
-                bigdir_entries.push(hash.try_into().expect("incorrect size"));
-            }
+                    // envoyer un datum request
+                    dir_entries.push(DirectoryEntry {
+                        filename: name.try_into().expect("incorrect size"),
+                        content_hash: hash,
+                    });
+                }
 
-            let current = BigDirectoryNode::new(bigdir_entries);
-            match current {
-                Ok(current_node) => Some((hash_name, MerkleNode::BigDirectory(current_node))),
-                Err(e) => {
-                    println!("{}", e);
-                    None
+                let current = DirectoryNode::new(dir_entries);
+                match current {
+                    Ok(current_node) => Some((hash_name, MerkleNode::Directory(current_node))),
+                    Err(e) => {
+                        println!("{}", e);
+                        None
+                    }
                 }
             }
+            BIG => {
+                let mut bigdir_entries: Vec<NodeHash> = Vec::new();
+                let mut offset = 1 as usize;
+                for i in 0..((value_slice.len() - 1) / 32) as u8 {
+                    offset = (1 + 32 * i as usize) as usize;
+                    println!("offset:{}, i:{}", offset, i);
+                    let hash = &value_slice[offset..offset + 32];
+
+                    // envoyer un datum request
+                    bigdir_entries.push(hash.try_into().expect("incorrect size"));
+                }
+
+                println!("its a BIG bro");
+                Some((
+                    hash_name,
+                    MerkleNode::Big(crate::BigNode {
+                        children_hashes: bigdir_entries,
+                    }),
+                ))
+            }
+            BIGDIRECTORY => {
+                let mut bigdir_entries: Vec<NodeHash> = Vec::new();
+                let mut offset = 1 as usize;
+                for i in 0..((value_slice.len() - 1) / 32) as u8 {
+                    offset = (1 + 32 * i as usize) as usize;
+                    println!("offset:{}, i:{}", offset, i);
+                    let hash = &value_slice[offset..offset + 32];
+
+                    // envoyer un datum request
+                    bigdir_entries.push(hash.try_into().expect("incorrect size"));
+                }
+
+                let current = BigDirectoryNode::new(bigdir_entries);
+                match current {
+                    Ok(current_node) => Some((hash_name, MerkleNode::BigDirectory(current_node))),
+                    Err(e) => {
+                        println!("{}", e);
+                        None
+                    }
+                }
+            }
+            _ => None,
         }
-        _ => None,
     }
 }

client-network/src/lib.rs

@@ -73,7 +73,7 @@ impl P2PSharedData {
 
         let mut threads = Vec::new();
 
-        let senders = MultipleSenders::new(1, &shared_socket, cmd_tx, &mut threads);
+        let senders = MultipleSenders::new(5, &shared_socket, cmd_tx, &mut threads);
         let shared_senders = Arc::new(senders);
         let server_name = Arc::new(Mutex::new("".to_string()));
         let server_address = Arc::new(Mutex::new("".to_string()));

client-network/src/message_handling.rs

@@ -370,14 +370,11 @@ pub fn parse_message(
                             // envoyer la root request
                             let _ = &guard.remove_entry(&id);
                             println!("message {} retiré de la liste", id);
-
-                            let rootrequest = construct_message(
-                                ROOTREQUEST,
-                                Vec::new(),
-                                generate_id(),
-                                crypto_pair,
-                            );
-                            //&guard.insert(, v)
+                            let new_id = generate_id();
+                            let rootrequest =
+                                construct_message(ROOTREQUEST, Vec::new(), new_id, crypto_pair);
+                            let _ = &guard.insert(new_id, EventType::RootRequest);
+                            println!("root requesst sent");
                             return rootrequest;
                         }
                         EventType::Hello => {
@@ -392,6 +389,7 @@ pub fn parse_message(
         }
         ROOTREPLY => {
             // recuperer le pseudo du peers ayant repondu
+            println!("root reply received");
             let peers_exist = handhsake_history.get_peer_info_ip(ip.to_string());
             match peers_exist {
                 Some(peerinfo) => {
@@ -429,7 +427,9 @@ pub fn parse_message(
                                     constructed_message = datumreqest;
                                     guard.insert(new_id, EventType::DatumRequest);
                                 }
-                                _ => {}
+                                _ => {
+                                    println!("event not prensent");
+                                }
                             }
                         }
                         None => {}
@@ -468,7 +468,6 @@ pub fn parse_message(
                         }
                     }
                     EventType::DatumRequestBig => {
-                        let _ = &guard.remove_entry(&id);
                         println!("message {} retiré de la liste", id);
                         let received_length = u16::from_be_bytes(
                             received_message[TYPE..LENGTH]
@@ -481,6 +480,7 @@ pub fn parse_message(
                             parse_received_datum(received_datum.to_vec(), received_length as usize);
                         match parsed_node {
                             Some(tuple) => {
+                                let _ = &guard.remove_entry(&id);
                                 let _ = cmd_tx.send(NetworkEvent::DataReceived(
                                     tuple.0,
                                     tuple.1,
@@ -488,7 +488,9 @@ pub fn parse_message(
                                 ));
                                 println!("datareceived event sent");
                             }
-                            None => {}
+                            None => {
+                                println!("message corrompu, nouvelle tentative");
+                            }
                         }
                     }
                     _ => {}

client-network/src/messages_channels.rs

@@ -234,7 +234,8 @@ pub fn start_retry_thread(
                             );
                             let base: u64 = 2;
 
-                            let backoff = base.saturating_pow(attempt as u32); // 2^1 == 2 seconds
+                            // let backoff = base.saturating_pow(attempt as u32); // 2^1 == 2 seconds
+                            let backoff = 1;
                             let newretry = RetryMessage {
                                 next_try: SystemTime::now()
                                     .duration_since(UNIX_EPOCH)
@@ -272,7 +273,7 @@ pub fn start_receving_thread(
     let messages_received_clone = shared_data.messages_received();
     let servername_clone = shared_data.servername();
     let thread = thread::spawn(move || {
-        let mut buf = [0u8; 1024];
+        let mut buf = [0u8; 1500];
         loop {
             match sock_clone.recv_from(&mut buf) {
                 Ok((amt, src)) => {

client-network/src/registration.rs

@@ -75,6 +75,7 @@ pub async fn perform_handshake(
                 sd.add_message(id, EventType::Hello);
                 sd.set_serveraddress(sockaddr_bytes.to_string());
             } else {
+                println!("hello the nroot");
                 sd.add_message(id, EventType::HelloThenRootRequest);
             }