refactor: Optimize SSE keepalive interval and remove redundant database updates

commit: dabbe8a2fe89c43475f1b9516a184fc8ecbd3527
author: Kit · 20mo ago · 2025-02-14 14:36 UTC
parent: 3975fb4
signature: SSH UnverifiedSHA256:H91DFuEG4jpk5edzLA4aUKkpv4zv9Q339ipRmkph6Tk The key is unknown

1 file · +1 -8

M src/routes/api/sse/+server.ts +1 -8


@@ -151,15 +151,8 @@ export const GET: RequestHandler = async ({ locals }) => {
151	151		controller.enqueue(encoder.encode('data: Connected\n\n'));
152	152
153	153		// Keep connection alive and update lastSeen: send a comment every 20 seconds
154		-	keepAliveInterval = setInterval(async () => {
	154	+	keepAliveInterval = setInterval(() => {
155	155		controller.enqueue(encoder.encode(':\n\n'));
156		-	// Update lastSeen timestamp on each keepalive
157		-	await db.update(users)
158		-	.set({ lastSeen: Date.now() })
159		-	.where(eq(users.id, userId))
160		-	.catch(error => {
161		-	console.log('[SSE] Error updating lastSeen on keepalive:', error);
162		-	});
163	156		}, 20000);
164	157		},
165	158		async cancel(reason) {

             controller.enqueue(encoder.encode('data: Connected\n\n'));
             // Keep connection alive and update lastSeen: send a comment every 20 seconds
-            keepAliveInterval = setInterval(async () => {
+            keepAliveInterval = setInterval(() => {
                 controller.enqueue(encoder.encode(':\n\n'));
-                // Update lastSeen timestamp on each keepalive
-                await db.update(users)
-                    .set({ lastSeen: Date.now() })
-                    .where(eq(users.id, userId))
-                    .catch(error => {
-                        console.log('[SSE] Error updating lastSeen on keepalive:', error);
-                    });
             }, 20000);
         },
         async cancel(reason) {