Function retryWithFixedDelay

ai/ai.ts:1031–1051

(
  operation: () => Promise<T>,
  maxRetries: number = 2,
  delayMs: number = 1000,
  token?: AbortToken,
)

const retryWithFixedDelay = async <T>(
  operation: () => Promise<T>,
  maxRetries: number = 2,
  delayMs: number = 1000,
  token?: AbortToken,
): Promise<T> => {
  let lastError: any;
  for (let i = 0; i < maxRetries; i++) {
    token?.throwIfAborted();
    try {
      return await operation();
    } catch (error: any) {
      lastError = error;
      if (token?.aborted) throw error;
      if (!isRetryableError(error)) throw error;
      if (i === maxRetries - 1) break;
      await sleep(delayMs, token);
    }
  }
  throw lastError;
};

const isRetryableError = (error: any): boolean => {
  if (!error) return false;
  if (error.name === "AbortError") return false;