const result = await getOAuthApiKey(oauthProvider, oauthCreds);
if (!result) {
  return null;
}

const MAX_REFRESH_RETRIES = 3;
const RETRY_DELAY_MS = 1000;

async function withRetry<T>(
  fn: () => Promise<T>,
  retries: number = MAX_REFRESH_RETRIES,
  delayMs: number = RETRY_DELAY_MS,
): Promise<T> {
  for (let attempt = 1; attempt <= retries; attempt++) {
    try {
      return await fn();
    } catch (error) {
      if (attempt === retries) throw error;
      log.warn(\`OAuth refresh attempt ${attempt}/${retries} failed, retrying in ${delayMs}ms\`, {
        error: error instanceof Error ? error.message : String(error),
      });
      await new Promise((resolve) => setTimeout(resolve, delayMs * attempt));
    }
  }
  throw new Error("Unexpected: retry loop exited without return or throw");
}

return await withRetry(() => getOAuthApiKey(oauthProvider, oauthCreds));