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

Merge pull request #1591 from mempool/nymkappa/bugfix/chain-validation-block-height

Browse Source 
Skip missing blocks during block hash chain validation
This commit is contained in:
wiz 2022-05-17 15:56:27 +09:00 committed by GitHub
commit 2fd0c06092
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
backend/src/repositories/BlocksRepository.ts
View File

@ -397,18 +397,28 @@ class BlocksRepository {
const [blocks]: any[] = await DB.query(`SELECT height, hash, previous_block_hash, const [blocks]: any[] = await DB.query(`SELECT height, hash, previous_block_hash,
UNIX_TIMESTAMP(blockTimestamp) as timestamp FROM blocks ORDER BY height`); UNIX_TIMESTAMP(blockTimestamp) as timestamp FROM blocks ORDER BY height`);
let currentHeight = 1; let partialMsg = false;
while (currentHeight < blocks.length) { let idx = 1;
if (blocks[currentHeight].previous_block_hash !== blocks[currentHeight - 1].hash) { while (idx < blocks.length) {
logger.warn(`Chain divergence detected at block ${blocks[currentHeight - 1].height}, re-indexing newer blocks and hashrates`); if (blocks[idx].height - 1 !== blocks[idx - 1].height) {
await this.$deleteBlocksFrom(blocks[currentHeight - 1].height); if (partialMsg === false) {
await HashratesRepository.$deleteHashratesFromTimestamp(blocks[currentHeight - 1].timestamp - 604800); logger.info('Some blocks are not indexed, skipping missing blocks during chain validation');
partialMsg = true;
}
++idx;
continue;
}
if (blocks[idx].previous_block_hash !== blocks[idx - 1].hash) {
logger.warn(`Chain divergence detected at block ${blocks[idx - 1].height}, re-indexing newer blocks and hashrates`);
await this.$deleteBlocksFrom(blocks[idx - 1].height);
await HashratesRepository.$deleteHashratesFromTimestamp(blocks[idx - 1].timestamp - 604800);
return false; return false;
} }
++currentHeight; ++idx;
} }
logger.info(`${currentHeight} blocks hash validated in ${new Date().getTime() - start} ms`); logger.info(`${idx} blocks hash validated in ${new Date().getTime() - start} ms`);
return true; return true;
} catch (e) { } catch (e) {
logger.err('Cannot validate chain of block hash. Reason: ' + (e instanceof Error ? e.message : e)); logger.err('Cannot validate chain of block hash. Reason: ' + (e instanceof Error ? e.message : e));