Open API

import os, time, requests

BASE = "https://cambooth.e2app.co/api/open/v1"
s = requests.Session()
s.headers["X-Api-Key"] = os.environ.get("ECB_API_KEY", "ecbk_your_key_here")

def get(path, params=None):
    while True:
        r = s.get(f"{BASE}/{path}", params=params, timeout=30)
        if r.status_code == 429:                    # rate limited
            time.sleep(int(r.headers.get("Retry-After", "5")))
            continue
        env = r.json()                              # { "status": …, "data"/"error": … }
        if env.get("status") != "ok":
            e = env.get("error", {})
            raise RuntimeError(f"{e.get('code')}: {e.get('message')} (errorId={e.get('errorId')})")
        return env["data"]                          # unwrap the envelope

# Page through every uploaded clip with the cursor (recommended for sync).
cursor = None
while True:
    params = {"status": "uploaded", "pageSize": 100}
    if cursor:
        params["after"] = cursor
    page = get("clips", params)
    for c in page["items"]:
        pass  # use c["videoId"], c["barcode"], c["source"], …
    cursor = page.get("nextCursor")
    if not cursor:
        break

<?php
const BASE = 'https://cambooth.e2app.co/api/open/v1';
$key = getenv('ECB_API_KEY') ?: 'ecbk_your_key_here';

// GET with automatic 429 (Retry-After) back-off.
function api_get(string $key, string $path, array $q = []): mixed {
    $url = BASE . '/' . $path . ($q ? '?' . http_build_query($q) : '');
    while (true) {
        $ch = curl_init($url);
        curl_setopt_array($ch, [CURLOPT_RETURNTRANSFER => true, CURLOPT_HEADER => true,
            CURLOPT_HTTPHEADER => ['X-Api-Key: ' . $key]]);
        $resp = curl_exec($ch);
        $code = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
        $hs   = curl_getinfo($ch, CURLINFO_HEADER_SIZE);
        curl_close($ch);
        if ($code === 429) {                        // rate limited
            preg_match('/^retry-after:\s*(\d+)/im', substr($resp, 0, $hs), $m);
            sleep((int)($m[1] ?? 5));
            continue;
        }
        $env = json_decode(substr($resp, $hs), true);
        if (($env['status'] ?? '') !== 'ok')
            throw new RuntimeException(($env['error']['code'] ?? 'error') . ': ' . ($env['error']['message'] ?? ''));
        return $env['data'];                        // unwrap the envelope
    }
}

// Page through every uploaded clip with the cursor (recommended for sync).
$cursor = null;
do {
    $q = ['status' => 'uploaded', 'pageSize' => 100];
    if ($cursor) $q['after'] = $cursor;
    $page = api_get($key, 'clips', $q);
    foreach ($page['items'] as $c) { /* use $c['videoId'], $c['barcode'] … */ }
    $cursor = $page['nextCursor'] ?? null;
} while ($cursor);

// Cargo.toml: reqwest = { version = "0.12", features = ["blocking", "json"] }
//             serde   = { version = "1", features = ["derive"] }
use serde::Deserialize;
use std::{thread, time::Duration};

const BASE: &str = "https://cambooth.e2app.co/api/open/v1";

#[derive(Deserialize)]
struct Env<T> { status: String, data: Option<T> }   // (error fields omitted here)

#[derive(Deserialize)]
#[serde(rename_all = "camelCase")]
struct Clip { video_id: i64, barcode: Option<String>, source: Option<String> }

#[derive(Deserialize)]
#[serde(rename_all = "camelCase")]
struct ClipPage { items: Vec<Clip>, next_cursor: Option<String> }

// GET, unwrap the { status, data } envelope, with 429 (Retry-After) back-off.
fn get(c: &reqwest::blocking::Client, key: &str, path: &str, q: &[(&str, String)])
    -> Result<ClipPage, Box<dyn std::error::Error>> {
    loop {
        let r = c.get(format!("{BASE}/{path}")).header("X-Api-Key", key).query(q).send()?;
        if r.status().as_u16() == 429 {
            let w = r.headers().get("retry-after").and_then(|v| v.to_str().ok())
                .and_then(|s| s.parse().ok()).unwrap_or(5);
            thread::sleep(Duration::from_secs(w));
            continue;
        }
        let env: Env<ClipPage> = r.error_for_status()?.json()?;
        return env.data.ok_or_else(|| format!("status={}", env.status).into());
    }
}

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let key = std::env::var("ECB_API_KEY").unwrap_or("ecbk_your_key_here".into());
    let c = reqwest::blocking::Client::new();
    let mut cursor: Option<String> = None;
    loop {
        let mut q = vec![("status", "uploaded".into()), ("pageSize", "100".into())];
        if let Some(cur) = &cursor { q.push(("after", cur.clone())); }
        let page = get(&c, &key, "clips", &q)?;
        // for clip in &page.items { /* use clip.video_id, clip.barcode … */ }
        match page.next_cursor { Some(n) => cursor = Some(n), None => break }
    }
    Ok(())
}