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

[health api] add indexing progress

Browse Source
This commit is contained in:
nymkappa 2023-10-02 11:08:10 +02:00
parent 545b3e7325
commit f80c0738b2
No known key found for this signature in database
GPG Key ID: E155910B16E8BD04
1 changed files with 20 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
backend/src/api/bitcoin/bitcoin.routes.ts
View File

@ -140,9 +140,18 @@ class BitcoinRoutes {
height: -1, height: -1,
indexing: { indexing: {
enabled: Common.indexingEnabled(), enabled: Common.indexingEnabled(),
indexedBlockCount: -1, blocks: {
indexedBlockCountWithCPFP: -1, count: -1,
indexedBlockCountWithCoinStats: -1, progress: -1,
withCpfp: {
count: -1,
progress: -1,
},
withCoinStats: {
count: -1,
progress: -1,
}
},
} }
}, },
}; };
@ -167,9 +176,14 @@ class BitcoinRoutes {
// Mempool // Mempool
response.mempool.height = blocks.getCurrentBlockHeight(); response.mempool.height = blocks.getCurrentBlockHeight();
if (Common.indexingEnabled()) { if (Common.indexingEnabled()) {
response.mempool.indexing.indexedBlockCount = await BlocksRepository.$getIndexedBlockCount(); const indexingBlockAmount = (config.MEMPOOL.INDEXING_BLOCKS_AMOUNT === -1 ? response.core.height : config.MEMPOOL.INDEXING_BLOCKS_AMOUNT);
response.mempool.indexing.indexedBlockCountWithCPFP = await BlocksRepository.$getIndexedCpfpBlockCount(); const computeProgress = (count: number): number => Math.min(1.0, Math.round(count / indexingBlockAmount * 100) / 100);
response.mempool.indexing.indexedBlockCountWithCoinStats = await BlocksRepository.$getIndexedCoinStatsBlockCount(); response.mempool.indexing.blocks.count = await BlocksRepository.$getIndexedBlockCount();
response.mempool.indexing.blocks.progress = computeProgress(response.mempool.indexing.blocks.count);
response.mempool.indexing.blocks.withCpfp.count = await BlocksRepository.$getIndexedCpfpBlockCount();
response.mempool.indexing.blocks.withCpfp.progress = computeProgress(response.mempool.indexing.blocks.withCpfp.count);
response.mempool.indexing.blocks.withCoinStats.count = await BlocksRepository.$getIndexedCoinStatsBlockCount();
response.mempool.indexing.blocks.withCoinStats.progress = computeProgress(response.mempool.indexing.blocks.withCoinStats.count);
} }
// Esplora // Esplora