curl -X POST "https://api.toapis.com/v1/videos/generations" \
  -H "Authorization: Bearer $TOAPIS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "model": "doubao-seedance-2-0",
    "prompt": "电影质感无人机航拍，夕阳余晖穿透北欧峡湾，水面波光粼粼，4k画质，慢速运镜",
    "aspect_ratio": "16:9",
    "duration": 5,
    "quality": "standard"
  }'

{
  "code": 0,
  "message": "Task queued successfully",
  "data": {
    "task_id": "task_seedance_89f02c4b918a",
    "status": "PROCESSING",
    "created_at": 1729411200
  }
}

import os
import time
import requests

API_KEY = os.getenv("TOAPIS_API_KEY", "your_toapis_api_key_here")
BASE_URL = "https://api.toapis.com/v1"

headers = {
    "Authorization": f"Bearer {API_KEY}",
    "Content-Type": "application/json"
}

def generate_video(prompt: str, duration: int = 5, aspect_ratio: str = "16:9") -> str:
    # 1. 提交异步视频生成任务
    payload = {
        "model": "doubao-seedance-2-0",
        "prompt": prompt,
        "duration": duration,
        "aspect_ratio": aspect_ratio
    }
    
    response = requests.post(f"{BASE_URL}/videos/generations", json=payload, headers=headers)
    response.raise_for_status()
    res_data = response.json()
    
    task_id = res_data["data"]["task_id"]
    print(f"[*] 任务提交成功，任务 ID: {task_id}")
    
    # 2. 轮询任务状态直至完成
    poll_interval = 3
    max_timeout = 180
    elapsed = 0
    
    while elapsed < max_timeout:
        time.sleep(poll_interval)
        elapsed += poll_interval
        
        status_res = requests.get(
            f"{BASE_URL}/tasks/video-status?task_id={task_id}", 
            headers=headers
        )
        
        if status_res.status_code == 200:
            task_info = status_res.json().get("data", {})
            status = task_info.get("status")
            print(f"[-] 当前耗时 {elapsed}s，状态: {status}")
            
            if status == "SUCCESS":
                video_url = task_info.get("video_url")
                print(f"[+] 视频生成成功！下载链接: {video_url}")
                return video_url
            elif status in ("FAILED", "CANCELED"):
                error_msg = task_info.get("error_message", "未知错误")
                raise RuntimeError(f"任务执行失败: {error_msg}")
        elif status_res.status_code == 429:
            print("[!] 触发速率限制，休眠 5 秒后重试...")
            time.sleep(5)
            
    raise TimeoutError(f"任务 {task_id} 在 {max_timeout} 秒内未完成，已超时。")

if __name__ == "__main__":
    prompt = "晨光中透明玻璃杯缓缓注入意式浓缩咖啡，极细腻液体流动飞溅特写，慢动作摄影。"
    video_url = generate_video(prompt)

import axios from 'axios';

const TOAPIS_API_KEY = process.env.TOAPIS_API_KEY || 'your_api_key';
const client = axios.create({
  baseURL: 'https://api.toapis.com/v1',
  headers: {
    Authorization: `Bearer ${TOAPIS_API_KEY}`,
    'Content-Type': 'application/json',
  },
});

interface VideoTaskResponse {
  code: number;
  data: {
    task_id: string;
    status: 'PENDING' | 'PROCESSING' | 'SUCCESS' | 'FAILED';
    video_url?: string;
    error_message?: string;
  };
}

export async function runSeedanceJob(prompt: string, duration = 5): Promise<string> {
  // 1. 提交任务
  const submitRes = await client.post<VideoTaskResponse>('/videos/generations', {
    model: 'doubao-seedance-2-0',
    prompt,
    duration,
    aspect_ratio: '16:9',
  });

  const taskId = submitRes.data.data.task_id;
  console.log(`[任务已提交] Task ID: ${taskId}`);

  // 2. 轮询状态
  const pollInterval = 3000;
  const maxAttempts = 60; // 累计最多等待 180 秒

  for (let attempt = 1; attempt <= maxAttempts; attempt++) {
    await new Promise((resolve) => setTimeout(resolve, pollInterval));

    const pollRes = await client.get<VideoTaskResponse>(`/tasks/video-status?task_id=${taskId}`);
    const task = pollRes.data.data;
    console.log(`[第 ${attempt} 次轮询] 当前状态: ${task.status}`);

    if (task.status === 'SUCCESS' && task.video_url) {
      return task.video_url;
    }
    if (task.status === 'FAILED') {
      throw new Error(`视频生成失败: ${task.error_message || '未知原因'}`);
    }
  }

  throw new Error('视频任务超过 180 秒未完成，已超时。');
}