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

Merge pull request #5633 from mempool/mononaut/fix-acc-ping-pong

Browse Source 
Fix acceleration websocket ping/pong
This commit is contained in:
wiz 2024-11-12 02:25:15 +09:00 committed by GitHub
commit 5b2f613856
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
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) {