Video generation

import base64, os, time, requests

BASE = "https://api.flex.ai/v1"
H = {"Authorization": f"Bearer {os.environ['FLEXAI_API_KEY']}"}

# 1. Submit. Returns 202 and a job ID.
resp = requests.post(f"{BASE}/videos/generations", headers=H, json={
    "model": "MiniMax-H3",
    "prompt": "A San Francisco cable car climbs a hill at golden hour, its bell clanging.",
})
resp.raise_for_status()
job = resp.json()

# 2. Poll until the job completes or fails.
while True:
    poll = requests.get(f"{BASE}/videos/generations/{job['id']}", headers=H)
    poll.raise_for_status()  # error responses carry no `status`
    r = poll.json()
    if r["status"] in ("completed", "failed"):
        break
    time.sleep(10)

# 3. The completed response carries the clip. It is served once, so save it now.
if r["status"] == "failed":
    raise RuntimeError(r["error"])
with open("clip.mp4", "wb") as f:
    f.write(base64.b64decode(r["data"][0]["b64_json"]))

JOB=$(curl -sf https://api.flex.ai/v1/videos/generations \
  -H "Authorization: Bearer $FLEXAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"model": "MiniMax-H3", "prompt": "A San Francisco cable car climbs a hill at golden hour, its bell clanging."}' \
  | jq -r .id)
[ -n "$JOB" ] || { echo "Submit failed"; exit 1; }

# Keep each poll response: the completed one carries the clip, and it is served once.
# With -f, curl writes no file on an HTTP error, so stop rather than re-read a stale one.
while true; do
  curl -sf https://api.flex.ai/v1/videos/generations/$JOB \
    -H "Authorization: Bearer $FLEXAI_API_KEY" -o job.json \
    || { echo "Poll failed (HTTP error)"; exit 1; }
  STATUS=$(jq -r .status job.json)
  [ "$STATUS" = "completed" ] && break
  [ "$STATUS" = "failed" ] && { jq .error job.json; exit 1; }
  sleep 10
done

jq -r '.data[0].b64_json' job.json | base64 -d > clip.mp4

import { writeFileSync } from "node:fs";

const BASE = "https://api.flex.ai/v1";
const H = { Authorization: `Bearer ${process.env.FLEXAI_API_KEY}` };

const submit = await fetch(`${BASE}/videos/generations`, {
  method: "POST",
  headers: { ...H, "Content-Type": "application/json" },
  body: JSON.stringify({
    model: "MiniMax-H3",
    prompt: "A San Francisco cable car climbs a hill at golden hour, its bell clanging.",
  }),
});
if (!submit.ok) throw new Error(`Submit failed: ${submit.status} ${await submit.text()}`);
const { id } = await submit.json();

// The completed response carries the clip, and it is served once.
let job;
while (true) {
  const poll = await fetch(`${BASE}/videos/generations/${id}`, { headers: H });
  if (!poll.ok) throw new Error(`Poll failed: ${poll.status} ${await poll.text()}`); // error bodies carry no status
  job = await poll.json();
  if (job.status === "completed" || job.status === "failed") break;
  await new Promise((r) => setTimeout(r, 10_000));
}
if (job.status === "failed") throw new Error(JSON.stringify(job.error));
writeFileSync("clip.mp4", Buffer.from(job.data[0].b64_json, "base64"));