Video API: создать задачу и сохранить job ID

import json
import os
import re
import time
import urllib.parse
import urllib.request
from pathlib import Path

key = os.environ["API429_API_KEY"]
base = "https://gateway.api429.com/v1"
headers = {"Authorization": "Bearer " + key, "Content-Type": "application/json"}
model = "gemini-omni-1.1-flash"
try:
    with urllib.request.urlopen(urllib.request.Request(base + "/models", headers=headers), timeout=30) as response:
        available = {item["id"] for item in json.load(response)["data"]}
except Exception:
    raise ValueError("Invalid models response; stop before generation") from None
if model not in available:
    raise ValueError("Model unavailable to this key")
payload = json.loads("{\"model\":\"gemini-omni-1.1-flash\",\"prompt\":\"A slow camera move around a blue ceramic cup on a table\",\"duration\":5,\"aspect_ratio\":\"16:9\",\"resolution\":\"720p\",\"n\":1}")
request = urllib.request.Request(base + "/videos/generations", data=json.dumps(payload).encode("utf-8"), headers=headers, method="POST")
# One paid POST only. On an ambiguous submit, investigate; do not rerun blindly.
try:
    with urllib.request.urlopen(request, timeout=60) as response:
        job = json.load(response)
        submit_status = response.status
except Exception:
    raise ValueError("Ambiguous submission; job ID unknown; inspect original attempt, no new POST") from None
job_id = job.get("id") if isinstance(job, dict) else None
if not isinstance(job_id, str) or not re.fullmatch(r"[A-Za-z0-9_-]{1,200}", job_id):
    raise ValueError("Unknown submission; investigate before any new POST")
Path("video-job.json").write_text(json.dumps({"id": job_id}), encoding="utf-8")
def stop(reason):
    raise RuntimeError(reason + "; job ID: " + job_id + "; inspect this job, no new POST") from None
if submit_status != 202 or job.get("object") != "video.generation.job" or job.get("status") != "queued":
    stop("Unknown submission shape")
url = base + "/videos/generations/" + urllib.parse.quote(job_id, safe="")
# Client policy: 12 reads, 5-second pause, 180-second deadline; no server timing guarantee.
deadline = time.monotonic() + 180
for attempt in range(12):
    remaining = deadline - time.monotonic()
    if remaining <= 0:
        stop("Client deadline")
    try:
        with urllib.request.urlopen(urllib.request.Request(url, headers=headers), timeout=min(30, remaining)) as response:
            output = json.load(response)
    except Exception:
        stop("Read failed")
    if time.monotonic() >= deadline:
        stop("Client deadline")
    if not isinstance(output, dict):
        stop("Malformed response")
    if output.get("object") == "video.generation":
        items = output.get("data")
        if output.get("model") != model or not isinstance(items, list) or len(items) != 1 or not isinstance(items[0], dict):
            stop("Malformed output")
        item = items[0]
        try:
            parsed = urllib.parse.urlsplit(item.get("url", ""))
            valid_url = parsed.scheme == "https" and bool(parsed.hostname) and parsed.username is None and parsed.password is None
        except (ValueError, TypeError):
            valid_url = False
        if item.get("mime_type") != "video/mp4" or not valid_url:
            stop("Unexpected video URL or MIME")
        # Review/download separately. Never forward API429 Authorization to this URL.
        print(item["url"])
        break
    if output.get("object") != "video.generation.job" or output.get("id") != job_id:
        stop("Unknown GET envelope")
    if output.get("status") == "succeeded":
        stop("Succeeded but full output envelope unverified")
    if output.get("status") != "queued":
        stop("Unknown state")
    time.sleep(min(5, max(0, deadline - time.monotonic())))
else:
    stop("Client read limit")

import { writeFile } from "node:fs/promises";
const key = process.env.API429_API_KEY;
if (!key) throw new Error("Set API429_API_KEY");
const base = "https://gateway.api429.com/v1";
const headers = { Authorization: "Bearer " + key, "Content-Type": "application/json" };
const model = "gemini-omni-1.1-flash";
const available = await fetch(base + "/models", { headers, signal: AbortSignal.timeout(30000) });
if (!available.ok) throw new Error("Models HTTP " + available.status);
let availableModels;
try { availableModels = await available.json(); }
catch { throw new Error("Invalid models response; stop before generation"); }
if (!Array.isArray(availableModels?.data)) throw new Error("Invalid models response; stop before generation");
if (!availableModels.data.some(item => item && item.id === model)) throw new Error("Model unavailable to this key");
// One paid POST only. Do not repeat an ambiguous submission automatically.
const submitted = await fetch(base + "/videos/generations", {
 method: "POST", headers, body: JSON.stringify({"model":"gemini-omni-1.1-flash","prompt":"A slow camera move around a blue ceramic cup on a table","duration":5,"aspect_ratio":"16:9","resolution":"720p","n":1}), signal: AbortSignal.timeout(60000)
});
let job;
try { job = await submitted.json(); }
catch { throw new Error("Ambiguous submission; job ID unknown; inspect original attempt, no new POST"); }
if (!job || typeof job.id !== "string" || !/^[A-Za-z0-9_-]{1,200}$/.test(job.id)) throw new Error("Unknown submission; investigate before any new POST");
await writeFile("video-job.json", JSON.stringify({ id: job.id }));
function stop(reason) { throw new Error(reason + "; job ID: " + job.id + "; inspect this job, no new POST"); }
if (submitted.status !== 202 || job.object !== "video.generation.job" || job.status !== "queued") stop("Unknown submission shape");
const url = base + "/videos/generations/" + encodeURIComponent(job.id);
// Client policy, not a server guarantee: 12 reads, 5-second pause, 180-second deadline.
const deadline = Date.now() + 180000;
let complete = false;
for (let attempt = 0; attempt < 12; attempt++) {
 const remaining = deadline - Date.now();
 if (remaining <= 0) stop("Client deadline");
 let output;
 try {
  const response = await fetch(url, { headers, signal: AbortSignal.timeout(Math.min(30000, remaining)) });
  if (!response.ok) stop("Read HTTP " + response.status);
  output = await response.json();
 } catch { stop("Read failed"); }
 if (Date.now() >= deadline) stop("Client deadline");
 if (!output || typeof output !== "object" || Array.isArray(output)) stop("Malformed response");
 if (output.object === "video.generation") {
  if (output.model !== model || !Array.isArray(output.data) || output.data.length !== 1 || !output.data[0]) stop("Malformed output");
  const item = output.data[0];
  let parsed;
  try { parsed = new URL(item.url); } catch { stop("Invalid video URL"); }
  if (parsed.protocol !== "https:" || parsed.username || parsed.password || item.mime_type !== "video/mp4") stop("Unexpected video URL or MIME");
  // Review/download separately; never forward API429 Authorization to this URL.
  console.log(parsed.href);
  complete = true;
  break;
 }
 if (output.object !== "video.generation.job" || output.id !== job.id) stop("Unknown GET envelope");
 if (output.status === "succeeded") stop("Succeeded but full output envelope unverified");
 if (output.status !== "queued") stop("Unknown state");
 await new Promise(resolve => setTimeout(resolve, Math.min(5000, Math.max(0, deadline - Date.now()))));
}
if (!complete) stop("Client read limit");