fix: load correct abis for chain requests

Author: filo87

src/handlers/balanceSheetHandlers.ts

@@ -52,7 +52,7 @@ multiMapper("balanceSheet:NoteDeposit", async ({ event, context }) => {
   await snapshotter(
     context,
     event,
-    "balanceSheetV3:NoteDeposit",
+    "balanceSheetV3_1:NoteDeposit",
     [holdingEscrow],
     HoldingEscrowSnapshot
   );
@@ -99,7 +99,7 @@ multiMapper("balanceSheet:Withdraw", async ({ event, context }) => {
   await snapshotter(
     context,
     event,
-    "balanceSheetV3:Withdraw",
+    "balanceSheetV3_1:Withdraw",
     [holdingEscrow],
     HoldingEscrowSnapshot
   );

src/handlers/holdingsHandlers.ts

@@ -70,7 +70,7 @@ multiMapper("holdings:Increase", async ({ event, context }) => {
   await holding.increase(amount, increasedValue);
   await holding.save(event);
 
-  await snapshotter(context, event, "holdingsV3:Increase", [holding], HoldingSnapshot);
+  await snapshotter(context, event, "holdingsV3_1:Increase", [holding], HoldingSnapshot);
 });
 
 multiMapper("holdings:Decrease", async ({ event, context }) => {
@@ -122,7 +122,7 @@ multiMapper("holdings:Update", async ({ event, context }) => {
   await holding.update(isPositive, diffValue);
   await holding.save(event);
 
-  await snapshotter(context, event, "holdingsV3:Update", [holding], HoldingSnapshot);
+  await snapshotter(context, event, "holdingsV3_1:Update", [holding], HoldingSnapshot);
 });
 
 multiMapper("holdings:UpdateValuation", async ({ event, context }) => {
@@ -148,5 +148,5 @@ multiMapper("holdings:UpdateValuation", async ({ event, context }) => {
   await holding.setValuation(valuation);
   await holding.save(event);
 
-  await snapshotter(context, event, "holdingsV3:UpdateValuation", [holding], HoldingSnapshot);
+  await snapshotter(context, event, "holdingsV3_1:UpdateValuation", [holding], HoldingSnapshot);
 });

src/handlers/merkleProofManagerHandlers.ts

@@ -1,7 +1,7 @@
 import { multiMapper } from "../helpers/multiMapper";
 import { logEvent, serviceError } from "../helpers/logger";
 import { BlockchainService, MerkleProofManagerService, PolicyService } from "../services";
-import { Abis } from "../contracts";
+import { Abis, getVersionForContract, REGISTRY_VERSION_ORDER } from "../contracts";
 
 multiMapper("merkleProofManagerFactory:DeployMerkleProofManager", async ({ event, context }) => {
   logEvent(event, context, "merkleProofManagerFactory:DeployMerkleProofManager");
@@ -26,11 +26,13 @@ multiMapper("merkleProofManager:UpdatePolicy", async ({ event, context }) => {
   logEvent(event, context, "merkleProofManager:UpdatePolicy");
   const { strategist, newRoot } = event.args;
 
+  const indexerVersion = REGISTRY_VERSION_ORDER[0];
+
   const centrifugeId = await BlockchainService.getCentrifugeId(context);
 
   const poolId = await context.client.readContract({
     address: event.log.address,
-    abi: Abis.v3.MerkleProofManager,
+    abi: Abis[indexerVersion as keyof typeof Abis].MerkleProofManager,
     functionName: "poolId",
   });
 

src/handlers/spokeHandlers.ts

@@ -11,7 +11,7 @@ import {
   TokenInstancePositionService,
 } from "../services";
 import { ERC20Abi } from "../../abis/ERC20";
-import { Abis } from "../contracts";
+import { Abis, REGISTRY_VERSION_ORDER } from "../contracts";
 import { RegistryChains } from "../chains";
 import { snapshotter } from "../helpers/snapshotter";
 import { HoldingEscrowSnapshot } from "ponder:schema";
@@ -155,6 +155,7 @@ multiMapper("spoke:UpdateAssetPrice", async ({ event, context }) => {
   } = event.args;
 
   const centrifugeId = await BlockchainService.getCentrifugeId(context);
+  const indexerVersion = REGISTRY_VERSION_ORDER[0];
 
   const chainId = context.chain.id;
   const poolEscrowFactoryAddress = RegistryChains.find((chain) => chain.network.chainId === chainId)
@@ -165,7 +166,7 @@ multiMapper("spoke:UpdateAssetPrice", async ({ event, context }) => {
   }
 
   const escrowAddress = await context.client.readContract({
-    abi: Abis.v3.PoolEscrowFactory,
+    abi: Abis[indexerVersion as keyof typeof Abis].PoolEscrowFactory,
     address: poolEscrowFactoryAddress.address,
     functionName: "escrow",
     args: [poolId],
@@ -202,7 +203,7 @@ multiMapper("spoke:UpdateAssetPrice", async ({ event, context }) => {
   await snapshotter(
     context,
     event,
-    "spokeV3:UpdateAssetPrice",
+    "spokeV3_1:UpdateAssetPrice",
     [holdingEscrow],
     HoldingEscrowSnapshot
   );