summaryrefslogtreecommitdiff
path: root/src/server.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/server.rs')
-rw-r--r--src/server.rs41
1 files changed, 41 insertions, 0 deletions
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();
+ }
+}