Make swap timeouts adjustable

CHANGELOG.md

@@ -2,6 +2,8 @@
 
 ## Unreleased
 
+- added: Make swap timeouts adjustable.
+
 ## 2.0.1 (2024-01-08)
 
 - added: Missing asset action types (claim, claimOrder, swapNetworkFee, and transferNetworkFee).

src/core/swap/swap-api.ts

@@ -14,7 +14,7 @@ import {
   EdgeSwapRequest,
   EdgeSwapRequestOptions
 } from '../../types/types'
-import { fuzzyTimeout } from '../../util/promise'
+import { fuzzyTimeout, timeout } from '../../util/promise'
 import { ApiInput } from '../root-pixie'
 
 /**
@@ -26,7 +26,13 @@ export async function fetchSwapQuotes(
   request: EdgeSwapRequest,
   opts: EdgeSwapRequestOptions = {}
 ): Promise<EdgeSwapQuote[]> {
-  const { disabled = {}, preferPluginId, promoCodes = {} } = opts
+  const {
+    disabled = {},
+    noResponseMs,
+    preferPluginId,
+    promoCodes = {},
+    slowResponseMs = 20000
+  } = opts
   const { log } = ai.props
 
   const account = ai.props.state.accounts[accountId]
@@ -76,7 +82,7 @@ export async function fetchSwapQuotes(
   }
 
   // Wait for the results, with error handling:
-  return await fuzzyTimeout(promises, 20000).then(
+  const promise = fuzzyTimeout(promises, slowResponseMs).then(
     ({ results: quotes, errors }) => {
       for (const pluginId of pendingIds) {
         log.warn(`${pluginId} gave swap timeout`)
@@ -98,6 +104,9 @@ export async function fetchSwapQuotes(
       throw pickBestError(errors)
     }
   )
+
+  if (noResponseMs == null) return await promise
+  return await timeout(promise, noResponseMs)
 }
 
 function wrapQuote(

src/types/types.ts

@@ -1452,6 +1452,18 @@ export interface EdgeSwapRequestOptions {
   preferType?: EdgeSwapPluginType
   disabled?: EdgePluginMap<true>
   promoCodes?: EdgePluginMap<string>
+
+  /**
+   * If we have some quotes already, how long should we wait
+   * for stragglers before we give up? Defaults to 20000ms.
+   */
+  slowResponseMs?: number
+
+  /**
+   * If don't have any quotes yet, how long should we wait
+   * before we give up? Defaults to Infinity.
+   */
+  noResponseMs?: number
 }
 
 // edge login ----------------------------------------------------------

src/util/promise.ts

@@ -26,12 +26,12 @@ export function timeout<T>(
     const timer = setTimeout(() => reject(error), ms)
     promise.then(
       ok => {
-        resolve(ok)
         clearTimeout(timer)
+        resolve(ok)
       },
       error => {
-        reject(error)
         clearTimeout(timer)
+        reject(error)
       }
     )
   })