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

Update bulk /txs to use new failover router, internal-api path

Browse Source
This commit is contained in:
Mononaut 2023-08-16 18:30:18 +09:00
parent 38909cfc42
commit 156b5d0b3c
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/bitcoin/esplora-api.ts
View File

@ -214,7 +214,7 @@ class ElectrsApi implements AbstractBitcoinApi {
} }
async $getRawTransactions(txids: string[]): Promise<IEsploraApi.Transaction[]> { async $getRawTransactions(txids: string[]): Promise<IEsploraApi.Transaction[]> {
return this.$postWrapper<IEsploraApi.Transaction[]>(config.ESPLORA.REST_API_URL + '/txs', txids, 'json'); return this.failoverRouter.$post<IEsploraApi.Transaction[]>('/internal-api/txs', txids, 'json');
} }
async $getMempoolTransactions(txids: string[]): Promise<IEsploraApi.Transaction[]> { async $getMempoolTransactions(txids: string[]): Promise<IEsploraApi.Transaction[]> {

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

@ -505,10 +505,13 @@ class RbfCache {
if (config.MEMPOOL.BACKEND === 'esplora') { if (config.MEMPOOL.BACKEND === 'esplora') {
const sliceLength = 10000; const sliceLength = 10000;
let count = 0;
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);
count += txs.length;
logger.info(`Fetched ${count} of ${txids.length} unknown-status RBF transactions from esplora`);
processTxs(txs); processTxs(txs);
} catch (err) { } catch (err) {
logger.err('failed to fetch some cached rbf transactions'); logger.err('failed to fetch some cached rbf transactions');