Errors and rate limits

async function send(payload) {
  const res = await fetch(
    "https://api.senderz.app/api/v1/public/messages/email",
    {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
        "X-Sender-Tenant": process.env.SENDERZ_WORKSPACE,
        "X-API-Key": process.env.SENDERZ_API_KEY,
      },
      body: JSON.stringify(payload),
    },
  );

  const body = await res.json();
  if (body.success) return body.data;

  switch (body.code) {
    case "sender_inbox_not_verified":
    case "from_domain_not_verified":
      throw new Error(`Fix the sending identity: ${body.message}`);
    case "contact_email_taken":
      return null; // already on file, nothing to do
    default:
      if (res.status === 429) throw new RetryableError(res.headers.get("Retry-After"));
      if (res.status >= 500) throw new RetryableError(null);
      throw new Error(
        `${res.status} ${body.message} (request ${res.headers.get("X-Request-Id")})`,
      );
  }
}

import requests

RETRYABLE_STATUSES = {429, 500, 502, 503, 504}

def send(payload):
    res = requests.post(
        "https://api.senderz.app/api/v1/public/messages/email",
        headers={
            "X-Sender-Tenant": WORKSPACE,
            "X-API-Key": API_KEY,
        },
        json=payload,
    )
    body = res.json()
    if body.get("success"):
        return body["data"]

    code = body.get("code")
    if code in ("from_domain_not_verified", "sender_inbox_not_verified"):
        raise SendingIdentityError(body["message"])
    if code == "contact_email_taken":
        return None
    if res.status_code in RETRYABLE_STATUSES:
        raise Retryable(res.headers.get("Retry-After"))

    raise RuntimeError(
        f"{res.status_code} {body['message']} "
        f"(request {res.headers.get('X-Request-Id')})"
    )