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

resume tracking subscriptions after websocket reconnect

Browse Source
This commit is contained in:
Mononaut 2023-08-03 16:17:17 +09:00
parent cac2a984ab
commit cb5b96485c
No known key found for this signature in database
GPG Key ID: A3F058E41374C04E
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -28,8 +28,9 @@ export class WebsocketService {
private isTrackingTx = false; private isTrackingTx = false;
private trackingTxId: string; private trackingTxId: string;
private isTrackingMempoolBlock = false; private isTrackingMempoolBlock = false;
private isTrackingRbf = false; private isTrackingRbf: 'all' | 'fullRbf' | false = false;
private isTrackingRbfSummary = false; private isTrackingRbfSummary = false;
private isTrackingAddress: string | false = false;
private trackingMempoolBlock: number; private trackingMempoolBlock: number;
private latestGitCommit = ''; private latestGitCommit = '';
private onlineCheckTimeout: number; private onlineCheckTimeout: number;
@ -110,6 +111,15 @@ export class WebsocketService {
if (this.isTrackingMempoolBlock) { if (this.isTrackingMempoolBlock) {
this.startTrackMempoolBlock(this.trackingMempoolBlock); this.startTrackMempoolBlock(this.trackingMempoolBlock);
} }
if (this.isTrackingRbf) {
this.startTrackRbf(this.isTrackingRbf);
}
if (this.isTrackingRbfSummary) {
this.startTrackRbfSummary();
}
if (this.isTrackingAddress) {
this.startTrackAddress(this.isTrackingAddress);
}
this.stateService.connectionState$.next(2); this.stateService.connectionState$.next(2);
} }
@ -151,10 +161,12 @@ export class WebsocketService {
startTrackAddress(address: string) { startTrackAddress(address: string) {
this.websocketSubject.next({ 'track-address': address }); this.websocketSubject.next({ 'track-address': address });
this.isTrackingAddress = address;
} }
stopTrackingAddress() { stopTrackingAddress() {
this.websocketSubject.next({ 'track-address': 'stop' }); this.websocketSubject.next({ 'track-address': 'stop' });
this.isTrackingAddress = false;
} }
startTrackAsset(asset: string) { startTrackAsset(asset: string) {
@ -178,7 +190,7 @@ export class WebsocketService {
startTrackRbf(mode: 'all' | 'fullRbf') { startTrackRbf(mode: 'all' | 'fullRbf') {
this.websocketSubject.next({ 'track-rbf': mode }); this.websocketSubject.next({ 'track-rbf': mode });
this.isTrackingRbf = true; this.isTrackingRbf = mode;
} }
stopTrackRbf() { stopTrackRbf() {