feat: add pendle rollover

Author: dglowinski

src/swapService/config/mainnet.ts

@@ -19,6 +19,7 @@ const WUSDM_MAINNET = "0x57f5e098cad7a3d1eed53991d4d66c45c9af7812"
 const WUSDL_MAINNET = "0x7751E2F4b8ae93EF6B79d86419d42FE3295A4559"
 const WM_MAINNET = "0x437cc33344a0B27A429f795ff6B469C72698B291"
 const USD0PLUSPLUS_MAINNET = "0x35d8949372d46b7a3d5a56006ae77b215fc69bc0"
+const PT_WSTUSR1740182579 = "0xd0097149aa4cc0d0e1fc99b8bd73fc17dc32c1e9"
 // TEST mBASIS
 
 const mainnetRoutingConfig: ChainRoutingConfig = [
@@ -47,7 +48,7 @@ const mainnetRoutingConfig: ChainRoutingConfig = [
   {
     strategy: StrategyERC4626Wrapper.name(),
     match: {
-      tokensInOrOut: [WSTUSR_MAINNET, WUSDL_MAINNET],
+      tokensInOrOut: [WSTUSR_MAINNET, WUSDL_MAINNET, PT_WSTUSR1740182579],
     },
   },
   {

src/swapService/quoters/quoterUniswap.ts

@@ -30,7 +30,7 @@ export async function fetchUniswapQuote(
   })
 
   const router = new AlphaRouter({
-    chainId: swapParams.chainId as ChainId,
+    chainId: swapParams.chainId,
     provider: provider,
   })
 

src/swapService/runner.ts

@@ -44,7 +44,7 @@ export async function runPipeline(
 
   console.log(allResults)
 
-  const finalResult = allResults.pop()
+  const finalResult = allResults.at(-1)
   if (!finalResult)
     throw new ApiError(
       StatusCodes.NOT_FOUND,

src/swapService/strategies/balmySDK/pendleQuoteSource.ts

@@ -50,7 +50,6 @@ export class CustomPendleQuoteSource
     params: QuoteParams<PendleSupport, PendleConfig>,
   ): Promise<SourceQuoteResponse<PendleData>> {
     const { dstAmount, to, data } = await this.getQuote(params)
-    console.log("pendle: ", dstAmount)
 
     const quote = {
       sellAmount: params.request.order.sellAmount,
@@ -89,26 +88,48 @@ export class CustomPendleQuoteSource
     },
     config,
   }: QuoteParams<PendleSupport, PendleConfig>) {
-    const queryParams = {
-      receiver: recipient || takeFrom,
-      slippage: slippagePercentage / 100, // 1 = 100%
-      enableAggregator: true,
-      tokenIn: sellToken,
-      tokenOut: buyToken,
-      amountIn: order.sellAmount.toString(),
-    }
-
-    const queryString = qs.stringify(queryParams, {
-      skipNulls: true,
-      arrayFormat: "comma",
-    })
     const tokenIn = findToken(chainId, getAddress(sellToken))
     const tokenOut = findToken(chainId, getAddress(buyToken))
 
-    const pendleMarket =
-      tokenIn.meta?.pendleMarket || tokenOut.meta?.pendleMarket
+    let url
+    if (tokenIn?.meta?.isPendlePT && tokenOut?.meta?.isPendlePT) {
+      // rollover
+      const queryParams = {
+        receiver: recipient || takeFrom,
+        slippage: slippagePercentage / 100, // 1 = 100%
+        dstMarket: tokenOut.meta.pendleMarket,
+        ptAmount: order.sellAmount.toString(),
+      }
+
+      const queryString = qs.stringify(queryParams, {
+        skipNulls: true,
+        arrayFormat: "comma",
+      })
+
+      const pendleMarket = tokenIn.meta.pendleMarket
+      url = `${getUrl()}/${chainId}/markets/${pendleMarket}/roll-over-pt?${queryString}`
+    } else {
+      // swap
+      const queryParams = {
+        receiver: recipient || takeFrom,
+        slippage: slippagePercentage / 100, // 1 = 100%
+        enableAggregator: true,
+        tokenIn: sellToken,
+        tokenOut: buyToken,
+        amountIn: order.sellAmount.toString(),
+      }
+
+      const queryString = qs.stringify(queryParams, {
+        skipNulls: true,
+        arrayFormat: "comma",
+      })
+
+      const pendleMarket =
+        tokenIn?.meta?.pendleMarket || tokenOut?.meta?.pendleMarket
+
+      url = `${getUrl()}/${chainId}/markets/${pendleMarket}/swap?${queryString}`
+    }
 
-    const url = `${getUrl()}/${chainId}/markets/${pendleMarket}/swap?${queryString}`
     const response = await fetchService.fetch(url, {
       timeout,
       headers: getHeaders(config),
@@ -123,10 +144,12 @@ export class CustomPendleQuoteSource
         (await response.text()) || `Failed with status ${response.status}`,
       )
     }
+
     const {
-      data: { amountOut: dstAmount },
+      data: { amountOut, amountPtOut },
       tx: { to, data },
     } = await response.json()
+    const dstAmount = amountOut || amountPtOut
 
     return { dstAmount, to, data }
   }

src/swapService/strategies/strategy1Inch.ts renamed to src/swapService/strategies/deprecated/strategy1Inch.ts

@@ -1,7 +1,7 @@
 import * as chains from "viem/chains"
-import { SwapperMode } from "../interface"
-import { fetchPendleOverswapQuote, fetchPendleQuote } from "../quoters"
-import type { StrategyResult, SwapParams } from "../types"
+import { SwapperMode } from "../../interface"
+import { fetchPendleOverswapQuote, fetchPendleQuote } from "../../quoters"
+import type { StrategyResult, SwapParams } from "../../types"
 import {
   SWAPPER_HANDLER_GENERIC,
   buildApiResponseExactInputFromQuote,
@@ -10,7 +10,7 @@ import {
   encodeSwapMulticallItem,
   isExactInRepay,
   matchParams,
-} from "../utils"
+} from "../../utils"
 
 export const defaultConfig = {
   chainsSupported: [

src/swapService/strategies/strategyKyberswap.ts renamed to src/swapService/strategies/deprecated/strategyKyberswap.ts

@@ -1,30 +1,21 @@
-import { Strategy1Inch } from "./strategy1Inch"
 import { StrategyBalmySDK } from "./strategyBalmySDK"
 import { StrategyCombinedUniswap } from "./strategyCombinedUniswap"
 import { StrategyERC4626Wrapper } from "./strategyERC4626Wrapper"
-import { StrategyLifi } from "./strategyLifi"
 import { StrategyMidas } from "./strategyMidas"
-import { StrategyPendle } from "./strategyPendle"
 import { StrategyRepayWrapper } from "./strategyRepayWrapper"
 
 export {
-  Strategy1Inch,
   StrategyCombinedUniswap,
   StrategyMidas,
-  StrategyPendle,
-  StrategyLifi,
   StrategyRepayWrapper,
   StrategyBalmySDK,
   StrategyERC4626Wrapper,
 }
 
 export const strategies = {
-  [Strategy1Inch.name()]: Strategy1Inch,
-  [StrategyPendle.name()]: StrategyPendle,
   [StrategyMidas.name()]: StrategyMidas,
   [StrategyCombinedUniswap.name()]: StrategyCombinedUniswap,
   [StrategyRepayWrapper.name()]: StrategyRepayWrapper,
   [StrategyBalmySDK.name()]: StrategyBalmySDK,
-  [StrategyLifi.name()]: StrategyLifi,
   [StrategyERC4626Wrapper.name()]: StrategyERC4626Wrapper,
 }