From 7fe231a39484858a9f2268f76c675cb41e8629bd Mon Sep 17 00:00:00 2001
From: mo khan <mo@mokhan.ca>
Date: Thu, 29 May 2025 16:33:49 -0600
Subject: chore: move server to a separate file

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

(limited to 'src/server.rs')

diff --git a/src/server.rs b/src/server.rs
new file mode 100644
index 0000000..709aba1
--- /dev/null
+++ b/src/server.rs
@@ -0,0 +1,41 @@
+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();
+    }
+}
-- 
cgit v1.2.3