BLUE

Navigation

Breadcrumbs

/ / var / www / gtechmarathon2026.bitkit.dk / httpdocs / node_modules / @tanstack / query-core / src

Create

Upload

Tip: You can also drag & drop files anywhere on this page to upload.

Edit File Size: 5.50 KB

/var/www/gtechmarathon2026.bitkit.dk/httpdocs/node_modules/@tanstack/query-core/src/retryer.ts

Text Base64

import { focusManager } from './focusManager'
import { onlineManager } from './onlineManager'
import { pendingThenable } from './thenable'
import { isServer, sleep } from './utils'
import type { CancelOptions, DefaultError, NetworkMode } from './types'

// TYPES

interface RetryerConfig<TData = unknown, TError = DefaultError> {
  fn: () => TData | Promise<TData>
  initialPromise?: Promise<TData>
  abort?: () => void
  onError?: (error: TError) => void
  onSuccess?: (data: TData) => void
  onFail?: (failureCount: number, error: TError) => void
  onPause?: () => void
  onContinue?: () => void
  retry?: RetryValue<TError>
  retryDelay?: RetryDelayValue<TError>
  networkMode: NetworkMode | undefined
  canRun: () => boolean
}

export interface Retryer<TData = unknown> {
  promise: Promise<TData>
  cancel: (cancelOptions?: CancelOptions) => void
  continue: () => Promise<unknown>
  cancelRetry: () => void
  continueRetry: () => void
  canStart: () => boolean
  start: () => Promise<TData>
}

export type RetryValue<TError> = boolean | number | ShouldRetryFunction<TError>

type ShouldRetryFunction<TError = DefaultError> = (
  failureCount: number,
  error: TError,
) => boolean

export type RetryDelayValue<TError> = number | RetryDelayFunction<TError>

type RetryDelayFunction<TError = DefaultError> = (
  failureCount: number,
  error: TError,
) => number

function defaultRetryDelay(failureCount: number) {
  return Math.min(1000 * 2 ** failureCount, 30000)
}

export function canFetch(networkMode: NetworkMode | undefined): boolean {
  return (networkMode ?? 'online') === 'online'
    ? onlineManager.isOnline()
    : true
}

export class CancelledError extends Error {
  revert?: boolean
  silent?: boolean
  constructor(options?: CancelOptions) {
    super('CancelledError')
    this.revert = options?.revert
    this.silent = options?.silent
  }
}

export function isCancelledError(value: any): value is CancelledError {
  return value instanceof CancelledError
}

export function createRetryer<TData = unknown, TError = DefaultError>(
  config: RetryerConfig<TData, TError>,
): Retryer<TData> {
  let isRetryCancelled = false
  let failureCount = 0
  let isResolved = false
  let continueFn: ((value?: unknown) => void) | undefined

const thenable = pendingThenable<TData>()

const cancel = (cancelOptions?: CancelOptions): void => {
    if (!isResolved) {
      reject(new CancelledError(cancelOptions))

config.abort?.()
    }
  }
  const cancelRetry = () => {
    isRetryCancelled = true
  }

const continueRetry = () => {
    isRetryCancelled = false
  }

const canContinue = () =>
    focusManager.isFocused() &&
    (config.networkMode === 'always' || onlineManager.isOnline()) &&
    config.canRun()

const canStart = () => canFetch(config.networkMode) && config.canRun()

const resolve = (value: any) => {
    if (!isResolved) {
      isResolved = true
      config.onSuccess?.(value)
      continueFn?.()
      thenable.resolve(value)
    }
  }

const reject = (value: any) => {
    if (!isResolved) {
      isResolved = true
      config.onError?.(value)
      continueFn?.()
      thenable.reject(value)
    }
  }

const pause = () => {
    return new Promise((continueResolve) => {
      continueFn = (value) => {
        if (isResolved || canContinue()) {
          continueResolve(value)
        }
      }
      config.onPause?.()
    }).then(() => {
      continueFn = undefined
      if (!isResolved) {
        config.onContinue?.()
      }
    })
  }

// Create loop function
  const run = () => {
    // Do nothing if already resolved
    if (isResolved) {
      return
    }

let promiseOrValue: any

// we can re-use config.initialPromise on the first call of run()
    const initialPromise =
      failureCount === 0 ? config.initialPromise : undefined

// Execute query
    try {
      promiseOrValue = initialPromise ?? config.fn()
    } catch (error) {
      promiseOrValue = Promise.reject(error)
    }

Promise.resolve(promiseOrValue)
      .then(resolve)
      .catch((error) => {
        // Stop if the fetch is already resolved
        if (isResolved) {
          return
        }

// Do we need to retry the request?
        const retry = config.retry ?? (isServer ? 0 : 3)
        const retryDelay = config.retryDelay ?? defaultRetryDelay
        const delay =
          typeof retryDelay === 'function'
            ? retryDelay(failureCount, error)
            : retryDelay
        const shouldRetry =
          retry === true ||
          (typeof retry === 'number' && failureCount < retry) ||
          (typeof retry === 'function' && retry(failureCount, error))

if (isRetryCancelled || !shouldRetry) {
          // We are done if the query does not need to be retried
          reject(error)
          return
        }

failureCount++

// Notify on fail
        config.onFail?.(failureCount, error)

// Delay
        sleep(delay)
          // Pause if the document is not visible or when the device is offline
          .then(() => {
            return canContinue() ? undefined : pause()
          })
          .then(() => {
            if (isRetryCancelled) {
              reject(error)
            } else {
              run()
            }
          })
      })
  }

return {
    promise: thenable,
    cancel,
    continue: () => {
      continueFn?.()
      return thenable
    },
    cancelRetry,
    continueRetry,
    canStart,
    start: () => {
      // Start loop
      if (canStart()) {
        run()
      } else {
        pause().then(run)
      }
      return thenable
    },
  }
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Directory Contents

Dirs: 0 × Files: 22

Sort:

Enable drag-to-move

Name	Size	Perms	Modified	Actions
focusManager.ts	2.06 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
hydration.ts	8.08 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
index.ts	1.52 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
infiniteQueryBehavior.ts	5.27 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
infiniteQueryObserver.ts	4.69 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
mutation.ts	8.98 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
mutationCache.ts	6.86 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
mutationObserver.ts	4.76 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
notifyManager.ts	2.36 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
onlineManager.ts	1.77 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
queriesObserver.ts	7.54 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
query.ts	18.48 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
queryCache.ts	5.55 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
queryClient.ts	16.36 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
queryObserver.ts	22.87 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
removable.ts	851 B	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
retryer.ts	5.50 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
streamedQuery.ts	2.71 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
subscribable.ts	557 B	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
thenable.ts	2.87 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
types.ts	38.76 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
utils.ts	11.10 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive