SDK: add RFQ

packages/sdk-router/package.json

@@ -47,6 +47,8 @@
     "@types/jest": "^24.0.25",
     "dotenv": "^16.3.1",
     "husky": "^8.0.1",
+    "jest-mock-extended": "^3.0.5",
+    "node-fetch": "^2.0.0",
     "size-limit": "^8.1.0",
     "tsdx": "^0.14.1",
     "tslib": "^2.4.0",

packages/sdk-router/src/abi/FastBridge.json

@@ -534,6 +534,7 @@
       {
         "components": [
           { "internalType": "uint32", "name": "dstChainId", "type": "uint32" },
+          { "internalType": "address", "name": "sender", "type": "address" },
           { "internalType": "address", "name": "to", "type": "address" },
           {
             "internalType": "address",

packages/sdk-router/src/constants/addresses.ts

@@ -1,4 +1,9 @@
-import { CCTP_SUPPORTED_CHAIN_IDS, SUPPORTED_CHAIN_IDS } from './chainIds'
+import {
+  CCTP_SUPPORTED_CHAIN_IDS,
+  RFQ_SUPPORTED_CHAIN_IDS,
+  SUPPORTED_CHAIN_IDS,
+  SupportedChainId,
+} from './chainIds'
 
 export type AddressMap = {
   [chainId: number]: string
@@ -48,3 +53,20 @@ export const CCTP_ROUTER_ADDRESS_MAP: AddressMap = generateAddressMap(
   CCTP_ROUTER_ADDRESS,
   CCTP_ROUTER_EXCEPTION_MAP
 )
+
+/**
+ * FastBridge contract address for all chains except ones from FAST_BRIDGE_ADDRESS.
+ *
+ * TODO: Update this address once FastBridge is deployed.
+ */
+const FAST_BRIDGE_ADDRESS = ''
+const FAST_BRIDGE_EXCEPTION_MAP: AddressMap = {
+  [SupportedChainId.OPTIMISM]: '0x743fFbd0DbF88F6fCB7FaDf58fB641da93056EdF',
+  [SupportedChainId.ARBITRUM]: '0xA9EBFCb6DCD416FE975D5aB862717B329407f4F7',
+}
+
+export const FAST_BRIDGE_ADDRESS_MAP: AddressMap = generateAddressMap(
+  RFQ_SUPPORTED_CHAIN_IDS,
+  FAST_BRIDGE_ADDRESS,
+  FAST_BRIDGE_EXCEPTION_MAP
+)

packages/sdk-router/src/constants/chainIds.ts

@@ -41,3 +41,13 @@ export const CCTP_SUPPORTED_CHAIN_IDS: number[] = [
   SupportedChainId.BASE,
   SupportedChainId.POLYGON, // Circle domain 7
 ]
+
+/**
+ * List of chain ids where FastBridge (RFQ) is deployed, ordered by chain id
+ *
+ * Note: This is a subset of SUPPORTED_CHAIN_IDS.
+ */
+export const RFQ_SUPPORTED_CHAIN_IDS: number[] = [
+  SupportedChainId.OPTIMISM,
+  SupportedChainId.ARBITRUM,
+]

packages/sdk-router/src/constants/medianTime.ts

@@ -38,3 +38,13 @@ export const MEDIAN_TIME_CCTP = {
   [SupportedChainId.AVALANCHE]: 30,
   [SupportedChainId.POLYGON]: 480,
 }
+
+/**
+ * Median time (in seconds) for a SynapseRFQ transaction to be completed,
+ * when the transaction is sent from a given chain.
+ * TODO: Update this value once we have a better estimate.
+ */
+export const MEDIAN_TIME_RFQ = {
+  [SupportedChainId.OPTIMISM]: 30,
+  [SupportedChainId.ARBITRUM]: 30,
+}

packages/sdk-router/src/module/query.test.ts

@@ -10,6 +10,7 @@ import {
   modifyDeadline,
   applySlippage,
   applySlippageInBips,
+  createNoSwapQuery,
 } from './query'
 
 describe('#query', () => {
@@ -380,4 +381,15 @@ describe('#query', () => {
       )
     })
   })
+
+  it('createNoSwapQuery', () => {
+    const query = createNoSwapQuery('1', BigNumber.from(2))
+    expect(query).toEqual({
+      routerAdapter: '0x0000000000000000000000000000000000000000',
+      tokenOut: '1',
+      minAmountOut: BigNumber.from(2),
+      deadline: BigNumber.from(0),
+      rawParams: '0x',
+    })
+  })
 })

packages/sdk-router/src/module/query.ts

@@ -165,3 +165,20 @@ export const applySlippageInBips = (
 ): Query => {
   return applySlippage(query, slipBasisPoints, 10000)
 }
+
+/**
+ * Creates a Query object for a no-swap bridge action.
+ *
+ * @param token - The token to bridge.
+ * @param amount - The amount of token to bridge.
+ * @returns The Query object for a no-swap bridge action.
+ */
+export const createNoSwapQuery = (token: string, amount: BigNumber): Query => {
+  return {
+    routerAdapter: AddressZero,
+    tokenOut: token,
+    minAmountOut: amount,
+    deadline: BigNumber.from(0),
+    rawParams: '0x',
+  }
+}

packages/sdk-router/src/rfq/api.test.ts

@@ -0,0 +1,69 @@
+import { getAllQuotes } from './api'
+import { FastBridgeQuoteAPI, unmarshallFastBridgeQuote } from './quote'
+
+describe('getAllQuotes', () => {
+  const quotesAPI: FastBridgeQuoteAPI[] = [
+    {
+      origin_chain_id: 1,
+      origin_token_addr: '0x0000000000000000000000000000000000000001',
+      dest_chain_id: 2,
+      dest_token_addr: '0x0000000000000000000000000000000000000002',
+      dest_amount: '3',
+      max_origin_amount: '4',
+      fixed_fee: '5',
+      origin_fast_bridge_address: '10',
+      dest_fast_bridge_address: '11',
+      relayer_addr: '0x0000000000000000000000000000000000000003',
+      updated_at: '2023-01-01T00:00:00.420Z',
+    },
+    {
+      origin_chain_id: 3,
+      origin_token_addr: '0x0000000000000000000000000000000000000004',
+      dest_chain_id: 4,
+      dest_token_addr: '0x0000000000000000000000000000000000000005',
+      dest_amount: '6',
+      max_origin_amount: '7',
+      fixed_fee: '8',
+      origin_fast_bridge_address: '20',
+      dest_fast_bridge_address: '21',
+      relayer_addr: '0x0000000000000000000000000000000000000006',
+      updated_at: '2023-01-02T00:00:00.420Z',
+    },
+  ]
+
+  it('returns an empty array when the response is not ok', async () => {
+    global.fetch = jest.fn(() =>
+      Promise.resolve({
+        status: 500,
+        ok: false,
+      })
+    ) as any
+
+    const result = await getAllQuotes()
+    expect(result).toEqual([])
+  })
+
+  it('returns a list of quotes when the response is ok', async () => {
+    global.fetch = jest.fn(() =>
+      Promise.resolve({
+        status: 200,
+        ok: true,
+        json: () => Promise.resolve(quotesAPI),
+      })
+    ) as any
+
+    const result = await getAllQuotes()
+    // You might need to adjust this depending on how your unmarshallFastBridgeQuote function works
+    expect(result).toEqual([
+      unmarshallFastBridgeQuote(quotesAPI[0]),
+      unmarshallFastBridgeQuote(quotesAPI[1]),
+    ])
+  })
+
+  it('Integration test', async () => {
+    global.fetch = require('node-fetch')
+    const result = await getAllQuotes()
+    console.log('Quotes: ' + JSON.stringify(result, null, 2))
+    expect(result.length).toBeGreaterThan(0)
+  })
+})

packages/sdk-router/src/rfq/api.ts

@@ -0,0 +1,23 @@
+import {
+  FastBridgeQuote,
+  FastBridgeQuoteAPI,
+  unmarshallFastBridgeQuote,
+} from './quote'
+
+const API_URL = 'https://rfq-api.omnirpc.io'
+
+/**
+ * Hits Quoter API /quotes endpoint to get all quotes.
+ *
+ * @returns A promise that resolves to the list of quotes.
+ */
+export const getAllQuotes = async (): Promise<FastBridgeQuote[]> => {
+  const response = await fetch(API_URL + '/quotes')
+  // Return empty list if response is not ok
+  if (!response.ok) {
+    return []
+  }
+  // The response is a list of quotes in the FastBridgeQuoteAPI format
+  const quotes: FastBridgeQuoteAPI[] = await response.json()
+  return quotes.map(unmarshallFastBridgeQuote)
+}