@@ -132,7 +132,7 @@ class SyncService {
132132 const failures = ( prevNode ?. healthFailures || 0 ) + 1 ;
133133
134134 if ( failures >= HEALTH_FAILURE_THRESHOLD && prevNode ?. status === 'online' ) {
135- await HyNode . updateOne ( { _id : node . _id } , { $set : { status : 'offline' } } ) ;
135+ await HyNode . updateOne ( { _id : node . _id } , { $set : { status : 'offline' , onlineUsers : 0 } } ) ;
136136 webhook . emit ( webhook . EVENTS . NODE_OFFLINE , { nodeId : node . _id , name : node . name , lastError : error . message } ) ;
137137 logger . warn ( `[Agent] ${ node . name } : marked offline after ${ failures } consecutive failures` ) ;
138138 }
@@ -487,7 +487,7 @@ class SyncService {
487487 const failures = ( prevNode ?. healthFailures || 0 ) + 1 ;
488488
489489 if ( failures >= HEALTH_FAILURE_THRESHOLD && prevNode ?. status === 'online' ) {
490- await HyNode . updateOne ( { _id : node . _id } , { $set : { status : 'offline' } } ) ;
490+ await HyNode . updateOne ( { _id : node . _id } , { $set : { status : 'offline' , onlineUsers : 0 } } ) ;
491491 webhook . emit ( webhook . EVENTS . NODE_OFFLINE , { nodeId : node . _id , name : node . name , lastError : error . message } ) ;
492492 logger . warn ( `[Agent] ${ node . name } : marked offline after ${ failures } consecutive failures` ) ;
493493 }
@@ -774,7 +774,7 @@ class SyncService {
774774 const failures = ( prevNode ?. healthFailures || 0 ) + 1 ;
775775
776776 if ( failures >= HEALTH_FAILURE_THRESHOLD && prevNode ?. status === 'online' ) {
777- await HyNode . updateOne ( { _id : node . _id } , { $set : { status : 'offline' } } ) ;
777+ await HyNode . updateOne ( { _id : node . _id } , { $set : { status : 'offline' , onlineUsers : 0 } } ) ;
778778 webhook . emit ( webhook . EVENTS . NODE_OFFLINE , { nodeId : node . _id , name : node . name , lastError : error . message } ) ;
779779 logger . warn ( `[Stats] ${ node . name } : marked offline after ${ failures } consecutive failures` ) ;
780780 }
0 commit comments