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

Manually re-index the last 10 blocks when the new block previoushash does not match latest block hash

Browse Source
This commit is contained in:
nymkappa 2022-04-19 15:45:06 +09:00
parent 900e02d9a5
commit 84b72f8b32
No known key found for this signature in database
GPG Key ID: E155910B16E8BD04
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
backend/src/api/blocks.ts
View File

@ -332,15 +332,17 @@ class Blocks {
if (Common.indexingEnabled()) { if (Common.indexingEnabled()) {
if (!fastForwarded) { if (!fastForwarded) {
const lastBlock = await blocksRepository.$getBlockByHeight(blockExtended.height - 1); const lastBlock = await blocksRepository.$getBlockByHeight(blockExtended.height - 1);
if (lastBlock !== null && blockExtended.id !== lastBlock['previousblockhash']) { if (lastBlock !== null && blockExtended.previousblockhash !== lastBlock['hash']) {
logger.warn(`Chain divergence detected at block ${lastBlock['height']}, re-indexing most recent data`); logger.warn(`Chain divergence detected at block ${lastBlock['height']}, re-indexing most recent data`);
await BlocksRepository.$deleteBlocksFrom(lastBlock['height'] - 2); // We assume there won't be a reorg with more than 10 block depth
await BlocksRepository.$deleteBlocksFrom(lastBlock['height'] - 10);
await HashratesRepository.$deleteLastEntries(); await HashratesRepository.$deleteLastEntries();
this.reindexFlag = true; for (let i = 10; i >= 0; --i) {
} else { await this.$indexBlock(lastBlock['height'] - i);
await blocksRepository.$saveBlockInDatabase(blockExtended);
} }
} }
await blocksRepository.$saveBlockInDatabase(blockExtended);
}
} }
if (block.height % 2016 === 0) { if (block.height % 2016 === 0) {