Rate limits

BASE=https://phosra-api-sandbox-production.up.railway.app
# Dump headers + status for one request
HDRS=$(curl -s -D - -o /dev/null -w "HTTP_CODE:%{http_code}" \
  -H "Authorization: Bearer $PHOSRA_API_KEY" \
  "$BASE/api/v1/families")

if echo "$HDRS" | grep -q "HTTP_CODE:429"; then
  RESET=$(echo "$HDRS" | tr -d '\r' | awk 'tolower($1)=="x-ratelimit-reset:"{print $2}')
  WAIT=$(( RESET - $(date +%s) )); [ "$WAIT" -lt 1 ] && WAIT=1
  sleep "$WAIT"
  # ...then retry the request once
fi

async function withRateLimit<T>(call: () => Promise<Response>): Promise<Response> {
  let res = await call();
  if (res.status === 429) {
    // Prefer Retry-After (seconds); fall back to the absolute reset.
    const retryAfter = Number(res.headers.get("retry-after"));
    const reset = Number(res.headers.get("x-ratelimit-reset"));
    const waitMs = Number.isFinite(retryAfter) && retryAfter > 0
      ? retryAfter * 1000
      : Math.max(0, reset * 1000 - Date.now());
    await new Promise((r) => setTimeout(r, waitMs));
    res = await call(); // retry exactly once
  }
  return res;
}

import time, requests

def with_rate_limit(request_fn):
    res = request_fn()
    if res.status_code == 429:
        retry_after = res.headers.get("retry-after")
        if retry_after and retry_after.isdigit():
            wait = int(retry_after)
        else:
            reset = int(res.headers.get("x-ratelimit-reset", "0"))
            wait = max(0, reset - int(time.time()))
        time.sleep(wait)
        res = request_fn()  # retry exactly once
    return res

func withRateLimit(do func() (*http.Response, error)) (*http.Response, error) {
	res, err := do()
	if err != nil {
		return nil, err
	}
	if res.StatusCode == http.StatusTooManyRequests {
		wait := time.Duration(0)
		if ra, err := strconv.Atoi(res.Header.Get("Retry-After")); err == nil {
			wait = time.Duration(ra) * time.Second
		} else if reset, err := strconv.ParseInt(res.Header.Get("X-RateLimit-Reset"), 10, 64); err == nil {
			if d := time.Until(time.Unix(reset, 0)); d > 0 {
				wait = d
			}
		}
		time.Sleep(wait)
		return do() // retry exactly once
	}
	return res, nil
}