init

src/app/routes/api/events.$.ts

@@ -0,0 +1,67 @@
+import { createServerFileRoute } from "@tanstack/react-start/server";
+import { serverEvents, type ServerEvent } from "@/lib/events/emitter";
+import { logger } from "@/lib/logger";
+import { superTokensRequestMiddleware } from "@/utils/supertokens";
+
+export const ServerRoute = createServerFileRoute("/api/events/$").middleware([superTokensRequestMiddleware]).methods({
+  GET: ({ request, context }) => {
+    logger.info('ServerEvents | New connection', (context as any)?.userAuthId);
+    
+    const stream = new ReadableStream({
+      start(controller) {
+        // Send initial connection messages
+        const connectMessage = `data: ${JSON.stringify({ type: "connected" })}\n\n`;
+        controller.enqueue(new TextEncoder().encode(connectMessage));
+
+        // Listen for events and broadcast to all connections
+        const handleEvent = (event: ServerEvent) => {
+          logger.info('ServerEvents | Event received', event);
+          const message = `data: ${JSON.stringify(event)}\n\n`;
+          try {
+            controller.enqueue(new TextEncoder().encode(message));
+          } catch (error) {
+            logger.error("ServerEvents | Error sending SSE message", error);
+          }
+        };
+
+        serverEvents.on("test", handleEvent);
+
+        // Keep alive ping every 30 seconds
+        const pingInterval = setInterval(() => {
+          try {
+            const pingMessage = `data: ${JSON.stringify({ type: "ping" })}\n\n`;
+            controller.enqueue(new TextEncoder().encode(pingMessage));
+          } catch (e) {
+            clearInterval(pingInterval);
+            controller.close();
+          }
+        }, 30000);
+
+        const cleanup = () => {
+          serverEvents.off("test", handleEvent);
+          clearInterval(pingInterval);
+          try {
+            logger.info('ServerEvents | Closing connection', (context as any)?.userAuthId);
+            controller.close();
+          } catch (e) {
+            logger.error('ServerEvents | Error closing controller', e);
+          }
+        };
+
+        request.signal?.addEventListener("abort", cleanup);
+
+        return cleanup;
+      },
+    });
+
+    return new Response(stream, {
+      headers: {
+        "Content-Type": "text/event-stream",
+        "Cache-Control": "no-cache",
+        Connection: "keep-alive",
+        "Access-Control-Allow-Origin": "*",
+        "Access-Control-Allow-Headers": "Cache-Control",
+      },
+    });
+  },
+});