laantungir
/
super_ball
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix ws issue

This commit is contained in:
Your Name 2025-09-29 07:36:12 -04:00
parent 69514943a9
commit 5b618c08ed
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
thrower_daemon/daemon.js
View File

@ -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]);