refactor: extract an http module

1 files changed, 42 insertions, 0 deletions

diff --git a/src/lib.rs b/src/lib.rs
new file mode 100644
index 0000000..1ea4cf2
--- /dev/null
+++ b/src/lib.rs
@@ -0,0 +1,42 @@
+pub mod http {
+    use std::fs;
+    use std::io::BufReader;
+    use std::io::prelude::*;
+    use std::net::TcpListener;
+    use std::net::TcpStream;
+    pub struct Server {
+        bind: String,
+    }
+
+    impl Server {
+        pub fn new(bind: String) -> Server {
+            Server { bind }
+        }
+
+        pub fn start(&self) {
+            let listener = TcpListener::bind(self.bind.clone()).unwrap();
+            for next_stream in listener.incoming() {
+                self.handle(next_stream.unwrap());
+            }
+        }
+
+        pub fn handle(&self, mut stream: TcpStream) {
+            let io = BufReader::new(&stream);
+            let request_line = io.lines().next().unwrap().unwrap();
+
+            let (status_line, filename) = match &request_line[..] {
+                "GET / HTTP/1.1" => ("HTTP/1.1 200 OK", "./public/index.html"),
+                "GET /.well-known/oauth-authorization-server HTTP/1.1" => {
+                    ("HTTP/1.1 200 OK", "./public/metadata.json")
+                }
+                _ => ("HTTP/1.1 404 NOT FOUND", "./public/404.html"),
+            };
+
+            let contents = fs::read_to_string(filename).unwrap();
+            let length = contents.len();
+            let response = format!("{status_line}\r\nContent-Length: {length}\r\n\r\n{contents}");
+
+            stream.write_all(response.as_bytes()).unwrap();
+        }
+    }
+}