[Issue-4078] feat: find all routes

Author: bluezdot

packages/extension-base/src/services/swap-service/index.ts

@@ -6,13 +6,12 @@ import { TransactionError } from '@subwallet/extension-base/background/errors/Tr
 import KoniState from '@subwallet/extension-base/koni/background/handlers/State';
 import { ServiceStatus, ServiceWithProcessInterface, StoppableServiceInterface } from '@subwallet/extension-base/services/base/types';
 import { ChainService } from '@subwallet/extension-base/services/chain-service';
-import { _getAssetPriceId, _getAssetSymbol, _getMultiChainAsset } from '@subwallet/extension-base/services/chain-service/utils';
 import { EventService } from '@subwallet/extension-base/services/event-service';
 import { AssetHubSwapHandler } from '@subwallet/extension-base/services/swap-service/handler/asset-hub';
 import { SwapBaseInterface } from '@subwallet/extension-base/services/swap-service/handler/base-handler';
 import { ChainflipSwapHandler } from '@subwallet/extension-base/services/swap-service/handler/chainflip-handler';
 import { HydradxHandler } from '@subwallet/extension-base/services/swap-service/handler/hydradx-handler';
-import { _PROVIDER_TO_SUPPORTED_PAIR_MAP, findSwapDestinations, findXcmDestinations, getInitStep, getSwapAltToken, getSwapStep, getXcmStep, SWAP_QUOTE_TIMEOUT_MAP } from '@subwallet/extension-base/services/swap-service/utils';
+import { _PROVIDER_TO_SUPPORTED_PAIR_MAP, DynamicSwapAction, findSwapDestinations, findXcmDestinations, getInitStep, getSwapAltToken, getSwapStep, getXcmStep, isEquiValentAsset, SWAP_QUOTE_TIMEOUT_MAP } from '@subwallet/extension-base/services/swap-service/utils';
 import { BasicTxErrorType, SwapRequestV2 } from '@subwallet/extension-base/types';
 import { CommonOptimalPath, DEFAULT_FIRST_STEP, MOCK_STEP_FEE } from '@subwallet/extension-base/types/service-base';
 import { _SUPPORTED_SWAP_PROVIDERS, OptimalSwapPathParams, QuoteAskResponse, SwapErrorType, SwapPair, SwapProviderId, SwapQuote, SwapQuoteResponse, SwapRequest, SwapRequestResult, SwapStepType, SwapSubmitParams, SwapSubmitStepData, ValidateSwapProcessParams } from '@subwallet/extension-base/types/swap';
@@ -132,7 +131,7 @@ export class SwapService implements ServiceWithProcessInterface, StoppableServic
     } as SwapRequestResult;
   }
 
-  public handleSwapRequestV2 (request: SwapRequestV2) {
+  public handleSwapRequestV2 (request: SwapRequestV2): DynamicSwapAction[][] {
     const { fromToken, toToken } = request;
     const fromTokenInfo = this.chainService.getAssetBySlug(fromToken);
     const toTokenInfo = this.chainService.getAssetBySlug(toToken);
@@ -146,47 +145,54 @@ export class SwapService implements ServiceWithProcessInterface, StoppableServic
       return [];
     }
 
-    const steps = [getInitStep(fromToken)];
+    const routes: DynamicSwapAction[][] = [];
+    let steps: DynamicSwapAction[] = [];
 
-    // todo: try find swap
+    // try find swap
     if (fromChain === toChain) {
       if (firstSwapDes.includes(toTokenInfo)) {
+        steps.push(getInitStep(fromToken));
         steps.push(getSwapStep(toToken));
+        routes.push(steps);
 
-        return steps;
+        return routes;
       }
     }
 
-    // todo: try find xcm
-    if (_getMultiChainAsset(fromTokenInfo) === _getMultiChainAsset(toTokenInfo) || _getAssetPriceId(fromTokenInfo) === _getAssetPriceId(toTokenInfo) || _getAssetSymbol(fromTokenInfo) === _getAssetSymbol(toTokenInfo)) {
+    // try find xcm
+    if (isEquiValentAsset(fromTokenInfo, toTokenInfo)) {
       if (firstXcmDes.includes(toTokenInfo)) {
+        steps.push(getInitStep(fromToken));
         steps.push(getXcmStep(toToken));
+        routes.push(steps);
 
-        return steps;
+        return routes;
       }
     }
 
-    // todo: brute force find process
+    // brute force to find nested routes
     for (const xcmAsset of firstXcmDes) {
       const swapDesChild = findSwapDestinations(this.chainService, xcmAsset);
 
       if (!swapDesChild.length) {
         /* empty */
       } else if (swapDesChild.includes(toTokenInfo)) {
+        steps = [];
+        steps.push(getInitStep(fromToken));
         steps.push(getXcmStep(xcmAsset.slug));
         steps.push(getSwapStep(toToken));
-
-        return steps;
+        routes.push(steps);
       } else {
         for (const swapAsset of swapDesChild) {
           const xcmDesChild = findXcmDestinations(this.chainService, swapAsset);
 
           if (xcmDesChild.includes(toTokenInfo)) {
+            steps = [];
+            steps.push(getInitStep(fromToken));
             steps.push(getXcmStep(xcmAsset.slug));
             steps.push(getSwapStep(swapAsset.slug));
             steps.push(getXcmStep(toToken));
-
-            return steps;
+            routes.push(steps);
           }
         }
       }
@@ -198,26 +204,28 @@ export class SwapService implements ServiceWithProcessInterface, StoppableServic
       if (!xcmDesChild.length) {
         /* empty */
       } else if (xcmDesChild.includes(toTokenInfo)) {
+        steps = [];
+        steps.push(getInitStep(fromToken));
         steps.push(getSwapStep(swapAsset.slug));
         steps.push(getXcmStep(toToken));
-
-        return steps;
+        routes.push(steps);
       } else {
         for (const xcmAsset of xcmDesChild) {
           const swapDesChild = findSwapDestinations(this.chainService, xcmAsset);
 
           if (swapDesChild.includes(toTokenInfo)) {
+            steps = [];
+            steps.push(getInitStep(fromToken));
             steps.push(getSwapStep(swapAsset.slug));
             steps.push(getXcmStep(xcmAsset.slug));
             steps.push(getSwapStep(toToken));
-
-            return steps;
+            routes.push(steps);
           }
         }
       }
     }
 
-    return [];
+    return routes;
   }
 
   public async getLatestQuotes (request: SwapRequest): Promise<SwapQuoteResponse> {

packages/extension-base/src/services/swap-service/utils.ts

@@ -5,7 +5,7 @@ import { COMMON_ASSETS, COMMON_CHAIN_SLUGS } from '@subwallet/chain-list';
 import { _ChainAsset, _ChainInfo } from '@subwallet/chain-list/types';
 import { ChainService } from '@subwallet/extension-base/services/chain-service';
 import { _SubstrateApi } from '@subwallet/extension-base/services/chain-service/types';
-import { _getAssetDecimals, _getFungibleAssetType, _getMultiChainAsset } from '@subwallet/extension-base/services/chain-service/utils';
+import { _getAssetDecimals, _getAssetPriceId, _getAssetSymbol, _getFungibleAssetType, _getMultiChainAsset } from '@subwallet/extension-base/services/chain-service/utils';
 import { CHAINFLIP_BROKER_API } from '@subwallet/extension-base/services/swap-service/handler/chainflip-handler';
 import { SwapPair, SwapProviderId } from '@subwallet/extension-base/types/swap';
 import BigN from 'bignumber.js';
@@ -262,3 +262,11 @@ export function getSwapStep (tokenSlug: string): DynamicSwapAction {
     toToken: tokenSlug
   };
 }
+
+export function isEquiValentAsset (from: _ChainAsset, to: _ChainAsset) {
+  return (
+    _getMultiChainAsset(from) === _getMultiChainAsset(to) ||
+    _getAssetPriceId(from) === _getAssetPriceId(to) ||
+    _getAssetSymbol(from) === _getAssetSymbol(to)
+  );
+}