feat: update finalizer to handle quote deadline with emergencyReceive (#3026)

* feat: update finalizer to handle quote deadline with emergencyReceive

* Fix

* add emergencyReceive ABI

---------

Co-authored-by: Alexandru Matei <alexandrumatei3693@gmail.com>
Co-authored-by: Melisa Guevara <melisaguevarav@gmail.com>
Co-authored-by: nicholaspai <9457025+nicholaspai@users.noreply.github.com>

Author: 4 people

src/cctp-finalizer/services/cctpService.ts

@@ -50,6 +50,7 @@ export class CCTPService {
         attestation: cctpAttestationUnion,
         destinationChainId: providedDestinationChainIdUnion,
         signature: signatureUnion,
+        quoteDeadline: quoteDeadlineUnion,
       } = message;
 
       this.evmPrivateKey = await this.getPrivateKey("evm");
@@ -59,6 +60,7 @@ export class CCTPService {
       const cctpAttestation = cctpAttestationUnion?.string;
       const providedDestinationChainId = providedDestinationChainIdUnion?.long;
       const signature = signatureUnion?.string;
+      const quoteDeadline = quoteDeadlineUnion?.long;
 
       this.logger.info({
         at: "CCTPService#processBurnTransaction",
@@ -168,7 +170,7 @@ export class CCTPService {
       }
 
       // Process the mint
-      return await this.processMint(destinationChainId, sourceChainId, attestation, signature);
+      return await this.processMint(destinationChainId, sourceChainId, attestation, signature, quoteDeadline);
     } catch (error) {
       if (isCCTPError(error)) {
         if (error instanceof AlreadyProcessedError) {
@@ -250,7 +252,8 @@ export class CCTPService {
     destinationChainId: number,
     originChainId: number,
     attestation: any,
-    signature?: string
+    signature?: string,
+    quoteDeadline?: number
   ): Promise<ProcessBurnTransactionResponse> {
     const chainName = PUBLIC_NETWORKS[destinationChainId]?.name || `Chain ${destinationChainId}`;
     this.logger.info({
@@ -290,7 +293,8 @@ export class CCTPService {
           provider,
           this.evmPrivateKey,
           this.logger,
-          signature
+          signature,
+          quoteDeadline
         );
         return {
           success: true,

src/cctp-finalizer/types/index.ts

@@ -23,6 +23,7 @@ export interface PubSubMessage {
   attestation?: StringUnion | null;
   destinationChainId?: LongUnion | null;
   signature?: StringUnion | null;
+  quoteDeadline?: LongUnion | null;
 }
 
 export interface ChainConfig {

src/cctp-finalizer/utils/evmUtils.ts

@@ -135,7 +135,8 @@ export async function processMintEvm(
   provider: ethers.providers.JsonRpcProvider,
   privateKey: string,
   logger: winston.Logger,
-  signature?: string
+  signature?: string,
+  quoteDeadline?: number
 ): Promise<{ txHash: string }> {
   const signer = new ethers.Wallet(privateKey, provider);
 
@@ -147,10 +148,17 @@ export async function processMintEvm(
 
   const contract = new ethers.Contract(destination.address, destination.abi, signer);
 
-  const receiveMessageArgs = destination.requiresSignature
+  let receiveMessageArgs = destination.requiresSignature
     ? [attestation.message, attestation.attestation, signature]
     : [attestation.message, attestation.attestation];
 
+  // if the quote deadline has expired, we don't need to pass the signature
+  let method = "receiveMessage";
+  if (destination.requiresSignature && quoteDeadline < Date.now() / 1000) {
+    receiveMessageArgs = [attestation.message, attestation.attestation];
+    method = "emergencyReceiveMessage";
+  }
+
   logger.info({
     at: "evmUtils#processMintEvm",
     message: `Using ${destination.type} destination contract`,
@@ -163,7 +171,7 @@ export async function processMintEvm(
   const mintTx = await submitTransaction(
     {
       contract: contract,
-      method: "receiveMessage",
+      method,
       args: receiveMessageArgs,
       chainId,
     },

src/common/abi/SponsoredCCTPDstPeriphery.json

@@ -21,5 +21,23 @@
     "outputs": [],
     "stateMutability": "nonpayable",
     "type": "function"
+  },
+  {
+    "inputs": [
+      {
+        "internalType": "bytes",
+        "name": "message",
+        "type": "bytes"
+      },
+      {
+        "internalType": "bytes",
+        "name": "attestation",
+        "type": "bytes"
+      }
+    ],
+    "name": "emergencyReceiveMessage",
+    "outputs": [],
+    "stateMutability": "nonpayable",
+    "type": "function"
   }
 ]