feat: enable stable pair for Symbiosis provider (#2850)

* feat: enable stable pair for Symbiosis provider

* chore: add partner id

* fix: canonical pair should be stable pair

Author: piavgh

apps/kyberswap-interface/src/pages/CrossChainSwap/adapters/BaseSwapAdapter.ts

@@ -142,6 +142,7 @@ export interface SwapProvider {
     connection?: Connection,
   ): Promise<NormalizedTxResponse>
   getTransactionStatus(p: NormalizedTxResponse): Promise<SwapStatus>
+  canSupport(category: string): boolean
 }
 export abstract class BaseSwapAdapter implements SwapProvider {
   abstract getName(): string
@@ -156,6 +157,11 @@ export abstract class BaseSwapAdapter implements SwapProvider {
   ): Promise<NormalizedTxResponse>
   abstract getTransactionStatus(p: NormalizedTxResponse): Promise<SwapStatus>
 
+  canSupport(_category: string): boolean {
+    // Default implementation - support all categories
+    return true
+  }
+
   protected handleError(error: any): never {
     console.error(`[${this.getName()}] Error:`, error)
     throw new Error(`${this.getName()} provider error: ${error.message || 'Unknown error'}`)

apps/kyberswap-interface/src/pages/CrossChainSwap/adapters/SymbiosisAdapter.ts

@@ -1,7 +1,7 @@
 import { ChainId, Currency } from '@kyberswap/ks-sdk-core'
 import { WalletClient, formatUnits } from 'viem'
 
-import { ZERO_ADDRESS } from 'constants/index'
+import { CROSS_CHAIN_FEE_RECEIVER, ZERO_ADDRESS } from 'constants/index'
 
 import { Quote } from '../registry'
 import {
@@ -14,6 +14,7 @@ import {
 } from './BaseSwapAdapter'
 
 const SYMBIOSIS_API = 'https://api.symbiosis.finance/crosschain/v1'
+const KYBERSWAP_PARTNER_ID = 'kyberswap'
 
 export class SymbiosisAdapter extends BaseSwapAdapter {
   constructor() {
@@ -26,6 +27,12 @@ export class SymbiosisAdapter extends BaseSwapAdapter {
   getIcon(): string {
     return 'https://app.symbiosis.finance/images/favicon-32x32.png'
   }
+
+  canSupport(category: string): boolean {
+    // Symbiosis should only be used for stablePair category
+    return category === 'stablePair'
+  }
+
   getSupportedChains(): Chain[] {
     return [
       ChainId.MAINNET,
@@ -66,12 +73,14 @@ export class SymbiosisAdapter extends BaseSwapAdapter {
       from: params.sender,
       to: params.recipient,
       slippage: params.slippage,
+      partnerAddress: CROSS_CHAIN_FEE_RECEIVER,
     }
 
     const res = await fetch(`${SYMBIOSIS_API}/swap`, {
       method: 'POST',
       headers: {
         'Content-Type': 'application/json',
+        'X-Partner-Id': KYBERSWAP_PARTNER_ID,
       },
       body: JSON.stringify(body),
     }).then(r => r.json())
@@ -87,6 +96,22 @@ export class SymbiosisAdapter extends BaseSwapAdapter {
     const inputUsd = tokenInUsd * +formattedInputAmount
     const outputUsd = tokenOutUsd * +formattedOutputAmount
 
+    // Calculate protocol fee from the fees array
+    const protocolFee = (res.fees || []).reduce(
+      (
+        total: number,
+        fee: {
+          value: { amount: string; decimals: number; priceUsd: number }
+        },
+      ) => {
+        const { amount, decimals, priceUsd } = fee.value
+        const feeAmount = Number(amount) / Math.pow(10, decimals)
+        const feeUsd = feeAmount * priceUsd
+        return total + feeUsd
+      },
+      0,
+    )
+
     return {
       quoteParams: params,
       outputAmount: BigInt(res.tokenAmountOut.amount),
@@ -99,10 +124,8 @@ export class SymbiosisAdapter extends BaseSwapAdapter {
       timeEstimate: res.estimatedTime,
       contractAddress: res.approveTo || ZERO_ADDRESS,
       rawQuote: res,
-
-      // TODO: add Fee
-      protocolFee: 0,
-      platformFeePercent: 0,
+      protocolFee,
+      platformFeePercent: (params.feeBps * 100) / 10_000,
     }
   }
 

apps/kyberswap-interface/src/pages/CrossChainSwap/factory.ts

@@ -124,7 +124,7 @@ export class CrossChainSwapFactory {
       // CrossChainSwapFactory.getXyFinanceAdapter(),
       CrossChainSwapFactory.getNearIntentsAdapter(),
       CrossChainSwapFactory.getMayanAdapter(),
-      // CrossChainSwapFactory.getSymbiosisAdapter(),
+      CrossChainSwapFactory.getSymbiosisAdapter(),
       CrossChainSwapFactory.getDebridgeInstance(),
       CrossChainSwapFactory.getLifiInstance(),
       CrossChainSwapFactory.getOptimexAdapter(),

apps/kyberswap-interface/src/pages/CrossChainSwap/hooks/useCrossChainSwap.tsx

@@ -27,6 +27,7 @@ import {
   NOT_SUPPORTED_CHAINS_PRICE_SERVICE,
   NearQuoteParams,
   NonEvmChain,
+  NormalizedQuote,
   QuoteParams,
   SwapProvider,
 } from '../adapters'
@@ -46,6 +47,28 @@ const createTimeoutPromise = (ms: number) => {
   })
 }
 
+// Helper to calculate net output amount after protocol fees
+const getNetOutputAmount = (quote: NormalizedQuote): bigint => {
+  const { outputAmount, protocolFee, quoteParams } = quote
+  const { tokenOutUsd, toToken } = quoteParams
+
+  // Convert protocol fee from USD to token amount
+  if (protocolFee && tokenOutUsd && tokenOutUsd > 0) {
+    const decimals = toToken?.decimals || 18
+    const protocolFeeInTokens = protocolFee / tokenOutUsd
+
+    // Use parseUnits to safely convert decimal to BigInt without precision loss
+    try {
+      const protocolFeeInSmallestUnit = parseUnits(protocolFeeInTokens.toFixed(decimals), decimals)
+      return outputAmount - protocolFeeInSmallestUnit
+    } catch (e) {
+      console.error('Error converting protocol fee:', e)
+      return outputAmount
+    }
+  }
+  return outputAmount
+}
+
 const RegistryContext = createContext<
   | {
       showPreview: boolean
@@ -446,6 +469,7 @@ export const CrossChainSwapRegistryProvider = ({ children }: { children: React.R
           (currencyOut as any).wrapped.address,
         )
       ) {
+        setCategory('stablePair')
         feeBps = 5
       } else {
         const [token0Cat, token1Cat] = await Promise.all([
@@ -547,14 +571,24 @@ export const CrossChainSwapRegistryProvider = ({ children }: { children: React.R
           // Check for cancellation before starting
           if (signal.aborted) throw new Error('Cancelled')
 
+          // Skip adapter if it does not support the category
+          if (!adapter.canSupport(category)) {
+            console.log(`Skipping ${adapter.getName()} because it does not support category ${category}`)
+            return
+          }
+
           // Race between the adapter quote and timeout
           const quote = await Promise.race([adapter.getQuote(params), createTimeoutPromise(9_000)])
 
           // Check for cancellation after getting quote
           if (signal.aborted) throw new Error('Cancelled')
 
           quotes.push({ adapter, quote })
-          const sortedQuotes = [...quotes].sort((a, b) => (a.quote.outputAmount < b.quote.outputAmount ? 1 : -1))
+          const sortedQuotes = [...quotes].sort((a, b) => {
+            const netA = getNetOutputAmount(a.quote)
+            const netB = getNetOutputAmount(b.quote)
+            return netA < netB ? 1 : -1
+          })
           setQuotes(sortedQuotes)
           setLoading(false)
         } catch (err) {
@@ -571,7 +605,12 @@ export const CrossChainSwapRegistryProvider = ({ children }: { children: React.R
         throw new Error('No valid quotes found for the requested swap')
       }
 
-      quotes.sort((a, b) => (a.quote.outputAmount < b.quote.outputAmount ? 1 : -1))
+      // Sort by net output amount (after protocol fees)
+      quotes.sort((a, b) => {
+        const netA = getNetOutputAmount(a.quote)
+        const netB = getNetOutputAmount(b.quote)
+        return netA < netB ? 1 : -1
+      })
       return quotes
     }
 
@@ -628,6 +667,7 @@ export const CrossChainSwapRegistryProvider = ({ children }: { children: React.R
     isToSolana,
     connection,
     excludedSources,
+    category,
   ])
 
   return (