diff --git a/backend/src/api/pools-parser.ts b/backend/src/api/pools-parser.ts index f17df385a..f94c147a2 100644 --- a/backend/src/api/pools-parser.ts +++ b/backend/src/api/pools-parser.ts @@ -39,6 +39,10 @@ class PoolsParser { * @param pools */ public async migratePoolsJson(): Promise { + // We also need to wipe the backend cache to make sure we don't serve blocks with + // the wrong mining pool (usually happen with unknown blocks) + diskCache.wipeCache(); + await this.$insertUnknownPool(); for (const pool of this.miningPools) { @@ -142,10 +146,6 @@ class PoolsParser { WHERE pool_id = ?`, [pool.id] ); - - // We also need to wipe the backend cache to make sure we don't serve blocks with - // the wrong mining pool (usually happen with unknown blocks) - diskCache.wipeCache(); } private async $deleteUnknownBlocks(): Promise { @@ -156,10 +156,6 @@ class PoolsParser { WHERE pool_id = ? AND height >= 130635`, [unknownPool[0].id] ); - - // We also need to wipe the backend cache to make sure we don't serve blocks with - // the wrong mining pool (usually happen with unknown blocks) - diskCache.wipeCache(); } } diff --git a/backend/src/index.ts b/backend/src/index.ts index 812b49e15..29a6b1a72 100644 --- a/backend/src/index.ts +++ b/backend/src/index.ts @@ -113,6 +113,7 @@ class Server { this.setUpWebsocketHandling(); + await poolsUpdater.updatePoolsJson(); // Needs to be done before loading the disk cache because we sometimes wipe it await syncAssets.syncAssets$(); if (config.MEMPOOL.ENABLED) { diskCache.loadMempoolCache(); @@ -171,7 +172,6 @@ class Server { logger.debug(msg); } } - await poolsUpdater.updatePoolsJson(); await blocks.$updateBlocks(); await memPool.$updateMempool(); indexer.$run();