From 02ccdfddb7da0c7f9653d217556dba5c3afb5026 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Andr=C3=A9s=20Elizondo?= <andres@0xproject.com>
Date: Wed, 9 Oct 2024 11:12:39 -0600
Subject: [PATCH] Adds transaction backfill for Blocks mode.

---
 src/index.ts                              | 6 ++++++
 src/scripts/pull_and_save_block_events.ts | 4 ++--
 2 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/src/index.ts b/src/index.ts
index 4557d0f9..df29d68e 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -92,6 +92,12 @@ createConnection(ormConfig as ConnectionOptions)
         if (SCRAPER_MODE === 'BLOCKS') {
             schedule(connection, producer, blockEventsScraper.getParseSaveAsync, 'Pull and Save Blocks and Events');
             schedule(connection, producer, blockEventsScraper.backfillAsync, 'Backfill Blocks and Events');
+            schedule(
+                connection,
+                producer,
+                backfillTxScraper.getParseSaveTxBackfillAsync,
+                'Pull and Save Backfill Transactions',
+            );
             schedule(connection, producer, eventsBackfillScraper.getParseSaveEventsAsync, 'Backfill Events by Topic');
         } else if (SCRAPER_MODE === 'EVENTS') {
             schedule(null, null, currentBlockMonitor.monitor, 'Current Block');
diff --git a/src/scripts/pull_and_save_block_events.ts b/src/scripts/pull_and_save_block_events.ts
index ea804c4d..99a1844c 100644
--- a/src/scripts/pull_and_save_block_events.ts
+++ b/src/scripts/pull_and_save_block_events.ts
@@ -359,7 +359,7 @@ export class BlockEventsScraper {
 
         const oldestBlocksToBackfill = await connection.query(
             `SELECT DISTINCT block_number
-             FROM ${SCHEMA}.tx_backfill
+             FROM ${SCHEMA}.block_backfill
              WHERE done = false
              ORDER BY block_number
              LIMIT ${MAX_BLOCKS_TO_PULL}`,
@@ -379,7 +379,7 @@ export class BlockEventsScraper {
                 const queryRunner = connection.createQueryRunner();
                 await queryRunner.connect();
                 await queryRunner.manager.query(
-                    `UPDATE ${SCHEMA}.tx_backfill
+                    `UPDATE ${SCHEMA}.block_backfill
                      SET done = true
                      WHERE block_number IN (${newBlockNumbers.join(',')})`,
                 );