chore: release v1.523.0

package.json

@@ -81,6 +81,7 @@
     "@keepkey/hdwallet-keepkey-rest": "1.40.40",
     "@keepkey/keepkey-sdk": "0.2.52",
     "@lifi/sdk": "^2.2.3",
+    "@lukemorales/query-key-factory": "^1.3.2",
     "@metamask/detect-provider": "^1.2.0",
     "@react-spring/web": "^9.5.2",
     "@reduxjs/toolkit": "^1.9.3",

src/components/MultiHopTrade/components/MultiHopTradeConfirm/components/HopTransactionStep.tsx

@@ -9,7 +9,10 @@ import { getChainAdapterManager } from 'context/PluginProvider/chainAdapterSingl
 import { useLocaleFormatter } from 'hooks/useLocaleFormatter/useLocaleFormatter'
 import { getTxLink } from 'lib/getTxLink'
 import { fromBaseUnit } from 'lib/math'
-import { THORCHAIN_STREAM_SWAP_SOURCE } from 'lib/swapper/swappers/ThorchainSwapper/constants'
+import {
+  THORCHAIN_LONGTAIL_STREAMING_SWAP_SOURCE,
+  THORCHAIN_STREAM_SWAP_SOURCE,
+} from 'lib/swapper/swappers/ThorchainSwapper/constants'
 import { selectHopExecutionMetadata } from 'state/slices/tradeQuoteSlice/selectors'
 import { TransactionExecutionState } from 'state/slices/tradeQuoteSlice/types'
 import { useAppSelector } from 'state/store'
@@ -110,7 +113,9 @@ export const HopTransactionStep = ({
       )
     }
 
-    const isThorStreamingSwap = tradeQuoteStep.source === THORCHAIN_STREAM_SWAP_SOURCE
+    const isThorStreamingSwap =
+      tradeQuoteStep.source === THORCHAIN_STREAM_SWAP_SOURCE ||
+      THORCHAIN_LONGTAIL_STREAMING_SWAP_SOURCE
 
     if (sellTxHash !== undefined && isThorStreamingSwap) {
       return (

src/components/MultiHopTrade/components/TradeConfirm/ReceiveSummary.tsx

@@ -22,7 +22,10 @@ import type { TextPropTypes } from 'components/Text/Text'
 import { getChainAdapterManager } from 'context/PluginProvider/chainAdapterSingleton'
 import { bnOrZero } from 'lib/bignumber/bignumber'
 import { fromBaseUnit } from 'lib/math'
-import { THORCHAIN_STREAM_SWAP_SOURCE } from 'lib/swapper/swappers/ThorchainSwapper/constants'
+import {
+  THORCHAIN_LONGTAIL_STREAMING_SWAP_SOURCE,
+  THORCHAIN_STREAM_SWAP_SOURCE,
+} from 'lib/swapper/swappers/ThorchainSwapper/constants'
 import { isSome } from 'lib/utils'
 import {
   selectActiveQuoteAffiliateBps,
@@ -248,43 +251,44 @@ export const ReceiveSummary: FC<ReceiveSummaryProps> = memo(
                 </Skeleton>
               </Row.Value>
             </Row>
-            {swapSource !== THORCHAIN_STREAM_SWAP_SOURCE && (
-              <>
-                <Divider borderColor='border.base' />
-                <Row>
-                  <Row.Label>
-                    <Text translation={minAmountAfterSlippageTranslation} />
-                  </Row.Label>
-                  <Row.Value whiteSpace='nowrap'>
-                    <Stack spacing={0} alignItems='flex-end'>
-                      <Skeleton isLoaded={!isLoading}>
-                        <Amount.Crypto value={amountAfterSlippage} symbol={symbol} />
-                      </Skeleton>
-                      {isAmountPositive &&
-                        hasIntermediaryTransactionOutputs &&
-                        intermediaryTransactionOutputsParsed?.map(
-                          ({ amountCryptoPrecision, symbol, chainName }) => (
-                            <Skeleton isLoaded={!isLoading} key={`${symbol}_${chainName}`}>
-                              <Amount.Crypto
-                                value={amountCryptoPrecision}
-                                symbol={symbol}
-                                prefix={translate('trade.or')}
-                                suffix={
-                                  chainName
-                                    ? translate('trade.onChainName', {
-                                        chainName,
-                                      })
-                                    : undefined
-                                }
-                              />
-                            </Skeleton>
-                          ),
-                        )}
-                    </Stack>
-                  </Row.Value>
-                </Row>
-              </>
-            )}
+            {swapSource !== THORCHAIN_STREAM_SWAP_SOURCE &&
+              swapSource !== THORCHAIN_LONGTAIL_STREAMING_SWAP_SOURCE && (
+                <>
+                  <Divider borderColor='border.base' />
+                  <Row>
+                    <Row.Label>
+                      <Text translation={minAmountAfterSlippageTranslation} />
+                    </Row.Label>
+                    <Row.Value whiteSpace='nowrap'>
+                      <Stack spacing={0} alignItems='flex-end'>
+                        <Skeleton isLoaded={!isLoading}>
+                          <Amount.Crypto value={amountAfterSlippage} symbol={symbol} />
+                        </Skeleton>
+                        {isAmountPositive &&
+                          hasIntermediaryTransactionOutputs &&
+                          intermediaryTransactionOutputsParsed?.map(
+                            ({ amountCryptoPrecision, symbol, chainName }) => (
+                              <Skeleton isLoaded={!isLoading} key={`${symbol}_${chainName}`}>
+                                <Amount.Crypto
+                                  value={amountCryptoPrecision}
+                                  symbol={symbol}
+                                  prefix={translate('trade.or')}
+                                  suffix={
+                                    chainName
+                                      ? translate('trade.onChainName', {
+                                          chainName,
+                                        })
+                                      : undefined
+                                  }
+                                />
+                              </Skeleton>
+                            ),
+                          )}
+                      </Stack>
+                    </Row.Value>
+                  </Row>
+                </>
+              )}
           </Stack>
         </Collapse>
         <FeeModal isOpen={showFeeModal} onClose={handleFeeModal} />

src/components/MultiHopTrade/components/TradeConfirm/TradeConfirm.tsx

@@ -49,7 +49,10 @@ import { getTxLink } from 'lib/getTxLink'
 import { firstNonZeroDecimal } from 'lib/math'
 import { getMixPanel } from 'lib/mixpanel/mixPanelSingleton'
 import { MixPanelEvent } from 'lib/mixpanel/types'
-import { THORCHAIN_STREAM_SWAP_SOURCE } from 'lib/swapper/swappers/ThorchainSwapper/constants'
+import {
+  THORCHAIN_LONGTAIL_STREAMING_SWAP_SOURCE,
+  THORCHAIN_STREAM_SWAP_SOURCE,
+} from 'lib/swapper/swappers/ThorchainSwapper/constants'
 import { assertUnreachable } from 'lib/utils'
 import { selectManualReceiveAddress } from 'state/slices/tradeInputSlice/selectors'
 import {
@@ -156,7 +159,9 @@ export const TradeConfirm = () => {
   const txHash = buyTxHash ?? sellTxHash
 
   const isThorStreamingSwap = useMemo(
-    () => tradeQuoteStep?.source === THORCHAIN_STREAM_SWAP_SOURCE,
+    () =>
+      tradeQuoteStep?.source === THORCHAIN_STREAM_SWAP_SOURCE ||
+      tradeQuoteStep?.source === THORCHAIN_LONGTAIL_STREAMING_SWAP_SOURCE,
     [tradeQuoteStep?.source],
   )
 

src/context/QueryClientProvider/queryClient.ts

@@ -4,6 +4,10 @@ export const queryClient = new QueryClient({
   defaultOptions: {
     queries: {
       refetchOnWindowFocus: false, // default: true
+      // This will ensure the cache is used if available (the query hasn't gone stale, and the cache isn't expired)
+      refetchOnMount: false, // default: true
+      // We will most likely want this as a default but would need to audit all usages to ensure this isn't going to be a rug anywhere
+      // staleTime: Infinity, // default: 0
     },
   },
 })

src/lib/getTxLink.ts

@@ -2,7 +2,11 @@ import type { SwapSource } from '@shapeshiftoss/swapper'
 import { SwapperName } from '@shapeshiftoss/swapper'
 import { Dex } from '@shapeshiftoss/unchained-client'
 
-import { THORCHAIN_STREAM_SWAP_SOURCE } from './swapper/swappers/ThorchainSwapper/constants'
+import {
+  THORCHAIN_LONGTAIL_STREAMING_SWAP_SOURCE,
+  THORCHAIN_LONGTAIL_SWAP_SOURCE,
+  THORCHAIN_STREAM_SWAP_SOURCE,
+} from './swapper/swappers/ThorchainSwapper/constants'
 
 type GetBaseUrl = {
   name: SwapSource | Dex | undefined
@@ -21,6 +25,8 @@ export const getTxBaseUrl = ({ name, defaultExplorerBaseUrl, isOrder }: GetBaseU
     case Dex.Thor:
     case SwapperName.Thorchain:
     case THORCHAIN_STREAM_SWAP_SOURCE:
+    case THORCHAIN_LONGTAIL_SWAP_SOURCE:
+    case THORCHAIN_LONGTAIL_STREAMING_SWAP_SOURCE:
       return 'https://viewblock.io/thorchain/tx/'
     default:
       return defaultExplorerBaseUrl

src/lib/swapper/swappers/ThorchainSwapper/constants.ts

@@ -28,6 +28,8 @@ export const buySupportedChainIds: Record<ChainId, boolean> = {
 }
 
 export const THORCHAIN_STREAM_SWAP_SOURCE: SwapSource = `${SwapperName.Thorchain} • Streaming`
+export const THORCHAIN_LONGTAIL_SWAP_SOURCE: SwapSource = `${SwapperName.Thorchain} • Long-tail`
+export const THORCHAIN_LONGTAIL_STREAMING_SWAP_SOURCE: SwapSource = `${SwapperName.Thorchain} • Long-tail streaming`
 
 // https://dev.thorchain.org/thorchain-dev/interface-guide/fees#thorchain-native-rune
 // static automatic outbound fee as defined by: https://daemon.thorchain.shapeshift.com/lcd/thorchain/constants

src/lib/swapper/swappers/ThorchainSwapper/endpoints.ts

@@ -5,28 +5,30 @@ import { cosmosAssetId, fromAssetId, fromChainId, thorchainAssetId } from '@shap
 import type { EvmChainId } from '@shapeshiftoss/chain-adapters'
 import { cosmossdk as cosmossdkChainAdapter } from '@shapeshiftoss/chain-adapters'
 import type { BTCSignTx } from '@shapeshiftoss/hdwallet-core'
-import type {
-  CosmosSdkFeeData,
-  EvmTransactionRequest,
-  GetTradeQuoteInput,
-  GetUnsignedCosmosSdkTransactionArgs,
-  GetUnsignedEvmTransactionArgs,
-  GetUnsignedUtxoTransactionArgs,
-  SwapErrorRight,
-  SwapperApi,
-  TradeQuote,
-  UtxoFeeData,
+import {
+  type CosmosSdkFeeData,
+  type EvmTransactionRequest,
+  type GetTradeQuoteInput,
+  type GetUnsignedCosmosSdkTransactionArgs,
+  type GetUnsignedEvmTransactionArgs,
+  type GetUnsignedUtxoTransactionArgs,
+  makeSwapErrorRight,
+  type SwapErrorRight,
+  type SwapperApi,
+  type TradeQuote,
+  TradeQuoteError,
+  type UtxoFeeData,
 } from '@shapeshiftoss/swapper'
 import type { AssetsByIdPartial } from '@shapeshiftoss/types'
 import { KnownChainIds } from '@shapeshiftoss/types'
 import { cosmossdk, evm, TxStatus } from '@shapeshiftoss/unchained-client'
-import { type Result } from '@sniptt/monads/build'
+import { Err, type Result } from '@sniptt/monads/build'
 import assert from 'assert'
 import axios from 'axios'
 import { getConfig } from 'config'
 import type { Address } from 'viem'
 import { encodeFunctionData, parseAbiItem } from 'viem'
-import { bnOrZero } from 'lib/bignumber/bignumber'
+import { BigNumber, bn, bnOrZero } from 'lib/bignumber/bignumber'
 import { getThorTxInfo as getUtxoThorTxInfo } from 'lib/swapper/swappers/ThorchainSwapper/utxo/utils/getThorTxData'
 import { assertUnreachable } from 'lib/utils'
 import { assertGetEvmChainAdapter } from 'lib/utils/evm'
@@ -73,7 +75,15 @@ export const thorchainApi: SwapperApi = {
     supportsEIP1559,
   }: GetUnsignedEvmTransactionArgs): Promise<EvmTransactionRequest> => {
     // TODO: pull these from db using id so we don't have type zoo and casting hell
-    const { router: to, data, steps, memo: tcMemo, tradeType } = tradeQuote as ThorEvmTradeQuote
+    const {
+      router: to,
+      data,
+      steps,
+      memo: tcMemo,
+      tradeType,
+      longtailData,
+      slippageTolerancePercentageDecimal,
+    } = tradeQuote as ThorEvmTradeQuote
     const { sellAmountIncludingProtocolFeesCryptoBaseUnit, sellAsset } = steps[0]
 
     const value = isNativeEvmAsset(sellAsset.assetId)
@@ -146,9 +156,33 @@ export const thorchainApi: SwapperApi = {
         const publicClient = viemClientByChainId[chainId as EvmChainId]
         assert(publicClient !== undefined, `no public client found for chainId '${chainId}'`)
 
+        const expectedAmountOut = BigInt(longtailData?.longtailToL1ExpectedAmountOut ?? 0)
+        // Paranoia assertion - expectedAmountOut should never be 0 as it would likely lead to a loss of funds.
+        assert(
+          expectedAmountOut !== undefined && expectedAmountOut > 0n,
+          'expected expectedAmountOut to be a positive amount',
+        )
+
+        const amountOutMin = BigInt(
+          bnOrZero(expectedAmountOut.toString())
+            .times(bn(1).minus(slippageTolerancePercentageDecimal ?? 0))
+            .toFixed(0, BigNumber.ROUND_UP),
+        )
+
+        if (amountOutMin <= 0n) {
+          throw Err(
+            makeSwapErrorRight({
+              code: TradeQuoteError.SellAmountBelowMinimum,
+              message: 'Sell amount is too small',
+            }),
+          )
+        }
+
+        // Paranoia: ensure we have this to prevent sandwich attacks on the first step of a LongtailToL1 trade.
+        assert(amountOutMin > 0n, 'expected expectedAmountOut to be a positive amount')
+
         const token: Address = fromAssetId(sellAsset.assetId).assetReference as Address
         const amount: bigint = BigInt(sellAmountIncludingProtocolFeesCryptoBaseUnit)
-        const amountOutMin: bigint = BigInt(0) // todo: the buy amount
         const currentTimestamp = BigInt(Math.floor(Date.now() / 1000))
         const tenMinutes = BigInt(600)
         const deadline = currentTimestamp + tenMinutes

src/lib/swapper/swappers/ThorchainSwapper/getThorTradeQuote/getTradeQuote.ts

@@ -19,6 +19,9 @@ type ThorTradeQuoteSpecificMetadata = {
   isStreaming: boolean
   memo: string
   recommendedMinimumCryptoBaseUnit: string
+  longtailData?: {
+    longtailToL1ExpectedAmountOut?: bigint
+  }
 }
 export type ThorEvmTradeQuote = TradeQuote &
   ThorTradeQuoteSpecificMetadata & {
@@ -58,15 +61,6 @@ export const getThorTradeQuote = async (
   const buyPoolId = assetIdToPoolAssetId({ assetId: buyAsset.assetId })
   const sellPoolId = assetIdToPoolAssetId({ assetId: sellAsset.assetId })
 
-  if (!buyPoolId || !sellPoolId) {
-    return Err(
-      makeSwapErrorRight({
-        message: 'Unsupported trade pair',
-        code: TradeQuoteError.UnsupportedTradePair,
-      }),
-    )
-  }
-
   // If one or both of these are undefined it means we are tradeing one or more long-tail ERC20 tokens
   const sellAssetPool = poolsResponse.find(pool => pool.asset === sellPoolId)
   const buyAssetPool = poolsResponse.find(pool => pool.asset === buyPoolId)
@@ -83,6 +77,18 @@ export const getThorTradeQuote = async (
     )
   }
 
+  if (
+    (!buyPoolId && tradeType !== TradeType.L1ToLongTail) ||
+    (!sellPoolId && tradeType !== TradeType.LongTailToL1)
+  ) {
+    return Err(
+      makeSwapErrorRight({
+        message: 'Unsupported trade pair',
+        code: TradeQuoteError.UnsupportedTradePair,
+      }),
+    )
+  }
+
   const streamingInterval =
     sellAssetPool && buyAssetPool
       ? (() => {