#视频生成 API

1. POST /video/generations   → 得到 task id（此时已按预估 token 预扣费用）
2. 每隔约 5 秒 GET /videos/{id}
3. status = succeeded        → 读取 content.video_url，按实际输出 token 结算
   status = failed / cancelled / expired → 预扣退回，无成片

curl https://api.haiyushuke.com/v1/video/generations \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "model": "doubao-seedance-2.0",
    "prompt": "清晨的海边公路，镜头缓慢前推，阳光洒在湿润的柏油路上，电影感，4 秒一个镜头切换",
    "resolution": "720p",
    "duration": 5,
    "generate_audio": true
  }'

{
  "id": "cgt-xxxxxxxx",
  "model": "doubao-seedance-2.0",
  "status": "queued"
}

curl https://api.haiyushuke.com/v1/videos/cgt-xxxxxxxx \
  -H "Authorization: Bearer YOUR_API_KEY"

{
  "id": "cgt-xxxxxxxx",
  "model": "doubao-seedance-2.0",
  "status": "succeeded",
  "resolution": "720p",
  "content": {
    "video_url": "https://example.com/output.mp4",
    "last_frame_url": "https://example.com/last-frame.jpg"
  },
  "usage": {
    "completion_tokens": 108900,
    "total_tokens": 108900
  }
}

import os
import time
import requests
 
BASE = os.environ.get("HAIYUSHUKE_BASE_URL", "https://api.haiyushuke.com/v1")
KEY = os.environ["HAIYUSHUKE_API_KEY"]
HEADERS = {
    "Authorization": f"Bearer {KEY}",
    "Content-Type": "application/json",
}
 
created = requests.post(
    f"{BASE}/video/generations",
    headers=HEADERS,
    json={
        "model": "doubao-seedance-2.0",
        "prompt": "城市夜景航拍，霓虹倒映在江面，缓慢环绕",
        "resolution": "720p",
        "duration": 5,
    },
    timeout=180,
)
created.raise_for_status()
task_id = created.json()["id"]
 
terminal_ok = {"succeeded", "success", "completed", "complete"}
terminal_fail = {"failed", "cancelled", "canceled", "expired", "error"}
 
for _ in range(90):
    r = requests.get(f"{BASE}/videos/{task_id}", headers=HEADERS, timeout=60)
    r.raise_for_status()
    task = r.json()
    status = str(task.get("status") or "").lower()
    if status in terminal_ok:
        content = task.get("content") or {}
        print(content.get("video_url") or task.get("video_url"))
        break
    if status in terminal_fail:
        raise RuntimeError(task.get("error") or status)
    time.sleep(5)
else:
    raise TimeoutError("视频生成超时")

const BASE = process.env.HAIYUSHUKE_BASE_URL ?? "https://api.haiyushuke.com/v1";
const KEY = process.env.HAIYUSHUKE_API_KEY;
 
async function createAndWait(prompt) {
  const created = await fetch(`${BASE}/video/generations`, {
    method: "POST",
    headers: {
      Authorization: `Bearer ${KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      model: "doubao-seedance-2.0",
      prompt,
      resolution: "720p",
      duration: 5,
    }),
  });
  if (!created.ok) throw new Error(await created.text());
  const { id } = await created.json();
 
  const ok = new Set(["succeeded", "success", "completed", "complete"]);
  const fail = new Set(["failed", "cancelled", "canceled", "expired", "error"]);
 
  for (let i = 0; i < 90; i++) {
    const res = await fetch(`${BASE}/videos/${id}`, {
      headers: { Authorization: `Bearer ${KEY}` },
    });
    if (!res.ok) throw new Error(await res.text());
    const task = await res.json();
    const status = String(task.status || "").toLowerCase();
    if (ok.has(status)) {
      return task.content?.video_url || task.video_url;
    }
    if (fail.has(status)) {
      throw new Error(task.error?.message || status);
    }
    await new Promise((r) => setTimeout(r, 5000));
  }
  throw new Error("视频生成超时");
}