BASE=https://api.nunchux.ai

# 1. Submit
SUBMIT=$(curl -sS --fail-with-body "$BASE/v1/google/v1beta/models/veo-3.1-generate-preview:predictLongRunning" \
  -H "X-API-Key: $NUNCHUX_API_KEY" \
  -H "Content-Type: application/json" \
  -H "User-Agent: YourApp/1.0" \
  -d '{
    "instances": [{ "prompt": "a fox trotting through a snowy forest at dawn" }],
    "parameters": { "resolution": "1080p", "durationSeconds": 8 }
  }') || { echo "submit failed: $SUBMIT" >&2; exit 1; }
OP=$(jq -er '.name' <<<"$SUBMIT") || { echo "no operation name in: $SUBMIT" >&2; exit 1; }

# 2. Poll until done is true
DELAY=5
for _ in $(seq 1 60); do
  RESP=$(curl -sS "$BASE/v1/google/v1beta/operations/$OP" \
    -H "X-API-Key: $NUNCHUX_API_KEY" \
    -H "User-Agent: YourApp/1.0")
  [ "$(jq -r '.done // false' <<<"$RESP")" = "true" ] && break
  sleep "$DELAY"; DELAY=$(( DELAY * 2 > 30 ? 30 : DELAY * 2 ))
done
[ "$(jq -r '.done // false' <<<"$RESP")" = "true" ] || { echo "timed out" >&2; exit 1; }

# 3. Check for failure. done is true on failure too.
jq -e '.error' >/dev/null 2>&1 <<<"$RESP" && { echo "failed: $(jq -c '.error' <<<"$RESP")" >&2; exit 1; }

# 4. Download. The URL expires about an hour after completion.
curl -sSL -o veo.mp4 "$(jq -r '.response.generateVideoResponse.generatedSamples[0].video.uri' <<<"$RESP")"

# pip install requests
import os, time, requests

BASE = "https://api.nunchux.ai"
HEADERS = {
    "X-API-Key": os.environ["NUNCHUX_API_KEY"],
    "User-Agent": "YourApp/1.0",
}

# 1. Submit
model = "veo-3.1-generate-preview"
submit = requests.post(
    f"{BASE}/v1/google/v1beta/models/{model}:predictLongRunning",
    headers=HEADERS,
    json={
        "instances": [{"prompt": "a fox trotting through a snowy forest at dawn"}],
        "parameters": {"resolution": "1080p", "durationSeconds": 8},
    },
)
if not submit.ok:
    raise RuntimeError(f"submit failed: HTTP {submit.status_code} {submit.text}")
op = submit.json()["name"]

# 2. Poll until done is true
delay = 5
for _ in range(60):
    data = requests.get(f"{BASE}/v1/google/v1beta/operations/{op}", headers=HEADERS).json()
    if data.get("done"):
        break
    time.sleep(delay)
    delay = min(delay * 2, 30)
else:
    raise TimeoutError("Veo operation did not finish")

# 3. Check for failure. done is true on failure too.
if "error" in data:
    raise RuntimeError(f"Veo failed: {data['error']}")

# 4. Download. The URL expires about an hour after completion.
url = data["response"]["generateVideoResponse"]["generatedSamples"][0]["video"]["uri"]
with requests.get(url, stream=True, timeout=300) as r:
    r.raise_for_status()
    with open("veo.mp4", "wb") as f:
        for chunk in r.iter_content(1 << 14):
            f.write(chunk)

import { writeFile } from "node:fs/promises";

const BASE = "https://api.nunchux.ai";
const HEADERS = {
  "X-API-Key": process.env.NUNCHUX_API_KEY,
  "Content-Type": "application/json",
  "User-Agent": "YourApp/1.0",
};
const sleep = (ms) => new Promise((r) => setTimeout(r, ms));

// 1. Submit
const model = "veo-3.1-generate-preview";
const submitRes = await fetch(
  `${BASE}/v1/google/v1beta/models/${model}:predictLongRunning`,
  {
    method: "POST",
    headers: HEADERS,
    body: JSON.stringify({
      instances: [{ prompt: "a fox trotting through a snowy forest at dawn" }],
      parameters: { resolution: "1080p", durationSeconds: 8 },
    }),
  }
);
if (!submitRes.ok) throw new Error(`submit failed: HTTP ${submitRes.status} ${await submitRes.text()}`);
const op = (await submitRes.json()).name;

// 2. Poll until done is true
let data;
let delay = 5_000;
for (let i = 0; i < 60; i++) {
  data = await fetch(`${BASE}/v1/google/v1beta/operations/${op}`, {
    headers: HEADERS,
  }).then((r) => r.json());
  if (data.done) break;
  await sleep(delay);
  delay = Math.min(delay * 2, 30_000);
}
if (!data?.done) throw new Error("Veo operation did not finish");

// 3. Check for failure. done is true on failure too.
if (data.error) throw new Error(`Veo failed: ${JSON.stringify(data.error)}`);

// 4. Download. The URL expires about an hour after completion.
const uri = data.response.generateVideoResponse.generatedSamples[0].video.uri;
const res = await fetch(uri);
if (!res.ok) throw new Error(`download failed: HTTP ${res.status}`);
await writeFile("veo.mp4", Buffer.from(await res.arrayBuffer()));