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

reconnect websocket after closed by server

Browse Source
This commit is contained in:
Mononaut 2023-05-01 18:10:51 -06:00
parent 107e0be59f
commit 85c9c79699
No known key found for this signature in database
GPG Key ID: A3F058E41374C04E
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);
} }