From f39dfd01ab06cf92a3bcad75fcb175a8242ec1b1 Mon Sep 17 00:00:00 2001 From: Nathan Reiner Date: Sat, 6 Jun 2026 09:38:56 +0200 Subject: Remove Server struct and replace it with single function --- src/http/Server.zig | 65 ----------------------------------------------------- 1 file changed, 65 deletions(-) delete mode 100644 src/http/Server.zig (limited to 'src/http/Server.zig') 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; - } -} -- cgit v1.2.3-70-g09d2