Manual resume (#629)

* wip

* resume for tb

* circle resume

* inline "ben" variable aha

* fix error msg

* use same approach for tokenbridge as for cctp

* use from()

* allow toChain to be passed in

Author: artursapek

connect/src/protocols/tokenBridge/tokenTransfer.ts

@@ -349,7 +349,6 @@ export namespace TokenTransfer {
     const leftover = (start: number, max: number) => Math.max(max - (Date.now() - start), 0);
 
     fromChain = fromChain ?? wh.getChain(receipt.from);
-    toChain = toChain ?? wh.getChain(receipt.to);
 
     // Check the source chain for initiation transaction
     // and capture the message id
@@ -403,8 +402,12 @@ export namespace TokenTransfer {
     if (isAttested(receipt) || isRedeemed(receipt)) {
       if (!receipt.attestation.attestation) throw "Signed Attestation required to check for redeem";
 
+      if (receipt.attestation.attestation.payloadName === 'AttestMeta') {
+        throw new Error('Unable to track an AttestMeta receipt');
+      }
+
       let isComplete = await TokenTransfer.isTransferComplete(
-        toChain,
+        toChain ?? wh.getChain(receipt.attestation.attestation.payload.to.chain),
         receipt.attestation.attestation as TokenTransfer.VAA,
       );
 

connect/src/routes/cctp/manual.ts

@@ -6,6 +6,7 @@ import type {
   CircleTransferDetails,
   Signer,
   TokenId,
+  TransactionId,
 } from "@wormhole-foundation/sdk-definitions";
 import { CircleBridge, isSameToken } from "@wormhole-foundation/sdk-definitions";
 import { signSendWait } from "../../common.js";
@@ -170,7 +171,7 @@ export class CCTPRoute<N extends Network>
       const { message, attestation } = att;
       if (!attestation) throw new Error(`No Circle attestation for ${id}`);
 
-      const toChain = await this.wh.getChain(receipt.to);
+      const toChain = this.wh.getChain(receipt.to);
       const cb = await toChain.getCircleBridge();
       const xfer = cb.redeem(message.payload.mintRecipient, message, attestation);
       const dstTxids = await signSendWait<N, Chain>(toChain, xfer, signer);
@@ -185,6 +186,11 @@ export class CCTPRoute<N extends Network>
     }
   }
 
+  async resume(txid: TransactionId): Promise<R> {
+    const xfer = await CircleTransfer.from(this.wh, txid, 10 * 1000);
+    return CircleTransfer.getReceipt(xfer);
+  }
+
   public override async *track(receipt: R, timeout?: number) {
     yield* CircleTransfer.track(this.wh, receipt, timeout);
   }

connect/src/routes/route.ts

@@ -1,5 +1,5 @@
 import type { Chain, Network } from "@wormhole-foundation/sdk-base";
-import type { ChainContext, Signer, TokenId } from "@wormhole-foundation/sdk-definitions";
+import type { ChainContext, Signer, TokenId, TransactionId } from "@wormhole-foundation/sdk-definitions";
 import type { Wormhole } from "../wormhole.js";
 import type { RouteTransferRequest } from "./request.js";
 import type {
@@ -130,6 +130,7 @@ export abstract class ManualRoute<
   NATIVE_GAS_DROPOFF_SUPPORTED = false;
   IS_AUTOMATIC = false;
   public abstract complete(sender: Signer, receipt: R): Promise<R>;
+  public abstract resume(tx: TransactionId): Promise<R>;
 }
 
 export function isManual<N extends Network>(route: Route<N>): route is ManualRoute<N> {

connect/src/routes/tokenBridge/manual.ts

@@ -6,6 +6,7 @@ import type {
   Signer,
   TokenId,
   TokenTransferDetails,
+  TransactionId,
 } from "@wormhole-foundation/sdk-definitions";
 import { TokenTransfer } from "../../protocols/tokenBridge/tokenTransfer.js";
 import type {
@@ -168,6 +169,11 @@ export class TokenBridgeRoute<N extends Network>
       destinationTxs: dstTxIds,
     };
   }
+  
+  async resume(txid: TransactionId): Promise<R> {
+    const xfer = await TokenTransfer.from(this.wh, txid, 10 * 1000);
+    return TokenTransfer.getReceipt(xfer);
+  }
 
   public override async *track(receipt: R, timeout?: number) {
     yield* TokenTransfer.track(this.wh, receipt, timeout);