Function getVideoJobStatus

packages/ai/src/activities/generateVideo/index.ts:584–685

(options: {
  adapter: TAdapter & { kind: typeof kind }
  jobId: string
})

 * ```
 */
export async function getVideoJobStatus<
  TAdapter extends VideoAdapter<string, any, any, any>,
>(options: {
  adapter: TAdapter & { kind: typeof kind }
  jobId: string
}): Promise<{
  status: 'pending' | 'processing' | 'completed' | 'failed'
  progress?: number
  url?: string
  error?: string
  usage?: TokenUsage
}> {
  const { adapter, jobId } = options
  const requestId = createId('video-status')
  const startTime = Date.now()

  aiEventClient.emit('video:request:started', {
    requestId,
    provider: adapter.name,
    model: adapter.model,
    requestType: 'status',
    jobId,
    timestamp: startTime,
  })

  // Get status first
  const statusResult = await adapter.getVideoStatus(jobId)

  // If completed, also get the URL
  if (statusResult.status === 'completed') {
    try {
      const urlResult = await adapter.getVideoUrl(jobId)
      aiEventClient.emit('video:request:completed', {
        requestId,
        provider: adapter.name,
        model: adapter.model,
        requestType: 'status',
        jobId,
        status: statusResult.status,
        progress: statusResult.progress,
        url: urlResult.url,
        duration: Date.now() - startTime,
        timestamp: Date.now(),
      })
      if (urlResult.usage) {
        aiEventClient.emit('video:usage', {
          requestId,
          model: adapter.model,
          usage: urlResult.usage,
          timestamp: Date.now(),
        })
      }
      return {
        status: statusResult.status,
        progress: statusResult.progress,
        url: urlResult.url,
        ...(urlResult.usage ? { usage: urlResult.usage } : {}),
      }