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(); } } fn main() { let server = Server::new("127.0.0.1:7878".to_string()); server.start() } #[cfg(test)] mod tests { #[test] fn it_starts_a_server() { assert!(true); } }