aboutsummaryrefslogtreecommitdiff
path: root/src/http
diff options
context:
space:
mode:
Diffstat (limited to 'src/http')
-rw-r--r--src/http/Server.zig50
-rw-r--r--src/http/Url.zig39
-rw-r--r--src/http/root.zig3
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());
}