Function retryHttpJson

scripts/integration/cli.mjs:1845–1865

(method, requestPath, body, label, options = {})

}

async function retryHttpJson(method, requestPath, body, label, options = {}) {
  const attempts = options.attempts ?? 3;
  const delayMs = options.delayMs ?? 2_000;
  let lastError;
  for (let attempt = 1; attempt <= attempts; attempt += 1) {
    try {
      return await httpJson(method, requestPath, body, {
        maxElapsedMs: options.maxElapsedMs ?? httpActionBudgetMs,
      });
    } catch (error) {
      lastError = error;
      if (attempt === attempts) {
        break;
      }
      await sleep(delayMs);
    }
  }
  throw new Error(
    `${label} failed after ${attempts} attempts: ${lastError?.message ?? lastError}`,
  );
}

function httpBuffer(method, requestPath, body, options = {}) {
  const payload = body === undefined ? null : Buffer.from(JSON.stringify(body));