[Issue-4078] feat: find process (temp)

Author: bluezdot

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

@@ -48,8 +48,8 @@ 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 { SWPermitTransaction, SWTransaction, SWTransactionInput, SWTransactionResponse, SWTransactionResult, TransactionEmitter, TransactionEventResponse, ValidateTransactionResponseInput } from '@subwallet/extension-base/services/transaction-service/types';
 import { generateSwapPairs } from '@subwallet/extension-base/services/swap-service/utils';
+import { SWPermitTransaction, 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';
 import { SWStorage } from '@subwallet/extension-base/storage';
@@ -1345,6 +1345,7 @@ export default class KoniExtension {
     const warnings: TransactionWarning[] = [];
     const chainInfo = this.#koniState.getChainInfo(chain);
 
+    // todo: remove test:
     const test = generateSwapPairs(this.#koniState.getSubstrateApi(chain), this.#koniState.chainService, transferTokenInfo, 3).map((asset) => asset.slug);
 
     console.log('test', test);
@@ -4069,6 +4070,16 @@ export default class KoniExtension {
   }
 
   private async handleSwapRequest (request: SwapRequest): Promise<SwapRequestResult> {
+    // todo: remove test:
+    const testSwapRequest = this.#koniState.swapService.handleSwapRequestV2({
+      address: '1BzDB5n2rfSJwvuCW9deKY9XnUyys8Gy44SoX8tRNDCFBhx',
+      fromAmount: '1',
+      fromToken: 'polkadot-NATIVE-DOT',
+      toToken: 'hydration-NATIVE-DOT'
+    });
+
+    console.log('testSwapRequest', testSwapRequest);
+
     return this.#koniState.swapService.handleSwapRequest(request);
   }
 

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

@@ -11,8 +11,8 @@ import { AssetHubSwapHandler } from '@subwallet/extension-base/services/swap-ser
 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, getSwapAltToken, SWAP_QUOTE_TIMEOUT_MAP } from '@subwallet/extension-base/services/swap-service/utils';
-import { BasicTxErrorType } from '@subwallet/extension-base/types';
+import { _PROVIDER_TO_SUPPORTED_PAIR_MAP, generateSwapPairs, getSwapAltToken, 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';
 import { createPromiseHandler, PromiseHandler } from '@subwallet/extension-base/utils';
@@ -125,12 +125,39 @@ export class SwapService implements ServiceWithProcessInterface, StoppableServic
       selectedQuote: swapQuoteResponse.optimalQuote
     });
 
+    console.log('optimalProcess', optimalProcess);
+    console.log('swapQuoteResponse', swapQuoteResponse);
+
     return {
       process: optimalProcess,
       quote: swapQuoteResponse
     } as SwapRequestResult;
   }
 
+  public handleSwapRequestV2 (request: SwapRequestV2) {
+    const { fromToken, toToken } = request;
+    const fromTokenInfo = this.chainService.getAssetBySlug(fromToken);
+    const toTokenInfo = this.chainService.getAssetBySlug(toToken);
+    const substrateApi = this.chainService.getSubstrateApi(fromTokenInfo.originChain);
+    const steps = [];
+
+    const destinations = generateSwapPairs(substrateApi, this.chainService, fromTokenInfo, 1);
+
+    if (destinations.length > 0 && destinations.includes(toTokenInfo)) {
+      steps.push({
+        action: 'SWAP', // todo: check XCM / SWAP
+        toToken
+      });
+    }
+
+    if (steps.length) {
+      return steps;
+    }
+
+    // todo: try find process
+    return steps;
+  }
+
   public async getLatestQuotes (request: SwapRequest): Promise<SwapQuoteResponse> {
     request.pair.metadata = this.getSwapPairMetadata(request.pair.slug); // todo: improve this
     const quoteAskResponses = await this.askProvidersForQuote(request);

packages/extension-base/src/types/swap/index.ts

@@ -169,6 +169,13 @@ export interface SwapRequest {
   currentQuote?: SwapProvider
 }
 
+export interface SwapRequestV2 {
+  address: string;
+  fromAmount: string;
+  fromToken: string;
+  toToken: string;
+}
+
 export interface SwapRequestResult {
   process: CommonOptimalPath;
   quote: SwapQuoteResponse;