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

more logs, reduce request chunk sizes

Browse Source
This commit is contained in:
Mononaut 2023-11-12 09:23:37 +00:00
parent a2f6ea7b3a
commit 5998b54fec
No known key found for this signature in database
GPG Key ID: A3F058E41374C04E
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
backend/src/api/bitcoin/esplora-api.ts
View File

@ -181,7 +181,8 @@ class FailoverRouter {
.catch((e) => { .catch((e) => {
let fallbackHost = this.fallbackHost; let fallbackHost = this.fallbackHost;
if (e?.response?.status !== 404) { if (e?.response?.status !== 404) {
logger.warn(`esplora request failed ${e?.response?.status || 500} ${host.host}${path}`); logger.warn(`esplora request failed ${e?.response?.status} ${host.host}${path}`);
logger.warn(e instanceof Error ? e.message : e);
fallbackHost = this.addFailure(host); fallbackHost = this.addFailure(host);
} }
if (retry && e?.code === 'ECONNREFUSED' && this.multihost) { if (retry && e?.code === 'ECONNREFUSED' && this.multihost) {

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

@ -480,14 +480,16 @@ class RbfCache {
}; };
if (config.MEMPOOL.BACKEND === 'esplora') { if (config.MEMPOOL.BACKEND === 'esplora') {
const sliceLength = 10000; const sliceLength = 1000;
for (let i = 0; i < Math.ceil(txids.length / sliceLength); i++) { for (let i = 0; i < Math.ceil(txids.length / sliceLength); i++) {
const slice = txids.slice(i * sliceLength, (i + 1) * sliceLength); const slice = txids.slice(i * sliceLength, (i + 1) * sliceLength);
try { try {
const txs = await bitcoinApi.$getRawTransactions(slice); const txs = await bitcoinApi.$getRawTransactions(slice);
logger.debug(`fetched ${slice.length} cached rbf transactions`);
processTxs(txs); processTxs(txs);
logger.debug(`processed ${slice.length} cached rbf transactions`);
} catch (err) { } catch (err) {
logger.err('failed to fetch some cached rbf transactions'); logger.err(`failed to fetch or process ${slice.length} cached rbf transactions`);
} }
} }
} else { } else {