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

Fix acceleration websocket ping/pong

Browse Source
This commit is contained in:
Mononaut 2024-11-11 17:23:30 +00:00
parent 7d3d59c348
commit f1e2c893cc
No known key found for this signature in database
GPG Key ID: A3F058E41374C04E
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -49,8 +49,8 @@ class AccelerationApi {
private websocketPath = config.MEMPOOL_SERVICES?.API ? `${config.MEMPOOL_SERVICES.API.replace('https://', 'wss://').replace('http://', 'ws://')}/accelerator/ws` : '/'; private websocketPath = config.MEMPOOL_SERVICES?.API ? `${config.MEMPOOL_SERVICES.API.replace('https://', 'wss://').replace('http://', 'ws://')}/accelerator/ws` : '/';
private _accelerations: Record<string, Acceleration> = {}; private _accelerations: Record<string, Acceleration> = {};
private lastPoll = 0; private lastPoll = 0;
private lastPing = 0; private lastPing = Date.now();
private lastPong = 0; private lastPong = Date.now();
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 }> = {};
@ -283,6 +283,7 @@ class AccelerationApi {
this.ws.on('pong', () => { this.ws.on('pong', () => {
logger.debug('received pong from acceleration websocket server'); logger.debug('received pong from acceleration websocket server');
this.lastPong = Date.now();
}); });
} else { } else {
if (this.lastPing > this.lastPong && Date.now() - this.lastPing > 10000) { if (this.lastPing > this.lastPong && Date.now() - this.lastPing > 10000) {