From 0d2c997fb3a6abd32939fd5385aa1dcc3dd5e53c Mon Sep 17 00:00:00 2001
From: Caleb Webber <caleb@codingthemsoftly.com>
Date: Tue, 5 Mar 2024 21:49:43 -0500
Subject: [PATCH] complete is_prime

---
 src/bin/is_prime.rs | 68 +++++++++++++++++++++++++++++++++++++--------
 1 file changed, 57 insertions(+), 11 deletions(-)

diff --git a/src/bin/is_prime.rs b/src/bin/is_prime.rs
index ee14d75..fab5641 100644
--- a/src/bin/is_prime.rs
+++ b/src/bin/is_prime.rs
@@ -8,7 +8,7 @@ const BUFF_SIZE: usize = 1;
 #[derive(Deserialize, Debug)]
 struct Request {
     method: String,
-    number: f32
+    number: f64
 }
 
 #[derive(Serialize, Debug)]
@@ -17,6 +17,22 @@ struct Response {
     prime: bool
 }
 
+fn is_prime(n: f64) -> bool {
+    if n <= 1.0 || n.floor() != n {
+        return false;
+    }
+
+    let max_check = n.sqrt().floor() as usize;
+
+    for i in 2..=max_check {
+        let div = n / (i as f64);
+        if div == div.floor() {
+            return false;
+        }
+    }
+    true
+}
+
 fn main() -> std::io::Result<()> {
 
     let listener = TcpListener::bind(format!("0.0.0.0:{PORT}"))?;
@@ -33,26 +49,40 @@ fn main() -> std::io::Result<()> {
                             println!("{:?}", buf);
                             match buf {
                                 [10] => {
-                                    println!("got newline");
+
                                     let s = String::from_utf8(big_buf.clone()).unwrap();
+                                    big_buf.clear();
+
+                                    println!("processing: {s}");
+
                                     let d = serde_json::from_str::<Request>(&s);
+
                                     match d {
                                         Ok(message) => {
-                                            let response = Response {
-                                                    method: String::from("isPrime"),
-                                                    prime: false
-                                                };
-                                            let res_str = serde_json::to_string(&response).unwrap();
-                                            let _ = stream.write(&res_str.as_bytes());
+                                            match message.method.as_str() {
+                                                "isPrime" => {
+                                                    let response = Response {
+                                                            method: String::from("isPrime"),
+                                                            prime: is_prime(message.number)
+                                                        };
+                                                    let res_str = format!("{}\n", serde_json::to_string(&response).unwrap());
+                                                    let _ = stream.write(res_str.as_bytes());
+                                                }
+                                                s => {
+                                                    println!("received invalid method: {s}");
+                                                    let _ = stream.write(&"malformed".as_bytes());
+                                                    let _ = stream.shutdown(std::net::Shutdown::Both);
+                                                }
+                                            }
                                         },
                                         Err(e) => {
-                                            println!("Error parsing\n{:?}", e);
+                                            println!("received malformed request: {:?}", e);
+                                            let _ = stream.write(&"malformed".as_bytes());
+                                            let _ = stream.shutdown(std::net::Shutdown::Both);
                                         }
                                     }
-                                    let _ = stream.write(&buf);
                                 },
                                 [n] => {
-                                    println!("read {n}");
                                     big_buf.push(n);
                                 }
                             }
@@ -68,3 +98,19 @@ fn main() -> std::io::Result<()> {
 
     Ok(())
 }
+
+
+#[cfg(test)]
+mod tests {
+    use super::is_prime;
+    #[test]
+    fn should_return_correct_primes() {
+        assert!(!is_prime(8.0));
+        assert!(is_prime(101.0));
+        assert!(!is_prime(420.0));
+        assert!(!is_prime(7.5));
+         assert!(!is_prime(1.0));
+        assert!(is_prime(76247027.0));
+        assert!(is_prime(7.0));
+    }
+}
\ No newline at end of file