1 files changed, 35 insertions, 5 deletions

diff --git a/src/http/Server.zig b/src/http/Server.zig
index b6e2d90..71037bb 100644
--- a/src/http/Server.zig
+++ b/src/http/Server.zig
@@ -3,18 +3,48 @@ const std = @import("std");
 const Self = @This();
 
 server: std.Io.net.Server,
-io: std.Io.Threaded,
+threaded: std.Io.Threaded,
 
 pub fn init(
     gpa: std.mem.Allocator,
     address: std.Io.net.IpAddress,
 ) !Self {
-    var io: std.Io.Threaded = .init(gpa, .{});
+    var threaded: std.Io.Threaded = .init(gpa, .{});
 
     return .{
-        .io = io,
-        .server = try address.listen(io.io(), .{ .reuse_address = true }),
+        .threaded = threaded,
+        .server = try address.listen(threaded.io(), .{ .reuse_address = true }),
     };
 }
 
-pub fn serve(_: *Self) !void {}
+pub fn serve(self: *Self, content: []const u8) !void {
+    var read_buffer: [1024 * 8]u8 = undefined;
+    var write_buffer: [1024 * 8]u8 = undefined;
+
+    while (true) {
+        const stream = try self.server.accept(self.threaded.io());
+        defer stream.close(self.threaded.io());
+
+        var reader = stream.reader(self.threaded.io(), &read_buffer);
+        var writer = stream.writer(self.threaded.io(), &write_buffer);
+
+        var server: std.http.Server = .init(&reader.interface, &writer.interface);
+        var request = server.receiveHead() catch |e| {
+            std.debug.print("error: {}\n", .{e});
+            continue;
+        };
+
+        std.debug.print("{s} {s}\n", .{ @tagName(request.head.method), request.head.target });
+
+        if (std.mem.eql(u8, request.head.target, "/")) {
+            request.respond(content, .{
+                .status = .ok,
+                .extra_headers = &.{
+                    .{ .name = "Content-Type", .value = "text/html" },
+                },
+            }) catch continue;
+        } else {
+            request.respond("Not Found", .{ .status = .not_found }) catch continue;
+        }
+    }
+}