Function invokeWithRetry

src/lib/invoke-with-retry.ts:36–66

(
  fn: string,
  body: Record<string, unknown> | undefined,
  { retries = 3, baseDelayMs = 800, isEmpty, signal }: RetryOptions = {}
)

 * Returns the final data (may still be a fallback after all retries exhausted).
 */
export async function invokeWithRetry<T = any>(
  fn: string,
  body: Record<string, unknown> | undefined,
  { retries = 3, baseDelayMs = 800, isEmpty, signal }: RetryOptions = {}
): Promise<T | null> {
  let lastData: T | null = null;
  for (let attempt = 0; attempt <= retries; attempt++) {
    if (signal?.aborted) return lastData;
    try {
      const { data, error } = await supabase.functions.invoke(fn, { body });
      if (error) throw error;
      lastData = data as T;
      const empty = isFallbackPayload(data) || (isEmpty ? isEmpty(data) : false);
      if (!empty) return lastData;
      // else fall through to retry
    } catch (e) {
      // swallow & retry
      // eslint-disable-next-line no-console
      console.warn(`[invokeWithRetry] ${fn} attempt ${attempt + 1} failed`, e);
    }
    if (attempt < retries) {
      const delay = baseDelayMs * Math.pow(2, attempt) + Math.floor(Math.random() * 400);
      try {
        await sleep(delay);
      } catch {
        return lastData;
      }
    }
  }
  return lastData;
}