From 8b76902f63a80f53953610b1627e5cb052c25ab8 Mon Sep 17 00:00:00 2001
From: Johannes Wendel <j_wendel14@cs.uni-kl.de>
Date: Mon, 20 Jan 2025 20:04:11 +0100
Subject: [PATCH] Current state

---
 src/lib.rs           |  1 +
 src/main.rs          |  1 -
 tests/integration.rs | 30 ++++++++++++++++++++++--------
 3 files changed, 23 insertions(+), 9 deletions(-)
 create mode 100644 src/lib.rs

diff --git a/src/lib.rs b/src/lib.rs
new file mode 100644
index 0000000..c65edbc
--- /dev/null
+++ b/src/lib.rs
@@ -0,0 +1 @@
+pub mod flutr;
\ No newline at end of file
diff --git a/src/main.rs b/src/main.rs
index a58e3ae..e2df411 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -5,7 +5,6 @@ use image::ImageReader;
 
 use clap::Parser;
 
-mod flutr;
 mod pixelmsgs;
 
 use flutr::FlutR;
diff --git a/tests/integration.rs b/tests/integration.rs
index 2aab7cb..3dc7137 100644
--- a/tests/integration.rs
+++ b/tests/integration.rs
@@ -1,6 +1,21 @@
-use std::net::{TcpListener};
+use std::{
+    net::TcpListener,
+    io::Read,
+    thread,
+};
 
-use std::io::Read;
+use flutr::FlutR;
+
+fn receive_bytes() -> [u8; 128]{
+    let listener = TcpListener::bind("127.0.0.1:7878").unwrap();
+    
+    let mut stream = listener.accept().unwrap().0;
+
+    let mut buf: [u8; 128] = [0; 128];
+    stream.read(&mut buf).unwrap();
+
+    return buf;
+}
 
 
 #[cfg(test)]
@@ -9,14 +24,13 @@ mod tests {
 
     #[test]
     fn it_works() {
-        let listener = TcpListener::bind("127.0.0.1:7878").unwrap();
-    
-        let mut stream = listener.accept().unwrap().0;
+        let receive_thread = thread::spawn(move || {return receive_bytes();});
 
-        let mut buf: [u8; 128] = [0; 128];
-        stream.read(&mut buf).unwrap();
+        let flutr_server = Flutr::new();
+        
 
-        for x in buf {
+        let buf = receive_thread.join();
+        for x in buf.unwrap() {
             print!("{x}, ");
         }
     }