machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

reset acceleration websocket if unresponsive

Browse Source
This commit is contained in:
Mononaut 2024-11-11 16:59:08 +00:00
parent 9718610104
commit ef498b55ed
No known key found for this signature in database
GPG Key ID: A3F058E41374C04E
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
backend/src/api/services/acceleration.ts
View File

@ -50,6 +50,7 @@ class AccelerationApi {
private _accelerations: Record<string, Acceleration> = {}; private _accelerations: Record<string, Acceleration> = {};
private lastPoll = 0; private lastPoll = 0;
private lastPing = 0; private lastPing = 0;
private lastPong = 0;
private forcePoll = false; private forcePoll = false;
private myAccelerations: Record<string, { status: MyAccelerationStatus, added: number, acceleration?: Acceleration }> = {}; private myAccelerations: Record<string, { status: MyAccelerationStatus, added: number, acceleration?: Acceleration }> = {};
@ -284,7 +285,12 @@ class AccelerationApi {
logger.debug('received pong from acceleration websocket server'); logger.debug('received pong from acceleration websocket server');
}); });
} else { } else {
if (Date.now() - this.lastPing > 30000) { if (this.lastPing > this.lastPong && Date.now() - this.lastPing > 5000) {
logger.warn('No pong received within 5 seconds, terminating connection');
this.ws.terminate();
this.ws = null;
this.websocketConnected = false;
} else if (Date.now() - this.lastPing > 30000) {
logger.debug('sending ping to acceleration websocket server'); logger.debug('sending ping to acceleration websocket server');
this.ws.ping(); this.ws.ping();
this.lastPing = Date.now(); this.lastPing = Date.now();