fix: update chainhook predicate start_block upon re-registration (#308)

* fix: update chainhook predicate start_block upon re-registration

* fix: add missing test fields

* style: consider ENV network

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,18 @@ 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();
+      switch (ENV.NETWORK) {
+        case 'mainnet':
+          if (predicate.networks.mainnet) predicate.networks.mainnet.start_block = blockHeight;
+          break;
+        case 'testnet':
+          if (predicate.networks.testnet) predicate.networks.testnet.start_block = blockHeight;
+          break;
+      }
+      return predicate as Predicate;
+    },
   };
   const chainhook: ChainhookNodeOptions = {
     base_url: `http://${ENV.CHAINHOOK_NODE_RPC_HOST}:${ENV.CHAINHOOK_NODE_RPC_PORT}`,

src/chainhook/server.ts

@@ -1290,6 +1290,7 @@ export class TestChainhookPayloadBuilder {
       },
       is_streaming_blocks: true,
     },
+    events: [],
   };
   private action: 'apply' | 'rollback' = 'apply';
   private get lastBlock(): StacksEvent {
@@ -1330,6 +1331,13 @@ export class TestChainhookPayloadBuilder {
         pox_cycle_length: 2100,
         pox_cycle_position: 1722,
         stacks_block_hash: '0xbccf63ec2438cf497786ce617ec7e64e2b27ee023a28a0927ee36b81870115d2',
+        tenure_height: null,
+        block_time: null,
+        signer_bitvec: null,
+        signer_signature: null,
+        signer_public_keys: null,
+        cycle_number: null,
+        reward_set: null,
       },
       parent_block_identifier: {
         hash: '0xca71af03f9a3012491af2f59f3244ecb241551803d641f8c8306ffa1187938b4',