feat: build cross swap tx

api/_dexes/cross-swap.ts

@@ -1,21 +1,31 @@
+import { SpokePool } from "@across-protocol/contracts/dist/typechain";
+
 import {
   isRouteEnabled,
   isInputTokenBridgeable,
   isOutputTokenBridgeable,
   getBridgeQuoteForMinOutput,
+  getSpokePool,
+  latestGasPriceCache,
 } from "../_utils";
 import {
   getUniswapCrossSwapQuotesForMinOutputB2A,
   getUniswapCrossSwapQuotesForMinOutputA2B,
   getBestUniswapCrossSwapQuotesForMinOutputA2A,
 } from "./uniswap";
 import { CrossSwap, CrossSwapQuotes } from "./types";
+import { getSwapAndBridge } from "./utils";
+import { tagIntegratorId } from "../_integrator-id";
+import { PopulatedTransaction } from "ethers";
+import { getMultiCallHandlerAddress } from "../_multicall-handler";
 
 export type CrossSwapType =
   (typeof CROSS_SWAP_TYPE)[keyof typeof CROSS_SWAP_TYPE];
 
 export type AmountType = (typeof AMOUNT_TYPE)[keyof typeof AMOUNT_TYPE];
 
+export type LeftoverType = (typeof LEFTOVER_TYPE)[keyof typeof LEFTOVER_TYPE];
+
 export const AMOUNT_TYPE = {
   EXACT_INPUT: "exactInput",
   MIN_OUTPUT: "minOutput",
@@ -28,6 +38,11 @@
   ANY_TO_ANY: "anyToAny",
 } as const;
 
+export const LEFTOVER_TYPE = {
+  OUTPUT_TOKEN: "outputToken",
+  BRIDGEABLE_TOKEN: "bridgeableToken",
+} as const;
+
 export const PREFERRED_BRIDGE_TOKENS = ["WETH", "USDC"];
 
 export async function getCrossSwapQuotes(
@@ -73,7 +88,7 @@
 }
 
 // @TODO: Implement the following function
 export async function getCrossSwapQuotesForExactInput(crossSwap: CrossSwap) {
   throw new Error("Not implemented yet");
 }
 
@@ -139,4 +154,92 @@
   return CROSS_SWAP_TYPE.ANY_TO_ANY;
 }
 
-export function calcFees() {}
+export async function buildCrossSwapTx(
+  crossSwapQuotes: CrossSwapQuotes,
+  integratorId?: string
+) {
+  const originChainId = crossSwapQuotes.crossSwap.inputToken.chainId;
+  const destinationChainId = crossSwapQuotes.crossSwap.outputToken.chainId;
+  const spokePool = getSpokePool(originChainId);
+  const deposit = {
+    depositor: crossSwapQuotes.crossSwap.depositor,
+    recipient: crossSwapQuotes.destinationSwapQuote
+      ? getMultiCallHandlerAddress(destinationChainId)
+      : crossSwapQuotes.crossSwap.recipient,
+    inputToken: crossSwapQuotes.bridgeQuote.inputToken.address,
+    outputToken: crossSwapQuotes.bridgeQuote.outputToken.address,
+    inputAmount: crossSwapQuotes.bridgeQuote.inputAmount,
+    outputAmount: crossSwapQuotes.bridgeQuote.outputAmount,
+    destinationChainid: crossSwapQuotes.bridgeQuote.outputToken.chainId,
+    exclusiveRelayer:
+      crossSwapQuotes.bridgeQuote.suggestedFees.exclusiveRelayer,
+    quoteTimestamp: crossSwapQuotes.bridgeQuote.suggestedFees.timestamp,
+    fillDeadline: await getFillDeadline(spokePool),
+    exclusivityDeadline:
+      crossSwapQuotes.bridgeQuote.suggestedFees.exclusivityDeadline,
+    message: crossSwapQuotes.bridgeQuote.message || "0x",
+  };
+
+  let tx: PopulatedTransaction;
+  let toAddress: string;
+
+  if (crossSwapQuotes.originSwapQuote) {
+    const swapAndBridge = getSwapAndBridge("uniswap", originChainId);
+    tx = await swapAndBridge.populateTransaction.swapAndBridge(
+      crossSwapQuotes.originSwapQuote.tokenIn.address,
+      crossSwapQuotes.originSwapQuote.tokenOut.address,
+      crossSwapQuotes.originSwapQuote.swapTx.data,
+      crossSwapQuotes.originSwapQuote.maximumAmountIn,
+      crossSwapQuotes.originSwapQuote.minAmountOut,
+      deposit
+    );
+    toAddress = swapAndBridge.address;
+  } else {
+    const spokePool = getSpokePool(
+      crossSwapQuotes.crossSwap.inputToken.chainId
+    );
+    tx = await spokePool.populateTransaction.depositV3(
+      deposit.depositor,
+      deposit.recipient,
+      deposit.inputToken,
+      deposit.outputToken,
+      deposit.inputAmount,
+      deposit.outputAmount,
+      deposit.destinationChainid,
+      deposit.exclusiveRelayer,
+      deposit.quoteTimestamp,
+      deposit.fillDeadline,
+      deposit.exclusivityDeadline,
+      deposit.message
+    );
+    toAddress = spokePool.address;
+  }
+
+  const [gas, gasPrice] = await Promise.all([
+    spokePool.provider.estimateGas({
+      from: crossSwapQuotes.crossSwap.depositor,
+      ...tx,
+    }),
+    latestGasPriceCache(originChainId).get(),
+  ]);
+
+  return {
+    from: crossSwapQuotes.crossSwap.depositor,
+    to: toAddress,
+    data: integratorId ? tagIntegratorId(integratorId, tx.data!) : tx.data,
+    gas,
+    gasPrice,
+    value: tx.value,
+  };
+}
+
+async function getFillDeadline(spokePool: SpokePool): Promise<number> {
+  const calls = [
+    spokePool.interface.encodeFunctionData("getCurrentTime"),
+    spokePool.interface.encodeFunctionData("fillDeadlineBuffer"),
+  ];
+
+  const [currentTime, fillDeadlineBuffer] =
+    await spokePool.callStatic.multicall(calls);
+  return Number(currentTime) + Number(fillDeadlineBuffer);
+}

api/_dexes/types.ts

@@ -1,6 +1,6 @@
 import { BigNumber } from "ethers";
 import { getSuggestedFees } from "../_utils";
-import { AmountType, CrossSwapType } from "./cross-swap";
+import { AmountType, CrossSwapType, LeftoverType } from "./cross-swap";
 
 export type { AmountType, CrossSwapType };
 
@@ -19,15 +19,18 @@ export type Swap = {
   recipient: string;
   slippageTolerance: number;
   type: AmountType;
+  leftoverType?: LeftoverType;
 };
 
 export type CrossSwap = {
   amount: BigNumber;
   inputToken: Token;
   outputToken: Token;
+  depositor: string;
   recipient: string;
   slippageTolerance: number;
   type: AmountType;
+  leftoverType?: LeftoverType;
   refundOnOrigin: boolean;
   refundAddress?: string;
 };