feat: add auto slippage endpoint + 0x migration (#1863)

* update quote route

* lint

* change api url for testing

* feat: add auto slippage route

* lint

* add buffer

* fix response

* remove some earn-old components

* integrate auto slippage

* fix slippage rounding errors

* update slippage on is auto changes

* remove logs

* re-add production url

* remove logs

Author: janndriessen

src/app/api/quote/route.ts

@@ -1,21 +1,23 @@
-import { EthAddress, QuoteToken } from '@indexcoop/flash-mint-sdk'
+import { EthAddress, type QuoteToken } from '@indexcoop/flash-mint-sdk'
 import {
   getTokenByChainAndAddress,
   isAddressEqual,
   isProductToken,
 } from '@indexcoop/tokenlists'
-import { NextRequest, NextResponse } from 'next/server'
-import { Address } from 'viem'
+import { NextResponse } from 'next/server'
 
-import { isBaseToken } from '@/lib/utils/tokens'
+import { getQuote } from '@/app/api/quote/utils'
+
+import type { NextRequest } from 'next/server'
+import type { Address } from 'viem'
 
 export interface IndexQuoteRequest {
   chainId: number
   account: string
   inputToken: string
   outputToken: string
-  inputAmount?: string
-  outputAmount?: string
+  inputAmount: string
+  outputAmount: string
   slippage: number
 }
 
@@ -34,12 +36,6 @@ export async function POST(req: NextRequest) {
 
     const inputToken = getQuoteToken(inputTokenAddress, chainId)
     const outputToken = getQuoteToken(outputTokenAddress, chainId)
-    const isBtcOnBase = isBaseToken(
-      chainId,
-      inputTokenAddress,
-      outputTokenAddress,
-    )
-    const isMintingIcUsd = outputToken?.quoteToken.symbol === 'icUSD'
 
     if (
       !inputToken ||
@@ -49,42 +45,26 @@ export async function POST(req: NextRequest) {
       return BadRequest('Bad Request')
     }
 
-    const isMinting = outputToken.isIndex
     const quoteRequest: {
       account: string
       chainId: string
       inputToken: string
       outputToken: string
-      inputAmount?: string
-      outputAmount?: string
+      inputAmount: string
+      outputAmount: string
       slippage: string
     } = {
       account,
       chainId: String(chainId),
       inputToken: inputToken.quoteToken.address,
       outputToken: outputToken.quoteToken.address,
+      // At the moment, we always wanna set both (inputAmount and indexTokenAmount)
+      inputAmount,
+      outputAmount,
       slippage: String(slippage),
     }
-    if (isMinting) {
-      quoteRequest.outputAmount = outputAmount
-    } else {
-      quoteRequest.inputAmount = inputAmount
-    }
-    if (isMintingIcUsd || isBtcOnBase) {
-      quoteRequest.inputAmount = inputAmount ?? '0'
-    }
-
-    const query = new URLSearchParams(quoteRequest).toString()
-    const url = `https://api.indexcoop.com/v2/quote?${query}`
-    const response = await fetch(url, {
-      method: 'GET',
-      headers: {
-        'Content-Type': 'application/json',
-        'x-api-key': process.env.INDEX_COOP_API_V2_KEY,
-      } as HeadersInit,
-    })
 
-    const quote = await response.json()
+    const quote = await getQuote(quoteRequest)
 
     if (!quote) {
       return NextResponse.json({ message: 'No quote found.' }, { status: 404 })

src/app/api/quote/utils.ts

@@ -0,0 +1,24 @@
+export interface FlashMintQuoteRequest {
+  chainId: number
+  account: string
+  inputToken: string
+  outputToken: string
+  inputAmount: string
+  outputAmount: string
+  slippage: number
+}
+
+export async function getQuote(quoteRequest: Record<string, string>) {
+  const query = new URLSearchParams(quoteRequest).toString()
+  const url = `https://api.indexcoop.com/v2/quote?${query}`
+  const response = await fetch(url, {
+    method: 'GET',
+    headers: {
+      'Content-Type': 'application/json',
+      'x-api-key': process.env.INDEX_COOP_API_V2_KEY,
+    } as HeadersInit,
+  })
+
+  const quote = await response.json()
+  return quote
+}

src/app/api/slippage/[...slug]/route.ts

@@ -0,0 +1,111 @@
+import {
+  getTokenByChainAndAddress,
+  getTokenByChainAndSymbol,
+} from '@indexcoop/tokenlists'
+import { headers } from 'next/headers'
+import { NextResponse } from 'next/server'
+import { isAddress, parseUnits } from 'viem'
+
+import { getQuote } from '@/app/api/quote/utils'
+import { formatWei } from '@/lib/utils'
+import { fetchTokenMetrics } from '@/lib/utils/api/index-data-provider'
+
+import type { NextRequest } from 'next/server'
+
+const slippageDefault = 0.5
+const slippageMax = 5.5
+
+export async function GET(
+  _: NextRequest,
+  { params }: { params: { slug: string[] } },
+): Promise<Response> {
+  try {
+    const { slug } = params
+    const chainId = Number(slug[0])
+    const address = slug[1]
+
+    if (!address || !isAddress(address)) {
+      return NextResponse.json('Bad Request', { status: 400 })
+    }
+
+    const token = getTokenByChainAndAddress(chainId, address)
+    const usdc = getTokenByChainAndSymbol(chainId, 'USDC')
+
+    if (!token || !usdc) {
+      return NextResponse.json('Bad Request', { status: 400 })
+    }
+
+    const headersList = await headers()
+    const host = headersList.get('host')
+    const metrics = await fetchTokenMetrics({
+      hostname:
+        process.env.NODE_ENV === 'development'
+          ? `http://${host}`
+          : `https://${host}`,
+      chainId,
+      tokenAddress: address,
+      metrics: ['nav'],
+    })
+
+    const nav = metrics?.NetAssetValue
+    const inputAmount = nav === undefined ? '1000' : (nav * 1.1).toString()
+
+    if (!nav) {
+      return NextResponse.json(
+        {
+          chainId,
+          address,
+          slippage: slippageDefault,
+        },
+        { status: 200 },
+      )
+    }
+
+    const quoteRequest: {
+      account: string
+      chainId: string
+      inputToken: string
+      outputToken: string
+      inputAmount: string
+      outputAmount: string
+      slippage: string
+    } = {
+      account: '0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045',
+      chainId: String(chainId),
+      inputToken: usdc.address,
+      outputToken: token.address,
+      // At the moment, we always wanna set both (inputAmount and indexTokenAmount)
+      inputAmount: parseUnits(inputAmount.toString(), usdc.decimals).toString(),
+      outputAmount: parseUnits('1', token.decimals).toString(),
+      slippage: String(0.5),
+    }
+
+    const quote = await getQuote(quoteRequest)
+
+    const quoteUsd = Number.parseFloat(
+      formatWei(quote.inputAmount, usdc.decimals),
+    )
+
+    const buffer = 1.2 // +20% on top of calc slippage
+    const slippage = ((quoteUsd - nav) / nav) * buffer
+
+    const slippagePercentage = slippage * 100
+    const slippageOrMax =
+      slippagePercentage > slippageMax ? slippageMax : slippagePercentage
+
+    return NextResponse.json(
+      {
+        chainId,
+        address,
+        slippage: slippage < 0 ? slippageDefault : slippageOrMax,
+      },
+      { status: 200 },
+    )
+  } catch (error) {
+    console.log(error)
+    return NextResponse.json(
+      { message: 'Internal Server Error' },
+      { status: 500 },
+    )
+  }
+}