retry in won function

.vscode/settings.json

@@ -90,6 +90,7 @@
     "Overridable",
     "pako",
     "payloadset",
+    "Promisable",
     "quadkey",
     "quadkeys",
     "rdns",

.yarn/versions/37922f8f.yml

@@ -0,0 +1,49 @@
+releases:
+  "@xyo-network/react-address": patch
+  "@xyo-network/react-address-history": patch
+  "@xyo-network/react-address-plugin": patch
+  "@xyo-network/react-address-render": patch
+  "@xyo-network/react-aggregate-price-plugin": patch
+  "@xyo-network/react-app-settings": patch
+  "@xyo-network/react-appbar": patch
+  "@xyo-network/react-archivist": patch
+  "@xyo-network/react-block": patch
+  "@xyo-network/react-boundwitness-plugin": patch
+  "@xyo-network/react-card": patch
+  "@xyo-network/react-coin-gecko-prices-plugin": patch
+  "@xyo-network/react-connected-accounts": patch
+  "@xyo-network/react-crypto-market-uniswap-plugin": patch
+  "@xyo-network/react-crypto-prices-plugin": patch
+  "@xyo-network/react-default-plugin": patch
+  "@xyo-network/react-details-plugin": patch
+  "@xyo-network/react-diviner": patch
+  "@xyo-network/react-elevation-map-quadkey-plugin": patch
+  "@xyo-network/react-embed": patch
+  "@xyo-network/react-ethereum-gas-price-blocknative-plugin": patch
+  "@xyo-network/react-ethereum-gas-price-etherchain-plugins": patch
+  "@xyo-network/react-ethereum-gas-price-etherchain-v2-plugin": patch
+  "@xyo-network/react-ethereum-gas-price-ethers-plugin": patch
+  "@xyo-network/react-ethereum-gas-price-etherscan-plugin": patch
+  "@xyo-network/react-ethereum-gas-price-ethgasstation-plugin": patch
+  "@xyo-network/react-ethereum-gas-price-payload-plugins": patch
+  "@xyo-network/react-ethereum-gas-price-plugin": patch
+  "@xyo-network/react-location-heatmap-quadkey-plugin": patch
+  "@xyo-network/react-location-point-map-plugin": patch
+  "@xyo-network/react-location-points-map-plugin": patch
+  "@xyo-network/react-module": patch
+  "@xyo-network/react-modules": patch
+  "@xyo-network/react-nft-score-plugin": patch
+  "@xyo-network/react-node": patch
+  "@xyo-network/react-node-context": patch
+  "@xyo-network/react-node-provider": patch
+  "@xyo-network/react-plugins": patch
+  "@xyo-network/react-pointer-plugin": patch
+  "@xyo-network/react-price-forecast-plugin": patch
+  "@xyo-network/react-schema-plugin": patch
+  "@xyo-network/react-sdk": patch
+  "@xyo-network/react-sentinel": patch
+  "@xyo-network/react-witness": patch
+  "@xyo-network/sdk-xyo-react": patch
+
+undecided:
+  - "@xyo-network/react-indexed-results"

packages/sdk/packages/indexed-results/src/hooks/support/divineSingleIndexedResults.tsx

@@ -1,8 +1,8 @@
-import { delay } from '@xylabs/delay'
 import { DivinerInstance } from '@xyo-network/diviner-model'
 import { Payload } from '@xyo-network/payload-model'
 
 import { ParseIndexedResults } from '../../interfaces'
+import { retry } from './retry'
 
 const divineSingleIndexedResultsInner = async <TPayload extends Payload = Payload>(
   diviner: DivinerInstance,
@@ -24,14 +24,6 @@ export const divineSingleIndexedResults = async <TPayload extends Payload = Payl
   retries = 0,
   interval = 100,
   backoff = 2,
-): Promise<TPayload[] | null> => {
-  const results = await divineSingleIndexedResultsInner(diviner, indexedQueries, parseIndexedResults)
-  if (results) {
-    return results
-  }
-  if (retries <= 0) {
-    return null
-  }
-  await delay(interval)
-  return divineSingleIndexedResults(diviner, indexedQueries, parseIndexedResults, retries - 1, interval * backoff, backoff)
+): Promise<TPayload[] | null | undefined> => {
+  return await retry(() => divineSingleIndexedResultsInner(diviner, indexedQueries, parseIndexedResults), { backoff, interval, retries })
 }

packages/sdk/packages/indexed-results/src/hooks/support/retry.tsx

@@ -0,0 +1,23 @@
+import { delay } from '@xylabs/delay'
+import { Promisable } from '@xylabs/promise'
+import { AnyObject } from '@xyo-network/object'
+
+export interface RetryConfig<T = AnyObject> {
+  backoff?: number
+  complete?: (result?: T) => boolean
+  interval?: number
+  retries?: number
+}
+
+export const retry = async <T = AnyObject,>(func: () => Promisable<T | undefined>, config?: RetryConfig<T>): Promise<T | undefined> => {
+  const { complete = (value: T | undefined) => value !== undefined, retries = 0, interval = 100, backoff = 2 } = config ?? {}
+  const result = await func()
+  if (complete(result)) {
+    return result
+  }
+  if (retries <= 0) {
+    return undefined
+  }
+  await delay(interval)
+  return retry(func, { backoff, complete, interval: interval * backoff, retries: retries - 1 })
+}