diff options
Diffstat (limited to 'src/http')
| -rw-r--r-- | src/http/Server.zig | 50 | ||||
| -rw-r--r-- | src/http/Url.zig | 39 | ||||
| -rw-r--r-- | src/http/root.zig | 3 |
3 files changed, 92 insertions, 0 deletions
diff --git a/src/http/Server.zig b/src/http/Server.zig new file mode 100644 index 0000000..71037bb --- /dev/null +++ b/src/http/Server.zig @@ -0,0 +1,50 @@ +const std = @import("std"); + +const Self = @This(); + +server: std.Io.net.Server, +threaded: std.Io.Threaded, + +pub fn init( + gpa: std.mem.Allocator, + address: std.Io.net.IpAddress, +) !Self { + var threaded: std.Io.Threaded = .init(gpa, .{}); + + return .{ + .threaded = threaded, + .server = try address.listen(threaded.io(), .{ .reuse_address = true }), + }; +} + +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; + } + } +} diff --git a/src/http/Url.zig b/src/http/Url.zig new file mode 100644 index 0000000..4a0a2b0 --- /dev/null +++ b/src/http/Url.zig @@ -0,0 +1,39 @@ +const std = @import("std"); + +const Segment = union(enum) { + literal: []const u8, + parameter: []const u8, + + pub fn format(self: @This(), writer: *std.Io.Writer) !void { + try writer.print("{s}{{ {s} }}", .{ @tagName(self), switch (self) { + inline else => |s| s, + } }); + } +}; + +pub fn Template(comptime template: []const u8) []const Segment { + var segments: []const Segment = &.{}; + var t = template; + + if (template.len == 0 or template[0] != '/') { + @compileError("template needs to be absolute"); + } + + while (t.len > 0) { + const index = std.mem.indexOfScalar(u8, t, '/'); + const segment = t[0 .. index orelse t.len]; + t = t[(index orelse t.len - 1) + 1 ..]; + + if (segment.len > 0) { + const s: []const Segment = &.{seg: { + if (segment[0] == '{' and segment[segment.len - 1] == '}') { + break :seg .{ .parameter = segment[1 .. segment.len - 1] }; + } else { + break :seg .{ .literal = segment }; + } + }}; + segments = segments ++ s; + } + } + return segments; +} diff --git a/src/http/root.zig b/src/http/root.zig index 743e1c4..317dacd 100644 --- a/src/http/root.zig +++ b/src/http/root.zig @@ -2,6 +2,9 @@ const std = @import("std"); +pub const Server = @import("Server.zig"); +pub const Url = @import("Url.zig"); + test { _ = std.testing.refAllDecls(@This()); } |