Image

JOB=$(curl -s https://api.albastov.com/v1/media/jobs \
  -H "Authorization: Bearer $ALBASTAR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"kind": "image", "model": "zimage-turbo",
       "params": {"prompt": "A lighthouse on a basalt cliff at dusk",
                  "aspect": "16:9", "seed": 42}}' \
  | python3 -c 'import json, sys; print(json.load(sys.stdin)["id"])')

until curl -s "https://api.albastov.com/v1/media/jobs/$JOB?wait=60" \
  -H "Authorization: Bearer $ALBASTAR_API_KEY" -o job.json \
  -w '%{http_code}' | grep -q 200; do :; done
cat job.json

import json
import os
import urllib.request

BASE = "https://api.albastov.com/v1"
HEADERS = {
    "User-Agent": "my-app/1.0",
    "Authorization": f"Bearer {os.environ['ALBASTAR_API_KEY']}",
    "Content-Type": "application/json",
}


def call(path, body=None):
    data = json.dumps(body).encode() if body is not None else None
    req = urllib.request.Request(BASE + path, data=data, headers=HEADERS)
    with urllib.request.urlopen(req, timeout=120) as res:
        return json.load(res)


job = call("/media/jobs", {
    "kind": "image",
    "model": "zimage-turbo",
    "params": {
        "prompt": "A lighthouse on a basalt cliff at dusk",
        "aspect": "16:9",
        "seed": 42,
    },
})
while job["state"] in ("queued", "waiting_device", "running"):
    job = call(f"/media/jobs/{job['id']}?wait=60")
print(job["state"], [r["url"] for r in job["results"]])

const base = "https://api.albastov.com/v1";
const headers = {
  Authorization: `Bearer ${process.env.ALBASTAR_API_KEY}`,
  "Content-Type": "application/json",
};

async function call(path, body) {
  const res = await fetch(base + path, {
    method: body ? "POST" : "GET",
    headers,
    body: body ? JSON.stringify(body) : undefined,
  });
  if (!res.ok) throw new Error(`${res.status} ${await res.text()}`);
  return res.json();
}

let job = await call("/media/jobs", {
  kind: "image",
  model: "zimage-turbo",
  params: {
    prompt: "A lighthouse on a basalt cliff at dusk",
    aspect: "16:9",
    seed: 42,
  },
});
while (["queued", "waiting_device", "running"].includes(job.state)) {
  job = await call(`/media/jobs/${job.id}?wait=60`);
}
console.log(job.state, job.results.map((r) => r.url));