feat: add thorswap quotor

packages/kit/src/views/Swap/quoter/index.ts

@@ -1,5 +1,7 @@
 import axios from 'axios';
 import BigNumber from 'bignumber.js';
+import { th } from 'date-fns/locale';
+import * as ethers from 'ethers';
 
 import { getNetworkImpl } from '@onekeyhq/engine/src/managers/network';
 import type { Token } from '@onekeyhq/engine/src/types/token';
@@ -31,6 +33,7 @@ import { DeezyQuoter } from './deezy';
 import { JupiterQuoter } from './jupiter';
 import { SocketQuoter } from './socket';
 import { SwftcQuoter } from './swftc';
+import { ThorSwapQuoter } from './thorswap';
 
 import type {
   BuildTransactionParams,
@@ -62,6 +65,16 @@ type TransactionOrder = {
   orderId: string;
 };
 
+type ThorSwapOrder = {
+  to: string;
+  memo: string;
+  amountIn: string;
+};
+
+type ThorSwapData = {
+  quoteId: string;
+};
+
 type EVMTransaction = {
   to: string;
   value: string;
@@ -84,6 +97,8 @@ type BuildTransactionHttpResponse = {
   order?: TransactionOrder;
   errMsg?: string;
   result?: FetchQuoteHttpResult;
+  thor?: ThorSwapData;
+  thorOrder?: ThorSwapOrder;
 };
 
 type FetchQuoteHttpParams = {
@@ -147,6 +162,8 @@ export class SwapQuoter {
 
   private socket = new SocketQuoter();
 
+  private thor = new ThorSwapQuoter();
+
   private deezy = new DeezyQuoter();
 
   private quoters: Quoter[] = [
@@ -155,6 +172,7 @@ export class SwapQuoter {
     this.jupiter,
     this.swftc,
     this.deezy,
+    this.thor,
   ];
 
   transactionReceipts: Record<
@@ -209,6 +227,44 @@ export class SwapQuoter {
     return result;
   }
 
+  async convertThorSwapOrderToTransaction(
+    params: BuildTransactionParams,
+    order: ThorSwapOrder,
+  ) {
+    const { tokenIn, networkIn, activeAccount, sellAmount } = params;
+    if (!sellAmount || !tokenIn) {
+      return;
+    }
+    if (!order.to || !order.memo || order.amountIn !== params.sellAmount) {
+      throw new Error(
+        'failed to build transaction due to invalid thor swap order params',
+      );
+    }
+    const depositCoinAmt = new BigNumber(order.amountIn)
+      .shiftedBy(-tokenIn.decimals)
+      .toFixed();
+    let result: TransactionData | undefined;
+    if (!tokenIn.tokenIdOnNetwork && networkIn.impl === IMPL_EVM) {
+      result = await backgroundApiProxy.engine.buildEncodedTxFromTransfer({
+        networkId: networkIn.id,
+        accountId: activeAccount.id,
+        transferInfo: {
+          from: activeAccount.address,
+          to: order.to,
+          amount: depositCoinAmt,
+        },
+      });
+      const transaction = result as IEncodedTxEvm;
+      if (transaction.data) {
+        throw new Error('failed to build transaction due to invalid data');
+      } else {
+        transaction.data = ethers.utils.hexlify(order.memo);
+      }
+      return result;
+    }
+    throw new Error('failed to build transaction due to unsupported network');
+  }
+
   async fetchLimitOrderQuote(params: ILimitOrderQuoteParams) {
     const urlParams = convertLimitOrderParams(params) as
       | FetchQuoteHttpParams
@@ -416,7 +472,6 @@ export class SwapQuoter {
     const requestId = this.parseRequestId(res);
 
     const data = res.data as BuildTransactionHttpResponse;
-
     if (data.errMsg) {
       throw new Error(data.errMsg);
     }
@@ -433,14 +488,20 @@ export class SwapQuoter {
             requestId,
           };
         }
-        return {
+        const result = {
           data: {
             ...data.transaction,
             from: params.activeAccount.address,
           } as IEncodedTxEvm,
           result: data.result,
           requestId,
-        };
+        } as BuildTransactionResponse;
+        if (data.thor) {
+          result.attachment = {
+            thorswapQuoteId: data.thor.quoteId,
+          };
+        }
+        return result;
       }
       return { data: data.transaction, result: data.result, requestId };
     }

packages/kit/src/views/Swap/quoter/thorswap.ts

@@ -0,0 +1,69 @@
+import axios from 'axios';
+
+import backgroundApiProxy from '../../../background/instance/backgroundApiProxy';
+import { QuoterType } from '../typings';
+
+import type {
+  Quoter,
+  TransactionDetails,
+  TransactionProgress,
+} from '../typings';
+
+export class ThorSwapQuoter implements Quoter {
+  type: QuoterType = QuoterType.thorswap;
+
+  async getBaseUrl() {
+    const baseUrl = await backgroundApiProxy.serviceSwap.getServerEndPoint();
+    return `${baseUrl}/thorswap`;
+  }
+
+  async queryTransactionProgress(
+    tx: TransactionDetails,
+  ): Promise<TransactionProgress> {
+    const { networkId, accountId, nonce, hash, attachment } = tx;
+    if (nonce !== undefined) {
+      const status =
+        await backgroundApiProxy.serviceHistory.queryTransactionNonceStatus({
+          networkId,
+          accountId,
+          nonce,
+        });
+      if (status === 'failed' || status === 'canceled') {
+        return { status };
+      }
+    }
+    if (hash && attachment?.thorswapQuoteId) {
+      const baseUrl = await this.getBaseUrl();
+      const url = `${baseUrl}/transaction_status`;
+      const res = await axios.get(url, {
+        params: {
+          hash,
+          quoteId: attachment?.thorswapQuoteId,
+        },
+      });
+      const data = res.data as {
+        status: string;
+        done: boolean;
+        result: {
+          quoteId: string;
+          firstTransactionHash: string;
+          status: string;
+          isLending: boolean;
+          isStreamingSwap: false;
+          legs: {
+            chain: string;
+            hash: string;
+          }[];
+        };
+      };
+      if (data.status === 'success') {
+        return { status: 'sucesss' };
+      }
+      return { status: 'pending' };
+    }
+    if (Date.now() - tx.addedTime > 60 * 60 * 1000 * 24) {
+      return { status: 'failed' };
+    }
+    return undefined;
+  }
+}

packages/kit/src/views/Swap/typings.ts

@@ -120,6 +120,7 @@ export enum QuoterType {
   jupiter = 'jupiter',
   onekey = 'onekey',
   deezy = 'Deezy',
+  thorswap = 'Thorswap',
 }
 
 export type FieldType = 'INPUT' | 'OUTPUT';
@@ -237,6 +238,12 @@ export interface TransactionAttachment {
   swftcReceiveCoinAmt?: string;
   swftcReceiveCoinCode?: string;
   socketUsedBridgeNames?: string[];
+
+  thorswapQuoteId?: string;
+}
+
+export interface ThorswapOrderReceipt {
+  quoteId: string;
 }
 
 export type BuildTransactionParams = FetchQuoteParams & {

packages/kit/src/views/Swap/utils.ts

@@ -300,7 +300,8 @@ export function convertParams(params: FetchQuoteParams) {
   if (params.onChainSatsPerVbyte) {
     urlParams.onChainSatsPerVbyte = params.onChainSatsPerVbyte;
   }
-  urlParams.includes = '0x,1inch,jupiter,openocean,swftc,socket,mdex,Deezy';
+  urlParams.includes =
+    '0x,1inch,jupiter,openocean,swftc,socket,mdex,Deezy,Thorswap';
   urlParams.noFilter = true;
   return urlParams;
 }