Bulk Content Generation

MAX_RETRIES=5

submit_batch() {
  local api_key="$1"
  local batch_file="$2"
  local retries=0
  local backoff=5

  while [ "$retries" -le "$MAX_RETRIES" ]; do
    HTTP_CODE=$(curl -s -o response.json -w "%{http_code}" \
      -D headers.txt \
      -X POST "https://api.app.hrizn.io/v1/public/content/batch" \
      -H "X-API-Key: $api_key" \
      -H "Content-Type: application/json" \
      -d @"$batch_file")

    if [ "$HTTP_CODE" -eq 202 ]; then
      echo "OK: $batch_file"
      return 0
    elif [ "$HTTP_CODE" -eq 429 ]; then
      retries=$((retries + 1))
      retry_after=$(grep -i 'retry-after' headers.txt | tr -d '\r' | awk '{print $2}')
      wait_time=${retry_after:-$backoff}
      echo "Rate limited on $batch_file — waiting ${wait_time}s (retry $retries/$MAX_RETRIES)"
      sleep "$wait_time"
      backoff=$((backoff * 2))
    else
      echo "Failed $HTTP_CODE: $batch_file"
      return 1
    fi
  done

  echo "Gave up after $MAX_RETRIES retries: $batch_file"
  return 1
}

import requests
import time
import json
from pathlib import Path

def submit_batch(api_key: str, batch_path: str, max_retries: int = 5) -> bool:
    url = "https://api.app.hrizn.io/v1/public/content/batch"
    headers = {"X-API-Key": api_key, "Content-Type": "application/json"}
    payload = json.loads(Path(batch_path).read_text())

    backoff = 5
    for attempt in range(max_retries + 1):
        resp = requests.post(url, json=payload, headers=headers)

        if resp.status_code == 202:
            print(f"OK: {batch_path}")
            return True
        elif resp.status_code == 429:
            wait = int(resp.headers.get("Retry-After", backoff))
            print(f"Rate limited on {batch_path} — waiting {wait}s (retry {attempt + 1}/{max_retries})")
            time.sleep(wait)
            backoff *= 2
        else:
            print(f"Failed {resp.status_code}: {batch_path}")
            return False

    print(f"Gave up after {max_retries} retries: {batch_path}")
    return False

async function submitBatch(apiKey, batchPayload, maxRetries = 5) {
  let backoff = 5000;

  for (let attempt = 0; attempt <= maxRetries; attempt++) {
    const response = await fetch('https://api.app.hrizn.io/v1/public/content/batch', {
      method: 'POST',
      headers: { 'X-API-Key': apiKey, 'Content-Type': 'application/json' },
      body: JSON.stringify(batchPayload),
    });

    if (response.status === 202) return await response.json();

    if (response.status === 429) {
      const retryAfter = parseInt(response.headers.get('Retry-After') || '5') * 1000;
      const wait = Math.max(retryAfter, backoff);
      console.log(`Rate limited — waiting ${wait / 1000}s (retry ${attempt + 1}/${maxRetries})`);
      await new Promise(r => setTimeout(r, wait));
      backoff *= 2;
      continue;
    }

    throw new Error(`Request failed with status ${response.status}`);
  }

  throw new Error('Max retries exceeded');
}