┌─────────────────┐             ┌─────────────────────┐             ┌─────────────────────────┐
│ クライアント    │             │ ToAPIs 統合ゲートウェイ │             │ ByteDance GPU クラスタ  │
│ (バックエンド)  │             │ (api.toapis.com)    │             │ (Seedance 2.0 エンジン) │
└────────┬────────┘             └──────────┬──────────┘             └────────────┬────────────┘
         │                                 │                                     │
         │ 1. POST /v1/videos/generations  │                                     │
         │────────────────────────────────>│ 2. 認証検証 & ジョブをキューへ投入  │
         │                                 │────────────────────────────────────>│
         │ 3. HTTP 202: task_id を返却     │                                     │
         │<────────────────────────────────│                                     │
         │                                 │                                     │
         │ 4. GET /v1/tasks/video-status   │                                     │
         │    (3秒待機後ポーリング開始)    │                                     │
         │────────────────────────────────>│ 5. キューの状態と進捗を確認         │
         │                                 │────────────────────────────────────>│
         │ 6. 進捗返却: "PROCESSING" (35%) │<────────────────────────────────────│
         │<────────────────────────────────│                                     │
         │                                 │                                     │
         │ 7. GET /v1/tasks/video-status   │                                     │
         │    (3秒待機後ポーリング継続)    │                                     │
         │────────────────────────────────>│ 8. レンダリング完了、CDN 配置完了   │
         │                                 │────────────────────────────────────>│
         │ 9. 完了返却: "SUCCESS" + MP4 URL│<────────────────────────────────────│
         │<────────────────────────────────│                                     │
         │                                 │                                     │
         │ 10. S3 などの独自ストレージ保存 │                                     │
         │─────────────────────────────────┴─────────────────────────────────────┘

export TOAPIS_API_KEY="sk-toapis-your-active-api-key"

# ステップ 1: 動画生成タスクの送信
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": "映画のような空撮映像、朝霧に包まれたスコットランドの古城、薄霧を切り裂く黄金のチンダル光、8k解像度 24fps",
    "aspect_ratio": "16:9",
    "duration": 5,
    "quality": "standard"
  }'

{
  "code": 0,
  "message": "Task submitted successfully",
  "data": {
    "task_id": "task_seedance_9f81a7b03c4e4d8a",
    "status": "QUEUED",
    "created_at": 1761037200,
    "model": "doubao-seedance-2-0",
    "estimated_seconds": 32
  }
}

# ステップ 2: 返却された task_id を指定して状態を確認
curl -X GET "https://api.toapis.com/v1/tasks/video-status?task_id=task_seedance_9f81a7b03c4e4d8a" \
  -H "Authorization: Bearer $TOAPIS_API_KEY"

"""
ToAPIs ゲートウェイ経由の Seedance 2.0 Video API 本番用 Python クライアント
主な機能:
- 型安全なリクエストペイロード生成
- タイムアウト保護付きの安全なステータスポーリング
- HTTP 429 レート制限に対応する指数バックオフ（ランダムジッター付き）
- レンダリングされた MP4 動画ストリームのローカル保存
"""

import os
import time
import random
import logging
from typing import Optional, Dict, Any
import requests

logging.basicConfig(level=logging.INFO, format="%(asctime)s [%(levelname)s] %(message)s")
logger = logging.getLogger("Seedance2Client")

class SeedanceAPIError(Exception):
    """Seedance API 固有の例外"""
    pass

class SeedanceClient:
    def __init__(self, api_key: Optional[str] = None, base_url: str = "https://api.toapis.com/v1"):
        self.api_key = api_key or os.getenv("TOAPIS_API_KEY")
        if not self.api_key:
            raise ValueError("API キーが見つかりません。TOAPIS_API_KEY を設定してください。")
        self.base_url = base_url.rstrip("/")
        self.headers = {
            "Authorization": f"Bearer {self.api_key}",
            "Content-Type": "application/json",
            "User-Agent": "ToAPIs-Seedance-SDK/2.0"
        }

    def submit_video_task(
        self,
        prompt: str,
        aspect_ratio: str = "16:9",
        duration: int = 5,
        quality: str = "standard",
        seed: Optional[int] = None,
        image_url: Optional[str] = None
    ) -> str:
        """動画生成タスクを投入し、task_id を取得します"""
        url = f"{self.base_url}/videos/generations"
        payload: Dict[str, Any] = {
            "model": "doubao-seedance-2-0",
            "prompt": prompt,
            "aspect_ratio": aspect_ratio,
            "duration": duration,
            "quality": quality
        }
        if seed is not None:
            payload["seed"] = seed
        if image_url:
            payload["image_url"] = image_url

        logger.info(f"Seedance 2.0 タスクを送信中: アスペクト比={aspect_ratio}, 長さ={duration}s...")
        response = requests.post(url, json=payload, headers=self.headers, timeout=30)
        
        if response.status_code == 429:
            raise SeedanceAPIError("同時実行制限 (HTTP 429) に達しました。バックオフが必要です。")
        response.raise_for_status()
        
        data = response.json()
        task_id = data.get("data", {}).get("task_id")
        if not task_id:
            raise SeedanceAPIError(f"予期しないレスポンス形式です: {data}")
            
        logger.info(f"タスク受付完了。Task ID: {task_id}")
        return task_id

    def poll_until_complete(
        self,
        task_id: str,
        initial_interval: float = 3.0,
        max_timeout: float = 180.0
    ) -> str:
        """SUCCESS または FAILED になるまでポーリングし、CDN の動画 URL を返却します"""
        url = f"{self.base_url}/tasks/video-status"
        params = {"task_id": task_id}
        start_time = time.time()
        current_interval = initial_interval

        while time.time() - start_time < max_timeout:
            time.sleep(current_interval)
            elapsed = int(time.time() - start_time)

            try:
                res = requests.get(url, params=params, headers=self.headers, timeout=15)
            except requests.RequestException as req_err:
                logger.warning(f"ネットワーク一時エラー (タスク {task_id}): {req_err}。再試行します...")
                continue

            if res.status_code == 429:
                backoff = current_interval * 1.5 + random.uniform(0.5, 1.5)
                logger.warning(f"HTTP 429 を受信。{backoff:.1f} 秒待機します...")
                time.sleep(backoff)
                continue

            if res.status_code != 200:
                logger.warning(f"ステータス確認エラー (HTTP {res.status_code}): {res.text}")
                continue

            body = res.json().get("data", {})
            status = body.get("status")
            progress = body.get("progress", 0)
            logger.info(f"[{elapsed}秒経過] ステータス: {status} ({progress}%)")

            if status == "SUCCESS":
                video_url = body.get("video_url")
                if not video_url:
                    raise SeedanceAPIError("ステータスは SUCCESS ですが video_url が存在しません。")
                logger.info(f"動画生成完了! 処理時間: {elapsed}秒, URL: {video_url}")
                return video_url
            elif status in ("FAILED", "CANCELED"):
                error_msg = body.get("error_message", "不明なレンダリングエラー")
                raise SeedanceAPIError(f"タスク {task_id} が異常終了しました: {error_msg}")

        raise TimeoutError(f"タスク {task_id} が制限時間 ({max_timeout}秒) を超過しました。")

    def download_video(self, video_url: str, output_path: str) -> None:
        """動画ストリームをダウンロードしてファイルに書き込みます"""
        logger.info(f"CDN から動画をダウンロードして {output_path} に保存します...")
        with requests.get(video_url, stream=True, timeout=60) as r:
            r.raise_for_status()
            with open(output_path, "wb") as f:
                for chunk in r.iter_content(chunk_size=8192):
                    f.write(chunk)
        logger.info(f"保存完了: {output_path} ({os.path.getsize(output_path)} バイト)")

if __name__ == "__main__":
    client = SeedanceClient()
    prompt = "クローズアップマクロ撮影：溶けた銅が精密なスチールギアの金型に注ぎ込まれ、火花が飛び散る。暗い工場の質感、レイトレーシング反射、1080p 30fps"
    
    try:
        t_id = client.submit_video_task(prompt=prompt, aspect_ratio="16:9", duration=5)
        url = client.poll_until_complete(t_id)
        client.download_video(url, "seedance_gear_sample.mp4")
    except Exception as exc:
        logger.error(f"実行エラー: {exc}")

import axios, { AxiosInstance } from 'axios';

export interface SeedanceGenerateOptions {
  prompt: string;
  aspectRatio?: '16:9' | '9:16' | '1:1' | '4:3' | '21:9';
  duration?: 5 | 10;
  quality?: 'standard' | 'high';
  seed?: number;
  imageUrl?: string;
  webhookUrl?: string;
}

export interface TaskStatusResponse {
  taskId: string;
  status: 'QUEUED' | 'PROCESSING' | 'SUCCESS' | 'FAILED';
  progress?: number;
  videoUrl?: string;
  errorMessage?: string;
}

export class SeedanceVideoService {
  private client: AxiosInstance;

  constructor(apiKey?: string, baseURL = 'https://api.toapis.com/v1') {
    const token = apiKey || process.env.TOAPIS_API_KEY;
    if (!token) {
      throw new Error('環境変数 TOAPIS_API_KEY が設定されていません。');
    }

    this.client = axios.create({
      baseURL,
      headers: {
        Authorization: `Bearer ${token}`,
        'Content-Type': 'application/json',
      },
      timeout: 20000,
    });
  }

  /**
   * Seedance 2.0 生成タスクを送信
   */
  async submitTask(options: SeedanceGenerateOptions): Promise<string> {
    const payload = {
      model: 'doubao-seedance-2-0',
      prompt: options.prompt,
      aspect_ratio: options.aspectRatio || '16:9',
      duration: options.duration || 5,
      quality: options.quality || 'standard',
      seed: options.seed,
      image_url: options.imageUrl,
      webhook_url: options.webhookUrl,
    };

    const res = await this.client.post('/videos/generations', payload);
    const taskId = res.data?.data?.task_id;
    if (!taskId) {
      throw new Error('ゲートウェイからの応答に task_id が含まれていません。');
    }
    return taskId;
  }

  /**
   * 完了までステータスをポーリング
   */
  async waitForCompletion(
    taskId: string,
    intervalMs = 3000,
    maxWaitMs = 180000
  ): Promise<string> {
    const startTime = Date.now();

    while (Date.now() - startTime < maxWaitMs) {
      await new Promise((resolve) => setTimeout(resolve, intervalMs));

      const res = await this.client.get('/tasks/video-status', {
        params: { task_id: taskId },
      });

      const data = res.data?.data;
      const status = data?.status;

      if (status === 'SUCCESS') {
        return data.video_url;
      }
      if (status === 'FAILED') {
        throw new Error(`Seedance 生成失敗: ${data.error_message || '不明なエラー'}`);
      }
    }

    throw new Error(`タスク ${taskId} がタイムアウト (${maxWaitMs / 1000}秒) しました。`);
  }
}

┌─────────────────────────────────────────────────────────────────────────────────┐
│ ポーリング vs Webhook アーキテクチャ比較表                                       │
├──────────────────┬─────────────────────────────┬────────────────────────────────┤
│ 比較項目         │ クライアントポーリング      │ Webhook イベントコールバック   │
├──────────────────┼─────────────────────────────┼────────────────────────────────┤
│ 最適な処理規模   │ 1日あたり 500本 未満        │ 1日あたり 500本 以上           │
│ アプリサーバー負荷│ 高い (1リクエストに10〜20回)│ 最小限 (1回の受信通知のみ)     │
│ ゲートウェイ QPS │ バースト時に増大            │ ポーリング不要で負荷ゼロ       │
│ ネットワーク環境 │ NAT / Localhost 環境で稼働  │ パブリック HTTPS が必須        │
│ 障害復旧の難易度 │ ループ内での再試行が容易    │ デッドレターキュー等の設計要   │
└──────────────────┴─────────────────────────────┴────────────────────────────────┘

FALLBACK_CASCADE = [
    {"model": "doubao-seedance-2-0", "timeout_sec": 45},
    {"model": "kling-3-omni", "timeout_sec": 60},
    {"model": "minimax-h3", "timeout_sec": 45}
]