From 117aa1375d4570c14df319b7776aa44e97544219 Mon Sep 17 00:00:00 2001
From: nymkappa <1612910616@pm.me>
Date: Sun, 12 Feb 2023 22:44:04 +0900
Subject: [PATCH] Disable mining pools update if AUTOMATIC_BLOCK_REINDEXING is
 not set - Re-index unknown blocks when a new pool is added

---
 backend/src/api/pools-parser.ts    | 11 +++++++++++
 backend/src/tasks/pools-updater.ts |  5 +++++
 2 files changed, 16 insertions(+)

diff --git a/backend/src/api/pools-parser.ts b/backend/src/api/pools-parser.ts
index 4ba38876d..7632f1207 100644
--- a/backend/src/api/pools-parser.ts
+++ b/backend/src/api/pools-parser.ts
@@ -37,6 +37,7 @@ class PoolsParser {
         const slug = pool.name.replace(/[^a-z0-9]/gi, '').toLowerCase();
         logger.debug(`Inserting new mining pool ${pool.name}`);
         await PoolsRepository.$insertNewMiningPool(pool, slug);
+        await this.$deleteUnknownBlocks();
       } else {
         if (poolDB.name !== pool.name) {
           // Pool has been renamed
@@ -126,6 +127,16 @@ class PoolsParser {
       [pool.id]
     );
   }
+
+  private async $deleteUnknownBlocks(): Promise<void> {
+    const [unknownPool] = await DB.query(`SELECT id from pools where slug = "unknown"`);
+    logger.notice(`Deleting blocks with unknown mining pool from height 130635 for re-indexing`);
+    await DB.query(`
+      DELETE FROM blocks
+      WHERE pool_id = ? AND height >= 130635`,
+      [unknownPool[0].id]
+    );
+  }
 }
 
 export default new PoolsParser();
diff --git a/backend/src/tasks/pools-updater.ts b/backend/src/tasks/pools-updater.ts
index a58e2177a..cbe137163 100644
--- a/backend/src/tasks/pools-updater.ts
+++ b/backend/src/tasks/pools-updater.ts
@@ -17,6 +17,11 @@ class PoolsUpdater {
   treeUrl: string = config.MEMPOOL.POOLS_JSON_TREE_URL;
 
   public async updatePoolsJson(): Promise<void> {
+    if (config.MEMPOOL.AUTOMATIC_BLOCK_REINDEXING === false) {
+      logger.info(`Not updating mining pools to avoid inconsistency because AUTOMATIC_BLOCK_REINDEXING is set to false`)
+      return;
+    }
+
     if (['mainnet', 'testnet', 'signet'].includes(config.MEMPOOL.NETWORK) === false) {
       return;
     }