Bulk metadata for large ID lists

const base = process.env.EPOCHAL_API_BASE ?? "https://epochalstock.com/api/v1";
const ids = ["es_001_example", "es_002_example"];

const response = await fetch(`${base}/images/batch`, {
  method: "POST",
  headers: {
    Authorization: `Bearer ${process.env.EPOCHAL_API_KEY}`,
    "Content-Type": "application/json",
    Accept: "application/json",
  },
  body: JSON.stringify({ ids }),
});

if (!response.ok) throw new Error(await response.text());
const { data } = await response.json();
console.log(`found ${data.found} of ${data.requested}`);

const foundIds = new Set(data.images.map((img) => img.id));
const missing = ids.filter((id) => !foundIds.has(id));
if (missing.length) console.warn("missing", missing);

$base = rtrim(getenv('EPOCHAL_API_BASE') ?: 'https://epochalstock.com/api/v1', '/');
$ids = ['es_001_example', 'es_002_example'];

$ch = curl_init($base . '/images/batch');
curl_setopt_array($ch, [
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_POST => true,
    CURLOPT_HTTPHEADER => [
        'Authorization: Bearer ' . getenv('EPOCHAL_API_KEY'),
        'Content-Type: application/json',
        'Accept: application/json',
    ],
    CURLOPT_POSTFIELDS => json_encode(['ids' => $ids], JSON_THROW_ON_ERROR),
    CURLOPT_TIMEOUT => 20,
]);
$response = curl_exec($ch);
$status = (int) curl_getinfo($ch, CURLINFO_HTTP_CODE);
curl_close($ch);

if ($status !== 200) {
    throw new RuntimeException((string) $response);
}

$data = json_decode($response, true, 512, JSON_THROW_ON_ERROR)['data'];
// $data['images'], $data['requested'], $data['found']
$foundIds = array_column($data['images'], 'id');
$missing = array_values(array_diff($ids, $foundIds));

import os
import requests

base = os.environ.get("EPOCHAL_API_BASE", "https://epochalstock.com/api/v1")
ids = ["es_001_example", "es_002_example"]

r = requests.post(
    f"{base}/images/batch",
    json={"ids": ids},
    headers={
        "Authorization": f"Bearer {os.environ['EPOCHAL_API_KEY']}",
        "Accept": "application/json",
    },
    timeout=20,
)
r.raise_for_status()
data = r.json()["data"]
print(f"found {data['found']} of {data['requested']}")
found_ids = {img["id"] for img in data["images"]}
missing = [i for i in ids if i not in found_ids]

function batch_once(string $base, array $ids): array
{
    $ch = curl_init(rtrim($base, '/') . '/images/batch');
    curl_setopt_array($ch, [
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_POST => true,
        CURLOPT_HTTPHEADER => [
            'Authorization: Bearer ' . getenv('EPOCHAL_API_KEY'),
            'Content-Type: application/json',
            'Accept: application/json',
        ],
        CURLOPT_POSTFIELDS => json_encode(['ids' => array_values($ids)], JSON_THROW_ON_ERROR),
        CURLOPT_TIMEOUT => 20,
        CURLOPT_HEADER => true,
    ]);
    $raw = curl_exec($ch);
    $status = (int) curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $headerSize = (int) curl_getinfo($ch, CURLINFO_HEADER_SIZE);
    curl_close($ch);

    $headers = substr((string) $raw, 0, $headerSize);
    $body = substr((string) $raw, $headerSize);

    if ($status === 429) {
        $retry = 2;
        if (preg_match('/^Retry-After:\s*(\d+)/mi', $headers, $m)) {
            $retry = max(1, (int) $m[1]);
        }
        sleep($retry);
        return batch_once($base, $ids);
    }
    if ($status !== 200) {
        throw new RuntimeException($body);
    }
    return json_decode($body, true, 512, JSON_THROW_ON_ERROR)['data'];
}

function rehydrate_all(array $allIds): array
{
    $base = getenv('EPOCHAL_API_BASE') ?: 'https://epochalstock.com/api/v1';
    $unique = array_values(array_unique($allIds));
    $images = [];
    $requested = 0;
    $found = 0;

    foreach (array_chunk($unique, 100) as $chunk) {
        $data = batch_once($base, $chunk);
        $images = array_merge($images, $data['images']);
        $requested += (int) $data['requested'];
        $found += (int) $data['found'];
    }

    $foundIds = array_column($images, 'id');
    $missing = array_values(array_diff($unique, $foundIds));
    return compact('images', 'requested', 'found', 'missing');
}

import os
import time
import requests

base = os.environ.get("EPOCHAL_API_BASE", "https://epochalstock.com/api/v1")
headers = {
    "Authorization": f"Bearer {os.environ['EPOCHAL_API_KEY']}",
    "Accept": "application/json",
}

def batch_once(ids):
    while True:
        r = requests.post(
            f"{base}/images/batch",
            json={"ids": ids},
            headers=headers,
            timeout=20,
        )
        if r.status_code == 429:
            time.sleep(int(r.headers.get("Retry-After", "2")))
            continue
        r.raise_for_status()
        return r.json()["data"]

def rehydrate_all(all_ids):
    unique = list(dict.fromkeys(all_ids))  # preserve order, dedupe
    images = []
    requested = found = 0
    for i in range(0, len(unique), 100):
        chunk = unique[i : i + 100]
        data = batch_once(chunk)
        images.extend(data["images"])
        requested += data["requested"]
        found += data["found"]
    found_ids = {img["id"] for img in images}
    missing = [i for i in unique if i not in found_ids]
    return {
        "images": images,
        "requested": requested,
        "found": found,
        "missing": missing,
    }

# Chunk manually when scripting large lists (example: first 100)
curl -sS -X POST "https://epochalstock.com/api/v1/images/batch" \
  -H "Authorization: Bearer $EPOCHAL_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Accept: application/json" \
  -d @chunk-001.json
# chunk-001.json → {"ids":["es_…", … up to 100]}