CyberStock API

X-API-Key: cs_live_YOUR_API_KEY_HERE

curl "$CYBERSTOCK_API_BASE/v1/account" \
  -H "X-API-Key: cs_live_YOUR_KEY"

{
  "ok": true,
  "account": {
    "email": "user@example.com",
    "plan": "pro",
    "api_access": true,
    "api_tier": "pro",
    "credits": 742,
    "credits_subscription": 500,
    "credits_topup": 242,
    "is_unlimited": false
  }
}

curl "$CYBERSTOCK_API_BASE/v1/sessions?limit=100&offset=0" \
  -H "X-API-Key: cs_live_YOUR_KEY"

# First page (default limit=100, max=2000)
curl "$CYBERSTOCK_API_BASE/v1/sessions/<SESSION_ID>?limit=1000&offset=0" \
  -H "X-API-Key: cs_live_YOUR_KEY"

# Loop until pagination.has_more === false
curl "$CYBERSTOCK_API_BASE/v1/sessions/<SESSION_ID>?limit=1000&offset=1000" \
  -H "X-API-Key: cs_live_YOUR_KEY"

{
  "ok": true,
  "session": { "id": "...", "status": "completed", "total_images": 10219 },
  "pagination": {
    "total": 10219,
    "offset": 0,
    "limit": 1000,
    "returned": 1000,
    "has_more": true,
    "next_offset": 1000
  },
  "results": [ /* 1000 items */ ]
}

curl -X POST "$CYBERSTOCK_API_BASE/v1/batches" \
  -H "X-API-Key: cs_live_YOUR_KEY" \
  -H "Content-Type: application/json" \
  -d '{ "name": "Shoot 2026-09-27" }'

{
  "ok": true,
  "batch_id": "6f1c…",
  "sftp": {
    "host": "<sftp host>",
    "port": 2022,
    "protocol": "sftp",
    "username": "cb_vqenvKAO0Cc",
    "password": "shown once — store it now",
    "remote_dir": "/"
  },
  "sftp_access_expires_at": "2026-09-30T10:00:00Z",
  "min_files": 1000,
  "next": "Upload your files over SFTP, then POST /v1/batches/6f1c…/start"
}

curl -X POST "$CYBERSTOCK_API_BASE/v1/batches/<BATCH_ID>/start" \
  -H "X-API-Key: cs_live_YOUR_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "language": "en",
    "keyword_count": 50,
    "platform": "adobe"
  }'

{
  "ok": true,
  "batch": {
    "batch_id": "6f1c…",
    "job_id": "a93e…",
    "status": "running",
    "name": "Shoot 2026-09-27",
    "sftp_username": "cb_vqenvKAO0Cc",
    "files": { "registered": 12000, "processed": 8200, "failed": 0,
               "queued": 3800, "processing": 0, "awaiting_preview": 0 },
    "billing": {
      "discount_pct": 15,
      "files_from_allowance": 2000,
      "files_on_credits": 10000,
      "files_on_fair_use_slow_lane": 0,
      "credits_charged": 8500,
      "credits_refunded": 0
    },
    "started_at": "2026-09-27T10:12:00Z",
    "completed_at": null,
    "results_path": "/v1/sessions/6f1c…"
  }
}

curl "$CYBERSTOCK_API_BASE/v1/batches?sftp_username=cb_vqenvKAO0Cc" \
  -H "X-API-Key: cs_live_YOUR_KEY"

POST https://your-server.example.com/cyberstock
Content-Type: application/json
CyberStock-Event: batch.completed
CyberStock-Delivery: 2b7d…            (stable across retries: dedupe on it)
CyberStock-Signature: t=1790000000,v1=5f2a…

{
  "id": "2b7d…",
  "type": "batch.completed",
  "created": "2026-09-27T14:03:11Z",
  "data": {
    "session_id": "6f1c…",
    "job_id": "a93e…",
    "status": "ready",
    "total_files": 12000,
    "processed_files": 12000,
    "failed_files": 0,
    "sftp_username": "cb_vqenvKAO0Cc",
    "session_url": "https://cyberstock.lol/sessions/6f1c…/review-edit",
    "results_path": "/v1/sessions/6f1c…"
  }
}

import hashlib, hmac

def verify(raw_body: bytes, signature_header: str, secret: str) -> bool:
    parts = dict(p.split("=", 1) for p in signature_header.split(","))
    signed = f"{parts['t']}.".encode() + raw_body
    expected = hmac.new(secret.encode(), signed, hashlib.sha256).hexdigest()
    return hmac.compare_digest(expected, parts["v1"])

"fair_use": {
  "state": "approaching",
  "message": "You are approaching the fair-use threshold of your plan. To keep full speed, credit packs are available.",
  "buy_credits_url": "https://cyberstock.lol/pricing"
}

"""Full CyberBatch automation: create -> SFTP upload -> start -> wait -> results."""
import os, time, requests, paramiko

API = os.environ["CYBERSTOCK_API_BASE"]
H = {"X-API-Key": os.environ["CYBERSTOCK_API_KEY"]}
FOLDER = "/path/to/images"           # 1 000+ JPG / PNG / TIFF / MP4 files

# 1. Create a batch. The SFTP password is returned once.
b = requests.post(f"{API}/v1/batches", json={"name": "Nightly upload"}, headers=H).json()
batch_id, s = b["batch_id"], b["sftp"]

# 2. Upload over SFTP.
t = paramiko.Transport((s["host"], s["port"]))
t.connect(username=s["username"], password=s["password"])
sftp = paramiko.SFTPClient.from_transport(t)
for name in os.listdir(FOLDER):
    sftp.put(os.path.join(FOLDER, name), f"{s['remote_dir'].rstrip('/')}/{name}")
sftp.close(); t.close()

# 3. Start with the same settings you would send to /v1/process.
r = requests.post(f"{API}/v1/batches/{batch_id}/start",
                  json={"language": "en", "keyword_count": 50}, headers=H)
if r.status_code == 400 and r.json()["error"] == "BATCH_TOO_SMALL":
    raise SystemExit(r.json()["message"])   # fewer than 1 000 files registered
r.raise_for_status()

# 4. Wait. With a webhook configured you can skip this loop entirely and
#    fetch results when batch.completed arrives.
while True:
    st = requests.get(f"{API}/v1/batches/{batch_id}", headers=H).json()["batch"]
    if st["status"] in ("ready", "partial", "failed", "canceled"):
        break
    time.sleep(300)

# 5. Results, paginated.
offset, results = 0, []
while True:
    page = requests.get(f"{API}/v1/sessions/{batch_id}",
                        params={"limit": 1000, "offset": offset}, headers=H).json()
    results += page["results"]
    if not page["pagination"]["has_more"]:
        break
    offset = page["pagination"]["next_offset"]
print(len(results), "files keyworded")