386th Commit

Shyam-Chen · Oct 14, 2024 · dfc8c7e · dfc8c7e
1 parent d443894
commit dfc8c7e
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/app/src/routes/sse/+handler.ts b/app/src/routes/sse/+handler.ts
@@ -18,7 +18,6 @@ export default async (app: FastifyInstance) => {
 
     req.raw.on('close', () => {
       clearInterval(interval);
-      reply.sse({ event: 'close' });
     });
   });
 };
diff --git a/app/src/routes/sse/event/[id]/+handler.ts b/app/src/routes/sse/event/[id]/+handler.ts
@@ -17,12 +17,14 @@ export default (async (app) => {
     (req, reply) => {
       const { id } = req.params;
 
-      sseEmitter.on(`/sse/event/${id}`, (data) => {
+      function eventId(data?: string | object) {
         reply.sse({ id, data });
-      });
+      }
+
+      sseEmitter.on(`/sse/event/${id}`, eventId);
 
       req.raw.on('close', () => {
-        reply.sse({ event: 'close' });
+        sseEmitter.off(`/sse/event/${id}`, eventId);
       });
     },
   );

diff --git a/app/src/routes/sse/model/+handler.ts b/app/src/routes/sse/model/+handler.ts
@@ -30,7 +30,6 @@ export default (async (app) => {
 
       request.raw.on('close', async () => {
         await stream.cancel();
-        reply.sse({ event: 'close' });
       });
     },
   );