Video Pipeline

step 1: check
  ├─ checkThreadExists(threadId)
  ├─ cost = getVideoCreditsCost(toolName, duration)
  ├─ checkVideoEligibility(userId, cost)
  ├─ deductCredits(userId, cost, taskId)  ← 原子幂等
  └─ { skip, startTime, cost }

step 2: notify-processing
  ├─ updateVideoInJsonb(taskId, { status: "processing" })
  ├─ updateMessageToolOutput(...)
  └─ notifyUser({ type: "video_status", video: { status: "processing" } })

step 3: create-task
  ├─ detectImageRatio(sourceImageId) 若 ratio="auto"
  ├─ provider = getProvider(providerName)
  └─ providerTaskId = await provider.createTask(task)

step 4: poll-result
  └─ pollWithInngestSteps(step, () => provider.pollTask(providerTaskId))
     # 用 step.sleep + step.waitForEvent 做 durable polling
     └─ GenerationResult { success, videoUrl, error }

step 5: post-process
  ├─ fetch(videoUrl) → Buffer
  ├─ ffprobe → { width, height, duration }
  ├─ ffmpeg -vframes 1 -q:v 2 → thumbnail JPEG (95% quality)
  ├─ generateBlurhash(thumbBuffer)
  ├─ uploadVideo → {userId}/{threadId}/video_{videoId}.mp4
  ├─ uploadThumbnail → {userId}/{threadId}/vc_{thumbId}.jpg
  └─ VideoResult { url, thumbUrl, width, height, duration, blurhash }

step 6: finalize
  ├─ trackToolUsage({ userId, threadId, taskId, tool_name, success, duration_ms, credits_consumed })
  ├─ trackMediaUsage({ taskId, toolName, provider, model, duration_ms, output_duration_ms })  # 仅时长
  └─ handleSuccess(...)
     ├─ checkVideoCsam(thumbBuffer, videoFileId)
     ├─ updateVideoInJsonb(taskId, { status: "completed", videoId, thumbId, ... })
     └─ notifyUser({ status: "completed", url, thumbUrl, ... })

interface Video {
  toolCallId?: string;
  toolName?: string;
  taskId: string;                 // UUID
  provider: string;               // seedance / grok / ws-wan27 / ...
  status: "pending" | "processing" | "completed" | "failed"
        | "insufficient_credits" | "insufficient_plan";
  createdAt: string;
  errorMessage?: string;
  errorCode?: string;

  input: {
    prompt?: string;
    sourceImageId?: string;
    sourceVideoId?: string;       // videoEdit / videoExtend / trimVideo
    sourceMedias?: string[];      // videoEdit reference images
    duration?: number;            // 5 / 10
    ratio?: string;
    trimStart?: number;
    trimEnd?: number;
    imageId?: string;             // motionControl 起始帧
  };

  output?: {
    videoId: string;              // Storage 路径
    thumbId: string;
    width: number;
    height: number;
    duration: number;
  };
}

{
  "type": "video_status",
  "taskId": "...",
  "video": {
    "taskId": "...",
    "status": "processing" | "completed" | "failed" | "insufficient_credits" | "insufficient_plan",
    "url": "https://...",
    "thumbUrl": "https://...",
    "width": 1920,
    "height": 1080,
    "duration": 5.5,
    "blurhash": "U6PVzY...",
    "errorCode": "csam_blocked",
    "errorMessage": "..."
  },
  "timestamp": "2026-04-14T12:34:56Z"
}

trackMediaUsage({
  userId, threadId, taskId, toolName,
  provider,                 // seedance / grok / ws-wan27 / ...
  model,                    // 模型字符串
  durationMs,               // 处理耗时
  outputDurationMs,         // 视频时长（统一 ms）
});