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

Merge pull request #5631 from mempool/mononaut/acc-ws-debug

Browse Source 
Better debug logs for accelerator websocket
This commit is contained in:
wiz 2024-11-12 00:32:54 +09:00 committed by GitHub
commit 937e82bb89
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -46,6 +46,7 @@ class AccelerationApi {
private websocketConnected: boolean = false; private websocketConnected: boolean = false;
private onDemandPollingEnabled = !config.MEMPOOL_SERVICES.ACCELERATIONS; private onDemandPollingEnabled = !config.MEMPOOL_SERVICES.ACCELERATIONS;
private apiPath = config.MEMPOOL.OFFICIAL ? (config.MEMPOOL_SERVICES.API + '/accelerator/accelerations') : (config.EXTERNAL_DATA_SERVER.MEMPOOL_API + '/accelerations'); private apiPath = config.MEMPOOL.OFFICIAL ? (config.MEMPOOL_SERVICES.API + '/accelerator/accelerations') : (config.EXTERNAL_DATA_SERVER.MEMPOOL_API + '/accelerations');
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 forcePoll = false; private forcePoll = false;
@ -242,18 +243,18 @@ class AccelerationApi {
while (this.useWebsocket) { while (this.useWebsocket) {
this.startedWebsocketLoop = true; this.startedWebsocketLoop = true;
if (!this.ws) { if (!this.ws) {
this.ws = new WebSocket(`${config.MEMPOOL_SERVICES.API.replace('https://', 'wss://').replace('http://', 'ws://')}/accelerator/ws`); this.ws = new WebSocket(this.websocketPath);
this.websocketConnected = true; this.websocketConnected = true;
this.ws.on('open', () => { this.ws.on('open', () => {
logger.info('Acceleration websocket opened'); logger.info(`Acceleration websocket opened to ${this.websocketPath}`);
this.ws?.send(JSON.stringify({ this.ws?.send(JSON.stringify({
'watch-accelerations': true 'watch-accelerations': true
})); }));
}); });
this.ws.on('error', (error) => { this.ws.on('error', (error) => {
logger.err('Acceleration websocket error: ' + error); logger.err(`Acceleration websocket error on ${this.websocketPath}: ` + error);
this.ws = null; this.ws = null;
this.websocketConnected = false; this.websocketConnected = false;
}); });