252 fu cctp

packages/fast-usdc-contract/src/exos/advancer.ts

@@ -37,6 +37,8 @@ import {
 } from '@agoric/orchestration';
 import type { AccountId } from '@agoric/orchestration/src/orchestration-api.js';
 import { parseAccountIdArg } from '@agoric/orchestration/src/utils/address.js';
+import type { NobleMethods } from '@agoric/orchestration/src/cosmos-api.js';
+import { caipIdFromInfo } from '@agoric/orchestration/src/utils/chain-info.js';
 import type { ZoeTools } from '@agoric/orchestration/src/utils/zoe-tools.js';
 import { pickFacet } from '@agoric/vat-data';
 import type { VowTools } from '@agoric/vow';
@@ -46,6 +48,7 @@ import type { Zone } from '@agoric/zone';
 import { Fail, q } from '@endo/errors';
 import { E } from '@endo/far';
 import { M, mustMatch } from '@endo/patterns';
+import { makeSupportsCctp } from '../utils/cctp.ts';
 import type { LiquidityPoolKit } from './liquidity-pool.js';
 import type { SettlerKit } from './settler.js';
 import type { StatusManager } from './status-manager.js';
@@ -134,7 +137,7 @@ export const prepareAdvancerKit = (
     log = makeTracer('Advancer', true),
     statusManager,
     usdc,
-    vowTools: { watch, when },
+    vowTools: { asVow, watch, when },
     zcf,
     zoeTools: { localTransfer, withdrawToSeat },
   }: AdvancerKitPowers,
@@ -149,6 +152,8 @@ export const prepareAdvancerKit = (
   const feeTools = makeFeeTools(feeConfig);
   const toAmount = (value: bigint) => AmountMath.make(usdc.brand, value);
 
+  const supportsCctp = makeSupportsCctp(chainHub);
+
   return zone.exoClassKit(
     'Fast USDC Advancer',
     AdvancerKitI,
@@ -203,6 +208,20 @@ export const prepareAdvancerKit = (
             assert.typeof(EUD, 'string');
             // throws if the bech32 prefix is not found
             const destination = chainHub.resolveAccountId(EUD);
+            const accountId = parseAccountIdArg(destination);
+            const chainId = caipIdFromInfo(accountId);
+            const info = await when(chainHub.getChainInfoByChainId(chainId));
+
+            // These are the cases that are currently supported
+            if (
+              chainId !== settlementAddress.chainId &&
+              info.namespace !== 'cosmos' &&
+              !info.cctpDestinationDomain
+            ) {
+              statusManager.skipAdvance(evidence, [
+                `Transfer to ${chainId} not supported.`,
+              ]);
+            }
 
             const fullAmount = toAmount(evidence.tx.amount);
             const { borrower, notifier, poolAccount } = this.state;
@@ -256,28 +275,56 @@ export const prepareAdvancerKit = (
           result: undefined,
           ctx: AdvancerVowCtx & { tmpSeat: ZCFSeat },
         ) {
-          const { poolAccount, settlementAddress } = this.state;
-          const { destination, advanceAmount, tmpSeat, ...detail } = ctx;
-          tmpSeat.exit();
-          const amount = harden({
-            denom: usdc.denom,
-            value: advanceAmount.value,
-          });
-          const intermediateRecipient = getNobleICA().getAddress();
-          const accountId = parseAccountIdArg(destination);
+          return asVow(async () => {
+            const { poolAccount, settlementAddress } = this.state;
+            const { tmpSeat, ...vowContext } = ctx;
+            const { destination, advanceAmount, ...detail } = vowContext;
+            tmpSeat.exit();
+            const amount = harden({
+              denom: usdc.denom,
+              value: advanceAmount.value,
+            });
+            const accountId = parseAccountIdArg(destination);
+            await null;
 
-          assert.equal(accountId.namespace, 'cosmos');
+            const intermediateRecipient = getNobleICA().getAddress();
 
-          const transferOrSendV =
-            accountId.reference === settlementAddress.chainId
-              ? E(poolAccount).send(destination, amount)
-              : E(poolAccount).transfer(destination, amount, {
-                  forwardOpts: { intermediateRecipient },
-                });
-          return watch(transferOrSendV, this.facets.transferHandler, {
-            destination,
-            advanceAmount,
-            ...detail,
+            let transferOrSendV;
+            if (
+              accountId.namespace === 'cosmos' &&
+              accountId.reference === settlementAddress.chainId
+            ) {
+              // send to recipient on Agoric
+              transferOrSendV = E(poolAccount).send(destination, amount);
+            } else if (accountId.namespace === 'cosmos') {
+              // send via IBC
+
+              transferOrSendV = E(poolAccount).transfer(destination, amount, {
+                forwardOpts: {
+                  intermediateRecipient,
+                },
+              });
+            } else if (supportsCctp(destination)) {
+              // send USDC via CCTP
+
+              await E(poolAccount).transfer(intermediateRecipient, amount);
+              // assets are on noble, transfer to dest.
+
+              const intermediaryAccount = getNobleICA();
+              transferOrSendV = intermediaryAccount.depositForBurn(
+                destination,
+                amount,
+              );
+            } else {
+              // This was supposed to be caught in handleTransactionEvent()
+              Fail`can only transfer to Agoric addresses, via IBC, or via CCTP`;
+            }
+
+            return watch(
+              transferOrSendV,
+              this.facets.transferHandler,
+              vowContext,
+            );
           });
         },
         /**