From 936c6316231e12295dade3079fc19db7c48252cf Mon Sep 17 00:00:00 2001
From: sreedevk <sreedev@icloud.com>
Date: Fri, 11 Jul 2025 14:24:21 +0000
Subject: [PATCH] added another test for processor

---
 src/server/processor.rs | 41 +++++++++++++++++++++++++++++++++++++++++
 1 file changed, 41 insertions(+)

diff --git a/src/server/processor.rs b/src/server/processor.rs
index d6a5a3e..d363bd5 100644
--- a/src/server/processor.rs
+++ b/src/server/processor.rs
@@ -62,6 +62,47 @@ mod tests {
     use std::fs::File;
     use std::io::Write;
 
+    #[test]
+    fn processor_differentiates_files_with_different_sizes() -> Result<()> {
+        let file_queue = Arc::new(Mutex::new(vec![]));
+        let (tx, rx) = mpsc::channel::<Message>();
+        let root = TempDir::new()?;
+        let store = Arc::new(Store::new());
+
+        let fq_c = file_queue.clone();
+        let store_c = store.clone();
+        let proc_thread = thread::spawn(move || {
+            let processor = Processor::new(fq_c, store_c, rx);
+            processor.process().expect("processor failed");
+        });
+
+        let files = 
+            [("hello.txt", "Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Ut enim ad minim veniam, quis nostrud exercitation ullamco laboris nisi ut aliquip ex ea commodo consequat"), 
+            ("hello_dup.txt", "Duis aute irure dolor in reprehenderit in voluptate velit esse cillum dolore eu fugiat nulla pariatur. Excepteur sint occaecat cupidatat non proident, sunt in culpa qui officia deserunt mollit anim id est laborum")];
+
+        for (filename, content) in files.into_iter() {
+            let fpath = root.path().join(filename);
+            let mut tf = File::create(fpath.clone())?;
+            tf.write_all(content.as_bytes())?;
+
+            let mut mfq = file_queue.lock().unwrap();
+            mfq.push(fpath.into_os_string().into_string().unwrap().into_boxed_str());
+        }
+
+        for _ in 0..10 {
+            if store.entries().len() < 2 {
+                thread::sleep(std::time::Duration::from_millis(100));
+            } 
+        }
+
+        tx.send(Message::Exit).expect("unable to send msg to processor");
+        proc_thread.join().expect("failed to join on thread!");
+
+        assert!(store.entries().len() == 2);
+
+        Ok(())
+    }
+
     #[test]
     fn processor_groups_files_with_same_size() -> Result<()> {
         let file_queue = Arc::new(Mutex::new(vec![]));