more sse stuff

examples/http/sse/main.zig

@@ -3,16 +3,24 @@ const zzz = @import("zzz");
 const http = zzz.HTTP;
 const log = std.log.scoped(.@"examples/sse");
 
+const tardy = zzz.tardy;
+const Runtime = tardy.Runtime;
+const Task = tardy.Task;
+
 const Server = http.Server(.plain, .auto);
 const Router = Server.Router;
 const Context = Server.Context;
 const Route = Server.Route;
 const SSE = Server.SSE;
 
-fn sse_task(sse: *SSE) !void {
-    log.debug("ctx ptr: {*}", .{sse.context});
+fn sse_process(rt: *Runtime, t: *const Task, sse: *SSE) !void {
+    _ = rt;
+    _ = t;
     try sse.send(.{ .data = "hi this is a message" }, sse_task);
-    std.time.sleep(std.time.ns_per_s);
+}
+
+fn sse_task(sse: *SSE) !void {
+    try sse.context.runtime.spawn_delay(*SSE, sse_process, sse, .{ .seconds = 1 });
 }
 
 fn sse_handler(ctx: *Context) void {

src/http/context.zig

@@ -21,7 +21,6 @@ const TaskFn = @import("tardy").TaskFn;
 const raw_respond = @import("server.zig").raw_respond;
 
 // Context is dependent on the server that gets created.
-// This is because the trigger_task ends up being dependent.
 pub fn Context(comptime Server: type) type {
     return struct {
         const Self = @This();
@@ -36,8 +35,12 @@ pub fn Context(comptime Server: type) type {
         captures: []Capture,
         queries: *QueryMap,
         provision: *Provision,
+        triggered: bool = false,
 
         pub fn to_sse(self: *Self, then: SSE.SSEHandlerFn) void {
+            assert(!self.triggered);
+            self.triggered = true;
+
             self.response.set(.{
                 .status = .OK,
                 .body = "",
@@ -78,6 +81,8 @@ pub fn Context(comptime Server: type) type {
         }
 
         pub fn respond(self: *Self, options: ResponseSetOptions) void {
+            assert(!self.triggered);
+            self.triggered = true;
             self.response.set(options);
 
             const body = options.body orelse "";

src/http/server.zig

@@ -749,7 +749,7 @@ pub fn Server(
                                 send_then_recv_task,
                                 provision,
                                 provision.socket,
-                                provision.buffer,
+                                encrypted_buffer,
                             );
                         },
                         .plain => {
@@ -767,7 +767,7 @@ pub fn Server(
                                 send_then_recv_task,
                                 provision,
                                 provision.socket,
-                                provision.buffer,
+                                plain_buffer,
                             );
                         },
                     }

src/http/sse.zig

@@ -5,6 +5,8 @@ const Pseudoslice = @import("../core/pseudoslice.zig").Pseudoslice;
 const Provision = @import("provision.zig").Provision;
 const _Context = @import("context.zig").Context;
 
+const Runtime = @import("tardy").Runtime;
+
 const SSEMessage = struct {
     id: ?[]const u8 = null,
     event: ?[]const u8 = null,

src/lib.zig

@@ -1,4 +1,5 @@
 const std = @import("std");
+pub const tardy = @import("tardy");
 
 /// HyperText Transfer Protocol.
 /// Supports: HTTP/1.1