w

2026-07-09 01:20:09 +03:00
parent 4d621e0a54
commit 9697d8724d
1 changed files with 5 additions and 7 deletions
@@ -66,16 +66,14 @@ async function runSSE() {
    const url = new URL(req.url || "/", `http://${req.headers.host}`);

    if (req.method === "GET") {
-      const sessionId = crypto.randomUUID();
      const transport = new SSEServerTransport("/message", res);
-      transports.set(sessionId, transport);
-
-      res.on("close", () => {
-        transports.delete(sessionId);
-      });
-
      const server = buildServer();
      await server.connect(transport);
+
+      transports.set(transport.sessionId, transport);
+      res.on("close", () => {
+        transports.delete(transport.sessionId);
+      });
      return;
    }