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

add missing rbf eviction

Browse Source
This commit is contained in:
Mononaut 2023-05-04 19:10:53 -04:00
parent d322c6b5b5
commit 3d0f7d6855
No known key found for this signature in database
GPG Key ID: A3F058E41374C04E
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
backend/src/api/rbf-cache.ts
View File

@ -163,7 +163,7 @@ class RbfCache {
} }
// flag a transaction as removed from the mempool // flag a transaction as removed from the mempool
public evict(txid, fast: boolean = false): void { public evict(txid: string, fast: boolean = false): void {
if (this.txs.has(txid) && (fast || !this.expiring.has(txid))) { if (this.txs.has(txid) && (fast || !this.expiring.has(txid))) {
this.expiring.set(txid, fast ? Date.now() + (1000 * 60 * 10) : Date.now() + (1000 * 86400)); // 24 hours this.expiring.set(txid, fast ? Date.now() + (1000 * 60 * 10) : Date.now() + (1000 * 86400)); // 24 hours
} }

3
backend/src/api/websocket-handler.ts
View File

@ -301,6 +301,9 @@ class WebsocketHandler {
rbfReplacements = rbfCache.getRbfTrees(false); rbfReplacements = rbfCache.getRbfTrees(false);
fullRbfReplacements = rbfCache.getRbfTrees(true); fullRbfReplacements = rbfCache.getRbfTrees(true);
} }
for (const deletedTx of deletedTransactions) {
rbfCache.evict(deletedTx.txid);
}
const recommendedFees = feeApi.getRecommendedFee(); const recommendedFees = feeApi.getRecommendedFee();
this.wss.clients.forEach(async (client) => { this.wss.clients.forEach(async (client) => {