fix reconnect

src/server/api/events.ts

@@ -8,7 +8,11 @@ const router = Hype.router()
 // individual events so apps can react to specific lifecycle changes.
 router.sse('/stream', (send) => {
   const unsub = onEvent(event => send(event))
-  return unsub
+  const heartbeat = setInterval(() => send('', 'ping'), 60_000)
+  return () => {
+    clearInterval(heartbeat)
+    unsub()
+  }
 })
 
 export default router

src/server/tunnels.ts

@@ -146,18 +146,19 @@ export function renameTunnelConfig(oldName: string, newName: string) {
   saveConfig(config)
 }
 
-function cancelReconnect(appName: string) {
+function cancelReconnect(appName: string, resetAttempts = true) {
   const timer = _reconnectTimers.get(appName)
   if (timer) {
     clearTimeout(timer)
     _reconnectTimers.delete(appName)
   }
-  _reconnectAttempts.delete(appName)
+  if (resetAttempts) _reconnectAttempts.delete(appName)
 }
 
-function openTunnel(appName: string, port: number, subdomain?: string) {
+function openTunnel(appName: string, port: number, subdomain?: string, isReconnect = false) {
   // Cancel any pending reconnect timer to prevent duplicate loops
-  cancelReconnect(appName)
+  // but preserve attempts counter during reconnection so backoff works
+  cancelReconnect(appName, !isReconnect)
 
   // Close existing tunnel if any
   const existing = _tunnels.get(appName)
@@ -232,7 +233,7 @@ function openTunnel(appName: string, port: number, subdomain?: string) {
         const config = loadConfig()
         if (!config[appName]) return
         hostLog(`Tunnel reconnecting: ${appName}`)
-        openTunnel(appName, port, config[appName]?.subdomain)
+        openTunnel(appName, port, config[appName]?.subdomain, true)
       }, delay)
 
       _reconnectTimers.set(appName, timer)

src/tools/events.ts

@@ -35,8 +35,10 @@ function ensureConnection() {
         buf = lines.pop()!
         for (const line of lines) {
           if (!line.startsWith('data: ')) continue
+          const payload = line.slice(6)
+          if (!payload) continue
           try {
-            const event: ToesEvent = JSON.parse(line.slice(6))
+            const event: ToesEvent = JSON.parse(payload)
             _listeners.forEach(l => {
               if (l.types.includes(event.type)) l.callback(event)
             })