fix: update chainhook predicate start_block upon re-registration

Author: rafaelcr

package-lock.json

@@ -58,7 +58,7 @@
     "@fastify/type-provider-typebox": "^3.2.0",
     "@google-cloud/storage": "^7.12.1",
     "@hirosystems/api-toolkit": "^1.7.1",
-    "@hirosystems/chainhook-client": "^2.0.0",
+    "@hirosystems/chainhook-client": "^2.4.0",
     "@sinclair/typebox": "^0.28.17",
     "@stacks/transactions": "^6.1.0",
     "@types/node": "^20.16.1",

package.json

@@ -4,6 +4,7 @@ import {
   EventObserverOptions,
   EventObserverPredicate,
   Payload,
+  Predicate,
   StacksPayload,
 } from '@hirosystems/chainhook-client';
 import { PgStore } from '../pg/pg-store';
@@ -66,6 +67,16 @@ export async function startChainhookServer(args: { db: PgStore }): Promise<Chain
     predicate_disk_file_path: ENV.CHAINHOOK_PREDICATE_PATH,
     predicate_health_check_interval_ms: 300_000,
     node_type: 'chainhook',
+    predicate_re_register_callback: async predicate => {
+      const blockHeight = await args.db.getChainTipBlockHeight();
+      if (predicate.networks.mainnet) {
+        predicate.networks.mainnet.start_block = blockHeight;
+      }
+      if (predicate.networks.testnet) {
+        predicate.networks.testnet.start_block = blockHeight;
+      }
+      return predicate as Predicate;
+    },
   };
   const chainhook: ChainhookNodeOptions = {
     base_url: `http://${ENV.CHAINHOOK_NODE_RPC_HOST}:${ENV.CHAINHOOK_NODE_RPC_PORT}`,