From 5b618c08ede61642889fc61a95c75aa54cb9e7a7 Mon Sep 17 00:00:00 2001 From: Your Name Date: Mon, 29 Sep 2025 07:36:12 -0400 Subject: [PATCH] fix ws issue --- thrower_daemon/daemon.js | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/thrower_daemon/daemon.js b/thrower_daemon/daemon.js index 5538693..f781f50 100644 --- a/thrower_daemon/daemon.js +++ b/thrower_daemon/daemon.js @@ -418,7 +418,7 @@ class EventProcessor { if (!routing.audit || typeof routing.audit !== 'string') return false; // Check maximum delay limit - const maxDelay = this.config.get('thrower.maxDelay') || 3600; + const maxDelay = this.config.get('thrower.maxDelay') || 86460; if (routing.delay > maxDelay) { this.logger.error(`Routing delay ${routing.delay}s exceeds maximum allowed delay of ${maxDelay}s`); return false; @@ -648,7 +648,7 @@ class ThrowerInfoManager { if (throwerInfo.privacyPolicy) tags.push(['privacy_policy', throwerInfo.privacyPolicy]); if (throwerInfo.termsOfService) tags.push(['terms_of_service', throwerInfo.termsOfService]); tags.push(['refresh_rate', throwerInfo.refreshRate.toString()]); - tags.push(['max_delay', (throwerInfo.maxDelay || 3600).toString()]); + tags.push(['max_delay', (throwerInfo.maxDelay || 86460).toString()]); const eventTemplate = { kind: 12222, @@ -933,7 +933,7 @@ class WebSocketManager { this.logger.info('Stopping WebSocket monitoring...'); this.connections.forEach(({ url, ws }) => { - if (ws.readyState === WebSocket.OPEN) { + if (ws.readyState === ws.OPEN) { // Send CLOSE message for subscription if (this.subscriptionId) { const closeMsg = JSON.stringify(['CLOSE', this.subscriptionId]);