diff --git a/backend/src/api/websocket-handler.ts b/backend/src/api/websocket-handler.ts index 925b676f1..2884f72eb 100644 --- a/backend/src/api/websocket-handler.ts +++ b/backend/src/api/websocket-handler.ts @@ -52,7 +52,7 @@ class WebsocketHandler { private socketData: { [key: string]: string } = {}; private serializedInitData: string = '{}'; - private lastRbfSummary: ReplacementInfo | null = null; + private lastRbfSummary: ReplacementInfo[] | null = null; constructor() { } @@ -464,10 +464,11 @@ class WebsocketHandler { let rbfReplacements; let fullRbfReplacements; let rbfSummary; - if (Object.keys(rbfChanges.trees).length) { + if (Object.keys(rbfChanges.trees).length || !this.lastRbfSummary) { rbfReplacements = rbfCache.getRbfTrees(false); fullRbfReplacements = rbfCache.getRbfTrees(true); - rbfSummary = rbfCache.getLatestRbfSummary(); + rbfSummary = rbfCache.getLatestRbfSummary() || []; + this.lastRbfSummary = rbfSummary; } for (const deletedTx of deletedTransactions) { diff --git a/frontend/src/app/services/websocket.service.ts b/frontend/src/app/services/websocket.service.ts index b4625b87c..53d3d5f5f 100644 --- a/frontend/src/app/services/websocket.service.ts +++ b/frontend/src/app/services/websocket.service.ts @@ -330,8 +330,8 @@ export class WebsocketService { this.stateService.rbfLatest$.next(response.rbfLatest); } - if (response.rbfLatestSummary) { - this.stateService.rbfLatestSummary$.next(response.rbfLatestSummary); + if (response.rbfLatestSummary !== undefined) { + this.stateService.rbfLatestSummary$.next(response.rbfLatestSummary || []); } if (response.txReplaced) {