dexorder/ai
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add WebSocket ping to keep connections alive through CloudFlare

Browse Source 
CloudFlare drops idle WebSocket connections after ~100 seconds.
Ping every 30 seconds to prevent this.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
Tim Olson
2026-04-01 22:35:33 -04:00
parent e502c160fe
commit 5b78ecb041
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
gateway/src/channels/websocket-handler.ts
View File

@@ -312,6 +312,7 @@ export class WebSocketHandler {
// Handle disconnection // Handle disconnection
socket.on('close', async (code: number, reason: Buffer) => { socket.on('close', async (code: number, reason: Buffer) => {
clearInterval(pingInterval);
logger.info({ sessionId: authContext.sessionId, code, reason: reason?.toString() }, 'WebSocket disconnected'); logger.info({ sessionId: authContext.sessionId, code, reason: reason?.toString() }, 'WebSocket disconnected');
// Unregister from event system // Unregister from event system
@@ -334,6 +335,14 @@ export class WebSocketHandler {
socket.on('error', (error: any) => { socket.on('error', (error: any) => {
logger.error({ error, sessionId: authContext.sessionId }, 'WebSocket error'); logger.error({ error, sessionId: authContext.sessionId }, 'WebSocket error');
}); });
// Ping every 30 seconds to keep the connection alive through CloudFlare proxy.
// CloudFlare drops idle WebSocket connections after ~100 seconds.
const pingInterval = setInterval(() => {
if (socket.readyState === 1) { // OPEN
socket.ping();
}
}, 30000);
} catch (error) { } catch (error) {
logger.error({ error }, 'Failed to initialize session'); logger.error({ error }, 'Failed to initialize session');
socket.close(1011, 'Internal server error'); socket.close(1011, 'Internal server error');