[Issue-4079] feat: handle 1-length path

Author: bluezdot

packages/extension-base/src/koni/background/handlers/Extension.ts

@@ -46,6 +46,7 @@ import { EXTENSION_REQUEST_URL } from '@subwallet/extension-base/services/reques
 import { AuthUrls } from '@subwallet/extension-base/services/request-service/types';
 import { DEFAULT_AUTO_LOCK_TIME } from '@subwallet/extension-base/services/setting-service/constants';
 import { checkLiquidityForPool, estimateTokensForPool, getReserveForPool } from '@subwallet/extension-base/services/swap-service/handler/asset-hub/utils';
+import { generateSwapPairs } from '@subwallet/extension-base/services/swap-service/utils';
 import { SWTransaction, SWTransactionInput, SWTransactionResponse, SWTransactionResult, TransactionEmitter, TransactionEventResponse, ValidateTransactionResponseInput } from '@subwallet/extension-base/services/transaction-service/types';
 import { isProposalExpired, isSupportWalletConnectChain, isSupportWalletConnectNamespace } from '@subwallet/extension-base/services/wallet-connect-service/helpers';
 import { ResultApproveWalletConnectSession, WalletConnectNotSupportRequest, WalletConnectSessionRequest } from '@subwallet/extension-base/services/wallet-connect-service/types';
@@ -1325,6 +1326,10 @@ export default class KoniExtension {
     const warnings: TransactionWarning[] = [];
     const chainInfo = this.#koniState.getChainInfo(chain);
 
+    const test = generateSwapPairs(this.#koniState.getSubstrateApi(chain), this.#koniState.chainService, transferTokenInfo);
+
+    console.log('test', test);
+
     const nativeTokenInfo = this.#koniState.getNativeTokenInfo(chain);
     const nativeTokenSlug: string = nativeTokenInfo.slug;
     const isTransferNativeToken = nativeTokenSlug === tokenSlug;

packages/extension-base/src/services/chain-service/utils/index.ts

@@ -486,6 +486,10 @@ export function _isAssetFungibleToken (chainAsset: _ChainAsset): boolean {
   return ![_AssetType.ERC721, _AssetType.PSP34, _AssetType.UNKNOWN].includes(chainAsset.assetType);
 }
 
+export function _getFungibleAssetType () {
+  return [_AssetType.NATIVE, _AssetType.LOCAL, _AssetType.ERC20, _AssetType.GRC20, _AssetType.TEP74, _AssetType.PSP22, _AssetType.VFT];
+}
+
 export const _isAssetAutoEnable = (chainAsset: _ChainAsset): boolean => {
   return chainAsset.metadata ? !!chainAsset.metadata.autoEnable : false;
 };

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

@@ -4,7 +4,9 @@
 import { Asset, Assets, Chain, Chains } from '@chainflip/sdk/swap';
 import { COMMON_ASSETS, COMMON_CHAIN_SLUGS } from '@subwallet/chain-list';
 import { _ChainAsset } from '@subwallet/chain-list/types';
-import { _getAssetDecimals } from '@subwallet/extension-base/services/chain-service/utils';
+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 { 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';
@@ -117,3 +119,66 @@ export function getChainflipBroker (isTestnet: boolean) { // noted: currently no
     };
   }
 }
+
+export function generateSwapPairs (substrateApi: _SubstrateApi, chainService: ChainService, fromAsset: _ChainAsset, maxPathLength = 1) {
+  let currentTargets: _ChainAsset[] = [];
+  let newTargets: _ChainAsset[] = [];
+
+  if (maxPathLength < 1) {
+    return currentTargets;
+  }
+
+  const xcmTargets = findXcmDestinations(chainService, fromAsset);
+  const swapTargets = findSwapDestinations(chainService, fromAsset);
+
+  newTargets = Array.from(new Set([...xcmTargets, ...swapTargets]));
+  currentTargets = Array.from(new Set([...currentTargets, ...newTargets]));
+
+  return currentTargets;
+}
+
+export function findXcmDestinations (chainService: ChainService, chainAsset: _ChainAsset) {
+  const xcmTargets: _ChainAsset[] = [];
+  const multichainAssetSlug = _getMultiChainAsset(chainAsset);
+
+  if (!multichainAssetSlug) {
+    return xcmTargets;
+  }
+
+  const assetRegistry = chainService.getAssetRegistry();
+
+  for (const asset of Object.values(assetRegistry)) {
+    if (multichainAssetSlug === _getMultiChainAsset(asset)) {
+      xcmTargets.push(asset);
+    }
+  }
+
+  return xcmTargets;
+}
+
+export function findSwapDestinations (chainService: ChainService, chainAsset: _ChainAsset) {
+  const swapTargets: _ChainAsset[] = [];
+  const chain = chainAsset.originChain;
+
+  const availableChains = Object.values(_PROVIDER_TO_SUPPORTED_PAIR_MAP).reduce((remainChains, currentChains) => {
+    if (currentChains.includes(chain)) {
+      currentChains.forEach((candidate) => {
+        remainChains.add(candidate);
+      });
+    }
+
+    return remainChains;
+  }, new Set<string>());
+
+  availableChains.forEach((candidate) => {
+    const assets = chainService.getAssetByChainAndType(candidate, _getFungibleAssetType()); // todo: recheck assetType
+
+    swapTargets.push(...Object.values(assets));
+  });
+
+  return swapTargets;
+}
+
+export function isHasChannel (subtrateApi: _SubstrateApi, fromChain: _ChainAsset, toChain: _ChainAsset) {
+  return true;
+}