diff options
| author | mo khan <mo@mokhan.ca> | 2025-05-29 11:20:18 -0600 |
|---|---|---|
| committer | mo khan <mo@mokhan.ca> | 2025-05-29 11:20:18 -0600 |
| commit | 11ac4f29097daca8558c9772215180d55c7b6c6a (patch) | |
| tree | 0b8f0e868bf803752ee1fc260a15bedbd3977a6b /src | |
| parent | 90de6093619db3401c7c275fb0a128a71ddd562d (diff) | |
refactor: remove some duplication
Diffstat (limited to 'src')
| -rw-r--r-- | src/main.rs | 33 |
1 files changed, 14 insertions, 19 deletions
diff --git a/src/main.rs b/src/main.rs index cd8d5ea..16d0223 100644 --- a/src/main.rs +++ b/src/main.rs @@ -16,24 +16,19 @@ pub fn start_server(bind: String) { } fn handle(mut stream: TcpStream) { - let buf_reader = BufReader::new(&stream); - let request_line = buf_reader.lines().next().unwrap().unwrap(); - - if request_line == "GET / HTTP/1.1" { - let status_line = "HTTP/1.1 200 OK"; - let contents = fs::read_to_string("./public/index.html").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(); + let io = BufReader::new(&stream); + let request_line = io.lines().next().unwrap().unwrap(); + let (status_line, filename) = if request_line == "GET / HTTP/1.1" { + ("HTTP/1.1 200 OK", "./public/index.html") } else { - let status_line = "HTTP/1.1 404 NOT FOUND"; - let contents = fs::read_to_string("./public/404.html").unwrap(); - let length = contents.len(); - let response = format!("{status_line}\r\nContent-Length: {length}\r\n\r\n{contents}"); + ("HTTP/1.1 404 NOT FOUND", "./public/404.html") + }; - stream.write_all(response.as_bytes()).unwrap(); - } + 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(); } #[cfg(test)] @@ -43,9 +38,9 @@ mod tests { #[test] fn it_starts_a_server() { - let server = thread::spawn(|| start_server("127.0.0.1:7878".to_string())); - + // TODO:: figure out how to spawn a server in a background thread + // let server = thread::spawn(|| start_server("127.0.0.1:7878".to_string())); assert!(true); - server.join().unwrap(); + // server.join().unwrap(); } } |
