mirrors/mempool
1
0
Fork 0
mirror of https://github.com/mempool/mempool.git synced 2025-03-03 09:39:17 +01:00
Code Issues Projects Releases Wiki Activity

Introduce a websocket ping check that closes the socket if no response.

Browse source
This commit is contained in:
softsimon 2020-03-06 02:05:26 +07:00
parent b60d9cdfbc
commit 5d4ce44627
2 changed files with 31 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
backend/src/api/websocket-handler.ts
View file

@ -74,6 +74,10 @@ class WebsocketHandler {
'git-commit': this.latestGitCommitHash
}));
}
if (parsedMessage.action === 'ping') {
client.send(JSON.stringify({'pong': true}));
}
} catch (e) {
console.log(e);
}

31
frontend/src/app/services/websocket.service.ts
View file

@ -18,6 +18,8 @@ export class WebsocketService {
private trackingTxId: string | null = null;
private trackingAddress: string | null = null;
private latestGitCommit = '';
private onlineCheckTimeout: number;
private onlineCheckTimeoutTwo: number;
constructor(
private stateService: StateService,
@ -107,13 +109,12 @@ export class WebsocketService {
}
this.stateService.isOffline$.next(false);
}
this.startOnlineCheck();
},
(err: Error) => {
console.log(err);
this.goneOffline = true;
this.stateService.isOffline$.next(true);
console.log('Error, retrying in 10 sec');
window.setTimeout(() => this.startSubscription(), 10000);
this.goOffline();
});
}
@ -135,4 +136,26 @@ export class WebsocketService {
this.websocketSubject.next({action: 'want', data: data});
this.lastWant = data;
}
goOffline() {
this.goneOffline = true;
this.stateService.isOffline$.next(true);
console.log('Error, retrying in 10 sec');
window.setTimeout(() => this.startSubscription(), 10000);
}
startOnlineCheck() {
clearTimeout(this.onlineCheckTimeout);
clearTimeout(this.onlineCheckTimeoutTwo);
this.onlineCheckTimeout = window.setTimeout(() => {
this.websocketSubject.next({action: 'ping'});
this.onlineCheckTimeoutTwo = window.setTimeout(() => {
if (!this.goneOffline) {
this.websocketSubject.complete();
this.goOffline();
}
}, 1000);
}, 10000);
}
}