nikolas: track sponsored account activation

packages/indexer-database/src/entities/evm/SponsoredAccountActivation.ts

@@ -0,0 +1,67 @@
+import {
+  Entity,
+  PrimaryGeneratedColumn,
+  Column,
+  Index,
+  Unique,
+  CreateDateColumn,
+  DeleteDateColumn,
+} from "typeorm";
+
+@Entity({ schema: "evm" })
+@Unique("UK_sponsoredAccountActivation_chain_block_tx_log", [
+  "chainId",
+  "blockNumber",
+  "transactionHash",
+  "logIndex",
+])
+@Index("IX_SponsoredAccountActivation_chainId", ["chainId"])
+@Index("IX_SponsoredAccountActivation_quoteNonce", ["quoteNonce"])
+@Index("IX_SponsoredAccountActivation_blockNumber", ["blockNumber"])
+@Index("IX_SponsoredAccountActivation_blockTimestamp", ["blockTimestamp"])
+@Index("IX_SponsoredAccountActivation_deletedAt", ["deletedAt"])
+@Index("IX_SponsoredAccountActivation_finalised", ["finalised"])
+@Index("IX_SponsoredAccountActivation_finalRecipient", ["finalRecipient"])
+export class SponsoredAccountActivation {
+  @PrimaryGeneratedColumn()
+  id: number;
+
+  @Column({ type: "bigint" })
+  chainId: string;
+
+  @Column({ nullable: true })
+  quoteNonce: string;
+
+  @Column()
+  finalRecipient: string;
+
+  @Column()
+  fundingToken: string;
+
+  @Column({ type: "numeric" })
+  evmAmountSponsored: string;
+
+  @Column()
+  blockNumber: number;
+
+  @Column()
+  transactionHash: string;
+
+  @Column()
+  transactionIndex: number;
+
+  @Column()
+  logIndex: number;
+
+  @Column()
+  finalised: boolean;
+
+  @Column()
+  blockTimestamp: Date;
+
+  @CreateDateColumn()
+  createdAt: Date;
+
+  @DeleteDateColumn({ nullable: true })
+  deletedAt?: Date;
+}

packages/indexer-database/src/entities/index.ts

@@ -51,3 +51,4 @@ export * from "./evm/SponsoredOFTSend";
 export * from "./evm/SimpleTransferFlowCompleted";
 export * from "./evm/ArbitraryActionsExecuted";
 export * from "./evm/FallbackHyperEVMFlowCompleted";
+export * from "./evm/SponsoredAccountActivation";

packages/indexer-database/src/main.ts

@@ -80,6 +80,7 @@ export const createDataSource = (config: DatabaseConfig): DataSource => {
       entities.SimpleTransferFlowCompleted,
       entities.ArbitraryActionsExecuted,
       entities.FallbackHyperEVMFlowCompleted,
+      entities.SponsoredAccountActivation,
     ],
     migrationsTableName: "_migrations",
     migrations: ["migrations/*.ts"],

packages/indexer-database/src/migrations/1763557964556-SponsoredAccountActivation.ts

@@ -0,0 +1,76 @@
+import { MigrationInterface, QueryRunner } from "typeorm";
+
+export class SponsoredAccountActivation1763557964556
+  implements MigrationInterface
+{
+  name = "SponsoredAccountActivation1763557964556";
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `CREATE TABLE "evm"."sponsored_account_activation" (
+        "id" SERIAL NOT NULL,
+        "chainId" bigint NOT NULL,
+        "quoteNonce" character varying,
+        "finalRecipient" character varying NOT NULL,
+        "fundingToken" character varying NOT NULL,
+        "evmAmountSponsored" numeric NOT NULL,
+        "blockNumber" integer NOT NULL,
+        "transactionHash" character varying NOT NULL,
+        "transactionIndex" integer NOT NULL,
+        "logIndex" integer NOT NULL,
+        "finalised" boolean NOT NULL DEFAULT false,
+        "blockTimestamp" TIMESTAMP NOT NULL,
+        "createdAt" TIMESTAMP NOT NULL DEFAULT now(),
+        "deletedAt" TIMESTAMP,
+        CONSTRAINT "UK_sponsoredAccountActivation_chain_block_tx_log" UNIQUE ("chainId", "blockNumber", "transactionHash", "logIndex"),
+        CONSTRAINT "PK_sponsoredAccountActivation_id" PRIMARY KEY ("id")
+      )`,
+    );
+    await queryRunner.query(
+      `CREATE INDEX "IX_SponsoredAccountActivation_chainId" ON "evm"."sponsored_account_activation" ("chainId") `,
+    );
+    await queryRunner.query(
+      `CREATE INDEX "IX_SponsoredAccountActivation_quoteNonce" ON "evm"."sponsored_account_activation" ("quoteNonce") `,
+    );
+    await queryRunner.query(
+      `CREATE INDEX "IX_SponsoredAccountActivation_finalRecipient" ON "evm"."sponsored_account_activation" ("finalRecipient") `,
+    );
+    await queryRunner.query(
+      `CREATE INDEX "IX_SponsoredAccountActivation_blockNumber" ON "evm"."sponsored_account_activation" ("blockNumber") `,
+    );
+    await queryRunner.query(
+      `CREATE INDEX "IX_SponsoredAccountActivation_finalised" ON "evm"."sponsored_account_activation" ("finalised") `,
+    );
+    await queryRunner.query(
+      `CREATE INDEX "IX_SponsoredAccountActivation_blockTimestamp" ON "evm"."sponsored_account_activation" ("blockTimestamp") `,
+    );
+    await queryRunner.query(
+      `CREATE INDEX "IX_SponsoredAccountActivation_deletedAt" ON "evm"."sponsored_account_activation" ("deletedAt") `,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `DROP INDEX "evm"."IX_SponsoredAccountActivation_deletedAt"`,
+    );
+    await queryRunner.query(
+      `DROP INDEX "evm"."IX_SponsoredAccountActivation_blockTimestamp"`,
+    );
+    await queryRunner.query(
+      `DROP INDEX "evm"."IX_SponsoredAccountActivation_finalised"`,
+    );
+    await queryRunner.query(
+      `DROP INDEX "evm"."IX_SponsoredAccountActivation_blockNumber"`,
+    );
+    await queryRunner.query(
+      `DROP INDEX "evm"."IX_SponsoredAccountActivation_finalRecipient"`,
+    );
+    await queryRunner.query(
+      `DROP INDEX "evm"."IX_SponsoredAccountActivation_quoteNonce"`,
+    );
+    await queryRunner.query(
+      `DROP INDEX "evm"."IX_SponsoredAccountActivation_chainId"`,
+    );
+    await queryRunner.query(`DROP TABLE "evm"."sponsored_account_activation"`);
+  }
+}

packages/indexer/src/data-indexing/model/hyperEvmExecutor.ts

@@ -1,5 +1,18 @@
 import { BigNumber, providers } from "ethers";
 
+export const SPONSORED_ACCOUNT_ACTIVATION_ABI = [
+  "event SponsoredAccountActivation(bytes32 indexed quoteNonce, address indexed finalRecipient, address indexed fundingToken, uint256 evmAmountSponsored)",
+];
+
+export interface SponsoredAccountActivationLog extends providers.Log {
+  args: {
+    quoteNonce: string;
+    finalRecipient: string;
+    fundingToken: string;
+    evmAmountSponsored: BigNumber;
+  };
+}
+
 export interface SimpleTransferFlowCompletedLog extends providers.Log {
   args: {
     quoteNonce: string;

packages/indexer/src/data-indexing/service/CCTPIndexerDataHandler.ts

@@ -8,6 +8,8 @@ import {
   SimpleTransferFlowCompletedLog,
   ArbitraryActionsExecutedLog,
   FallbackHyperEVMFlowCompletedLog,
+  SponsoredAccountActivationLog,
+  SPONSORED_ACCOUNT_ACTIVATION_ABI,
 } from "../model";
 import { IndexerDataHandler } from "./IndexerDataHandler";
 import { EventDecoder } from "../../web3/EventDecoder";
@@ -42,6 +44,7 @@ import { entities, SaveQueryResult } from "@repo/indexer-database";
 import {
   formatFallbackHyperEVMFlowCompletedEvent,
   formatSimpleTransferFlowCompletedEvent,
+  formatSponsoredAccountActivationEvent,
 } from "./hyperEvmExecutor";
 import {
   formatAndSaveEvents,
@@ -63,6 +66,7 @@ export type FetchEventsResult = {
   simpleTransferFlowCompletedEvents: SimpleTransferFlowCompletedLog[];
   arbitraryActionsExecutedEvents: ArbitraryActionsExecutedLog[];
   fallbackHyperEVMFlowCompletedEvents: FallbackHyperEVMFlowCompletedLog[];
+  sponsoredAccountActivationEvents: SponsoredAccountActivationLog[];
   blocks: Record<string, providers.Block>;
   transactionReceipts: Record<string, providers.TransactionReceipt>;
   transactions: Record<string, Transaction>;
@@ -80,6 +84,7 @@ export type StoreEventsResult = {
   savedSimpleTransferFlowCompletedEvents: SaveQueryResult<entities.SimpleTransferFlowCompleted>[];
   savedArbitraryActionsExecutedEvents: SaveQueryResult<entities.ArbitraryActionsExecuted>[];
   savedFallbackHyperEVMFlowCompletedEvents: SaveQueryResult<entities.FallbackHyperEVMFlowCompleted>[];
+  savedSponsoredAccountActivationEvents: SaveQueryResult<entities.SponsoredAccountActivation>[];
 };
 
 // Taken from https://developers.circle.com/cctp/evm-smart-contracts
@@ -295,6 +300,7 @@ export class CCTPIndexerDataHandler implements IndexerDataHandler {
     let arbitraryActionsExecutedEvents: ArbitraryActionsExecutedLog[] = [];
     let fallbackHyperEVMFlowCompletedEvents: FallbackHyperEVMFlowCompletedLog[] =
       [];
+    let sponsoredAccountActivationEvents: SponsoredAccountActivationLog[] = [];
     if (sponsoredCCTPDstPeripheryAddress) {
       simpleTransferFlowCompletedEvents = getEventsFromTransactionReceipts(
         filteredMessageReceivedTxReceipts,
@@ -313,6 +319,17 @@ export class CCTPIndexerDataHandler implements IndexerDataHandler {
         sponsoredCCTPDstPeripheryAddress,
         EventDecoder.decodeFallbackHyperEVMFlowCompletedEvents,
       );
+      const sponsoredCCTPDstPeripheryContract = new ethers.Contract(
+        sponsoredCCTPDstPeripheryAddress,
+        SPONSORED_ACCOUNT_ACTIVATION_ABI,
+        this.provider,
+      );
+      sponsoredAccountActivationEvents =
+        (await sponsoredCCTPDstPeripheryContract.queryFilter(
+          "SponsoredAccountActivation",
+          blockRange.from,
+          blockRange.to,
+        )) as unknown as SponsoredAccountActivationLog[];
     }
 
     this.runChecks(burnEvents, mintEvents);
@@ -337,6 +354,7 @@ export class CCTPIndexerDataHandler implements IndexerDataHandler {
       simpleTransferFlowCompletedEvents,
       arbitraryActionsExecutedEvents,
       fallbackHyperEVMFlowCompletedEvents,
+      sponsoredAccountActivationEvents,
       blocks,
       transactionReceipts,
       transactions: depositForBurnTransactions,
@@ -531,6 +549,7 @@ export class CCTPIndexerDataHandler implements IndexerDataHandler {
       simpleTransferFlowCompletedEvents,
       arbitraryActionsExecutedEvents,
       fallbackHyperEVMFlowCompletedEvents,
+      sponsoredAccountActivationEvents,
       blocks,
     } = events;
     const blocksTimestamps = this.getBlocksTimestamps(blocks);
@@ -560,6 +579,7 @@ export class CCTPIndexerDataHandler implements IndexerDataHandler {
       savedSimpleTransferFlowCompletedEvents,
       savedArbitraryActionsExecutedEvents,
       savedFallbackHyperEVMFlowCompletedEvents,
+      savedSponsoredAccountActivationEvents,
     ] = await Promise.all([
       this.cctpRepository.formatAndSaveBurnEvents(
         chainAgnosticBurnEvents,
@@ -605,6 +625,16 @@ export class CCTPIndexerDataHandler implements IndexerDataHandler {
         entities.FallbackHyperEVMFlowCompleted,
         primaryKeyColumns as (keyof entities.FallbackHyperEVMFlowCompleted)[],
       ),
+      formatAndSaveEvents(
+        this.cctpRepository,
+        sponsoredAccountActivationEvents,
+        lastFinalisedBlock,
+        this.chainId,
+        blocksTimestamps,
+        formatSponsoredAccountActivationEvent,
+        entities.SponsoredAccountActivation,
+        primaryKeyColumns as (keyof entities.SponsoredAccountActivation)[],
+      ),
     ]);
 
     return {
@@ -614,6 +644,7 @@ export class CCTPIndexerDataHandler implements IndexerDataHandler {
       savedSimpleTransferFlowCompletedEvents,
       savedArbitraryActionsExecutedEvents,
       savedFallbackHyperEVMFlowCompletedEvents,
+      savedSponsoredAccountActivationEvents,
     };
   }