v0.6.9: add application-level heartbeat to prevent proxy idle timeouts

Railway's reverse proxy may not recognize Engine.IO ping/pong as
connection activity. Send explicit heartbeat messages every 8s on
both expose and reach commands to keep the WebSocket alive.

Author: dantelex

apps/agent/package.json

@@ -1,6 +1,6 @@
 {
   "name": "agent",
-  "version": "0.6.8",
+  "version": "0.6.9",
   "private": true,
   "bin": {
     "connect": "./dist/cli.js"

apps/agent/src/commands/expose.ts

@@ -459,9 +459,30 @@ export async function exposeCommand(target: string, options: ExposeOptions): Pro
     }
   });
 
+  // Application-level keepalive to prevent Railway/proxy idle timeouts.
+  // Engine.IO ping/pong may not be recognized as activity by all reverse proxies.
+  let heartbeatInterval: ReturnType<typeof setInterval> | null = null;
+  
+  socket.on('connect', () => {
+    if (heartbeatInterval) clearInterval(heartbeatInterval);
+    heartbeatInterval = setInterval(() => {
+      if (socket.connected) {
+        socket.emit('heartbeat');
+      }
+    }, 8000);
+  });
+
+  socket.on('disconnect', () => {
+    if (heartbeatInterval) {
+      clearInterval(heartbeatInterval);
+      heartbeatInterval = null;
+    }
+  });
+
   // Handle process signals
   process.on('SIGINT', () => {
     console.log(chalk.yellow('\n👋 Stopping exposure...'));
+    if (heartbeatInterval) clearInterval(heartbeatInterval);
     socket.disconnect();
     process.exit(0);
   });

apps/agent/src/commands/reach.ts

@@ -230,6 +230,9 @@ async function createLocalTunnel(
     },
     transports: ['websocket'],
     reconnection: true,
+    reconnectionDelay: 1000,
+    reconnectionDelayMax: 10000,
+    timeout: 30000,
   });
 
   const connections = new Map<string, { localSocket: net.Socket; ready: boolean; buffer: Buffer[] }>();
@@ -401,16 +404,37 @@ async function createLocalTunnel(
     });
   });
 
+  // Application-level keepalive to prevent proxy idle timeouts
+  let heartbeatInterval: ReturnType<typeof setInterval> | null = null;
+  
+  socket.on('connect', () => {
+    if (heartbeatInterval) clearInterval(heartbeatInterval);
+    heartbeatInterval = setInterval(() => {
+      if (socket.connected) {
+        socket.emit('heartbeat');
+      }
+    }, 8000);
+  });
+
+  socket.on('disconnect', () => {
+    if (heartbeatInterval) {
+      clearInterval(heartbeatInterval);
+      heartbeatInterval = null;
+    }
+  });
+
   // Handle shutdown
   process.on('SIGINT', () => {
     console.log(chalk.yellow('\n👋 Disconnecting...'));
+    if (heartbeatInterval) clearInterval(heartbeatInterval);
     try { unregisterRoute(service.name); } catch { /* cleanup best-effort */ }
     server.close();
     socket.disconnect();
     process.exit(0);
   });
 
   process.on('SIGTERM', () => {
+    if (heartbeatInterval) clearInterval(heartbeatInterval);
     try { unregisterRoute(service.name); } catch { /* cleanup best-effort */ }
     server.close();
     socket.disconnect();

packages/cli/package.json

@@ -1,6 +1,6 @@
 {
   "name": "private-connect",
-  "version": "0.6.8",
+  "version": "0.6.9",
   "description": "Access private services by name from anywhere. No VPN setup, no firewall rules. Open source alternative to ngrok and Tailscale for service-level connectivity.",
   "bin": {
     "private-connect": "./dist/index.js"