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

Merge pull request #3706 from mempool/mononaut/reconnect-dead-websocket

Browse Source 
reconnect websocket after closed by server
This commit is contained in:
softsimon 2023-11-30 18:26:18 +09:00 committed by GitHub
commit 6b978f9262
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
frontend/src/app/services/websocket.service.ts
View File

@ -76,15 +76,20 @@ export class WebsocketService {
this.stateService.resetChainTip(); this.stateService.resetChainTip();
this.reconnectWebsocket();
});
}
}
reconnectWebsocket(retrying = false, hasInitData = false) {
console.log('reconnecting websocket');
this.websocketSubject.complete(); this.websocketSubject.complete();
this.subscription.unsubscribe(); this.subscription.unsubscribe();
this.websocketSubject = webSocket<WebsocketResponse>( this.websocketSubject = webSocket<WebsocketResponse>(
this.webSocketUrl.replace('{network}', this.network ? '/' + this.network : '') this.webSocketUrl.replace('{network}', this.network ? '/' + this.network : '')
); );
this.startSubscription(); this.startSubscription(retrying, hasInitData);
});
}
} }
startSubscription(retrying = false, hasInitData = false) { startSubscription(retrying = false, hasInitData = false) {
@ -237,7 +242,7 @@ export class WebsocketService {
this.goneOffline = true; this.goneOffline = true;
this.stateService.connectionState$.next(0); this.stateService.connectionState$.next(0);
window.setTimeout(() => { window.setTimeout(() => {
this.startSubscription(true); this.reconnectWebsocket(true);
}, retryDelay); }, retryDelay);
} }