Class BuyerRetryPolicy

Example

import { decideRetry, type RetryDecision } from '@adcp/sdk';

try {
  return await callAgent({ idempotency_key: key, ... });
} catch (e) {
  const error = extractAdcpError(e);
  const decision = decideRetry(error, { attempt });

  if (decision.action === 'retry') {
    await sleep(decision.delayMs);
    return callAgent({ idempotency_key: key, ... }); // SAME key
  }
  if (decision.action === 'mutate-and-retry') {
    // Apply correction (decision.field, decision.suggestion), fresh key.
    return callAgent({ idempotency_key: crypto.randomUUID(), ... });
  }
  throw new Error(`Escalate: ${decision.reason} — ${decision.message}`);
}
Copy