aboutsummaryrefslogtreecommitdiff
path: root/src/http/Server.zig
diff options
context:
space:
mode:
Diffstat (limited to 'src/http/Server.zig')
-rw-r--r--src/http/Server.zig65
1 files changed, 0 insertions, 65 deletions
diff --git a/src/http/Server.zig b/src/http/Server.zig
deleted file mode 100644
index dc331d8..0000000
--- a/src/http/Server.zig
+++ /dev/null
@@ -1,65 +0,0 @@
-const std = @import("std");
-
-const RouteSet = @import("RouteSet.zig");
-
-const Self = @This();
-
-server: std.Io.net.Server,
-threaded: std.Io.Threaded,
-routes: RouteSet,
-
-pub fn init(
- gpa: std.mem.Allocator,
- address: std.Io.net.IpAddress,
- comptime routes: RouteSet,
-) !Self {
- var threaded: std.Io.Threaded = .init(gpa, .{});
-
- return .{
- .threaded = threaded,
- .server = try address.listen(threaded.io(), .{ .reuse_address = true }),
- .routes = routes,
- };
-}
-
-pub fn serve(self: *Self, gpa: std.mem.Allocator) !void {
- var group: std.Io.Group = .init;
- const io = self.threaded.io();
-
- while (true) {
- const stream = try self.server.accept(self.threaded.io());
- group.async(io, handle, .{self, gpa, stream});
- }
-}
-
-pub fn handle(
- self: *Self,
- gpa: std.mem.Allocator,
- stream: std.Io.net.Stream,
-) void {
- var read_buffer: [1024 * 8]u8 = undefined;
- var write_buffer: [1024 * 8]u8 = undefined;
-
- defer stream.close(self.threaded.io());
-
- var arena: std.heap.ArenaAllocator = .init(gpa);
- defer arena.deinit();
-
- 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});
- return;
- };
-
- std.debug.print("{s} {s}\n", .{ @tagName(request.head.method), request.head.target });
-
- if (self.routes.getInterface(request.head.target)) |interface| {
- const message = interface.handle(gpa, arena.allocator(), self.threaded.io(), &request);
- message.send(self.threaded.io(), &request) catch return;
- } else {
- request.respond("", .{ .status = .not_found }) catch return;
- }
-}