From ab5c49ea7a7469b28b14d713a65f11cf4fd5a494 Mon Sep 17 00:00:00 2001
From: Mononaut <github@monospace.live>
Date: Tue, 1 Apr 2025 07:34:49 +0000
Subject: [PATCH] Reset block cache after updating pools

---
 backend/src/api/pools-parser.ts | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/backend/src/api/pools-parser.ts b/backend/src/api/pools-parser.ts
index 2fd55d6c5..2895da5a5 100644
--- a/backend/src/api/pools-parser.ts
+++ b/backend/src/api/pools-parser.ts
@@ -8,6 +8,7 @@ import mining from './mining/mining';
 import transactionUtils from './transaction-utils';
 import BlocksRepository from '../repositories/BlocksRepository';
 import redisCache from './redis-cache';
+import blocks from './blocks';
 
 class PoolsParser {
   miningPools: any[] = [];
@@ -42,6 +43,8 @@ class PoolsParser {
     await this.$insertUnknownPool();
 
     let reindexUnknown = false;
+    let clearCache = false;
+
 
     for (const pool of this.miningPools) {
       if (!pool.id) {
@@ -78,17 +81,20 @@ class PoolsParser {
         logger.debug(`Inserting new mining pool ${pool.name}`);
         await PoolsRepository.$insertNewMiningPool(pool, slug);
         reindexUnknown = true;
+        clearCache = true;
       } else {
         if (poolDB.name !== pool.name) {
           // Pool has been renamed
           const newSlug = pool.name.replace(/[^a-z0-9]/gi, '').toLowerCase();
           logger.warn(`Renaming ${poolDB.name} mining pool to ${pool.name}. Slug has been updated. Maybe you want to make a redirection from 'https://mempool.space/mining/pool/${poolDB.slug}' to 'https://mempool.space/mining/pool/${newSlug}`);
           await PoolsRepository.$renameMiningPool(poolDB.id, newSlug, pool.name);
+          clearCache = true;
         }
         if (poolDB.link !== pool.link) {
           // Pool link has changed
           logger.debug(`Updating link for ${pool.name} mining pool`);
           await PoolsRepository.$updateMiningPoolLink(poolDB.id, pool.link);
+          clearCache = true;
         }
         if (JSON.stringify(pool.addresses) !== poolDB.addresses ||
           JSON.stringify(pool.regexes) !== poolDB.regexes) {
@@ -96,6 +102,7 @@ class PoolsParser {
           logger.notice(`Updating addresses and/or coinbase tags for ${pool.name} mining pool.`);
           await PoolsRepository.$updateMiningPoolTags(poolDB.id, pool.addresses, pool.regexes);
           reindexUnknown = true;
+          clearCache = true;
           await this.$reindexBlocksForPool(poolDB.id);
         }
       }
@@ -111,6 +118,19 @@ class PoolsParser {
       }
       await this.$reindexBlocksForPool(unknownPool.id);
     }
+
+    // refresh the in-memory block cache with the reindexed data
+    if (clearCache) {
+      for (const block of blocks.getBlocks()) {
+        const reindexedBlock = await blocks.$indexBlock(block.height);
+        if (reindexedBlock.id === block.id) {
+          block.extras.pool = reindexedBlock.extras.pool;
+        }
+      }
+      // update persistent cache with the reindexed data
+      diskCache.$saveCacheToDisk();
+      redisCache.$updateBlocks(blocks.getBlocks());
+    }
   }
 
   public matchBlockMiner(scriptsig: string, addresses: string[], pools: PoolTag[]): PoolTag | undefined {