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

Don't overload core with mempool tx requests

Browse Source
This commit is contained in:
Mononaut 2023-08-18 23:38:45 +09:00
parent f36ee36576
commit 1b2122cd35
No known key found for this signature in database
GPG Key ID: A3F058E41374C04E
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
backend/src/api/transaction-utils.ts
View File

@ -74,8 +74,18 @@ class TransactionUtils {
public async $getMempoolTransactionsExtended(txids: string[], addPrevouts = false, lazyPrevouts = false, forceCore = false): Promise<MempoolTransactionExtended[]> { public async $getMempoolTransactionsExtended(txids: string[], addPrevouts = false, lazyPrevouts = false, forceCore = false): Promise<MempoolTransactionExtended[]> {
if (forceCore || config.MEMPOOL.BACKEND !== 'esplora') { if (forceCore || config.MEMPOOL.BACKEND !== 'esplora') {
const results = await Promise.allSettled(txids.map(txid => this.$getTransactionExtended(txid, addPrevouts, lazyPrevouts, forceCore, true))); const results: MempoolTransactionExtended[] = [];
return (results.filter(r => r.status === 'fulfilled') as PromiseFulfilledResult<MempoolTransactionExtended>[]).map(r => r.value); for (const txid of txids) {
try {
const result = await this.$getMempoolTransactionExtended(txid, addPrevouts, lazyPrevouts, forceCore);
if (result) {
results.push(result);
}
} catch {
// skip failures
}
}
return results;
} else { } else {
const transactions = await bitcoinApi.$getMempoolTransactions(txids); const transactions = await bitcoinApi.$getMempoolTransactions(txids);
return transactions.map(transaction => { return transactions.map(transaction => {