fix log disconnects and remove console logs.

Author: chrisdrackett

apps/client/src/hooks/useAutomationLogs.ts

@@ -47,7 +47,6 @@ export const useAutomationLogs = ({
 		if (level) params.append("level", level)
 
 		const url = `${baseUrl}/api/v1/logs/stream?${params.toString()}`
-		console.log("[useAutomationLogs] Connecting to:", url)
 
 		const eventSource = new EventSource(url)
 
@@ -68,7 +67,6 @@ export const useAutomationLogs = ({
 					setLogs(historicalLogs)
 					setIsLoading(false)
 				} else if (data.type === "log") {
-					console.log("[useAutomationLogs] New log:", data.log)
 					// Append new log (not marked as historical)
 					setLogs((prev) => [...prev, { ...data.log, isHistorical: false }])
 				}

apps/server/src/app/controllers/app.controller.mts

@@ -40,6 +40,15 @@ export function AppController({
             `data: ${JSON.stringify({ type: "initial", logs: existingLogs })}\n\n`,
           );
 
+          // Send keep-alive heartbeat every 15 seconds to prevent connection timeout
+          const heartbeatInterval = setInterval(() => {
+            try {
+              reply.raw.write(`: heartbeat\n\n`);
+            } catch (err) {
+              // Connection closed, cleanup will happen via 'close' event
+            }
+          }, 15000);
+
           // Subscribe to new logs
           const unsubscribe = code_glue.logger.subscribe(log => {
             // Apply filters
@@ -64,13 +73,18 @@ export function AppController({
             }
 
             // Send log to client
-            reply.raw.write(
-              `data: ${JSON.stringify({ type: "log", log })}\n\n`,
-            );
+            try {
+              reply.raw.write(
+                `data: ${JSON.stringify({ type: "log", log })}\n\n`,
+              );
+            } catch (err) {
+              // Connection closed, cleanup will happen via 'close' event
+            }
           });
 
           // Cleanup on client disconnect
           req.raw.on("close", () => {
+            clearInterval(heartbeatInterval);
             unsubscribe();
           });
         },