remove ws handler

Team3132 · Nov 21, 2024 · 50074ed · 50074ed
1 parent 824f619
commit 50074ed
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 17 deletions.
diff --git a/packages/frontend/src/api/hono.ts b/packages/frontend/src/api/hono.ts
@@ -54,24 +54,30 @@ const app = new OpenAPIHono<HonoEnv>()
           description: "Server Sent Events",
           content: {
             "text/event-stream": {
-              schema: z.string(),
+              schema: z.any(),
             },
           },
         },
         401: authResponses[401],
       },
     }),
     async (c) => {
-      return streamSSE(c, async (stream) => {
+      const sseRes = streamSSE(c, async (stream) => {
         ee.on("invalidate", (data) =>
           stream.writeSSE({
             data: JSON.stringify(data),
             event: "invalidate",
             id: ulid(),
           }),
         );
+
+        stream.onAbort(() => {
+          ee.off("invalidate");
+        });
         // biome-ignore lint/complexity/noBannedTypes: <explanation>
       }) as unknown as TypedResponse<{}, 200, string>;
+
+      return sseRes;
     },
   )
   .doc31("/api/docs/openapi.json", {

diff --git a/packages/frontend/src/trpcClient.ts b/packages/frontend/src/trpcClient.ts
@@ -52,21 +52,6 @@ export const queryClient = new QueryClient({
     },
   },
 });
-try {
-  // add websocket listener
-  const ws = new WebSocket(
-    `ws${backendUrl.protocol === "https:" ? "s" : ""}://${backendUrl.host}/api/ws`,
-  );
-
-  ws.addEventListener("message", (event) => {
-    const data = JSON.parse(event.data) as QueryKey;
-    queryClient.invalidateQueries({
-      queryKey: data,
-    });
-  });
-} catch (error) {
-  console.error(error);
-}
 
 export const appClient = hc<AppType>(
   `${backendUrl.protocol}//${backendUrl.host}/`,