Function injectGenerateVideo

packages/ai-angular/src/inject-generate-video.ts:58–155

(
  options: Omit<InjectGenerateVideoOptions, 'onResult'> & {
    onResult?: (result: VideoGenerateResult) => TTransformed
  },
)

// parameter is typed as `VideoGenerateResult` and `result` narrows to the
// transform's return. See issue #848.
export function injectGenerateVideo<TTransformed = void>(
  options: Omit<InjectGenerateVideoOptions, 'onResult'> & {
    onResult?: (result: VideoGenerateResult) => TTransformed
  },
): InjectGenerateVideoResult<
  InferGenerationOutputFromReturn<VideoGenerateResult, TTransformed>
> {
  assertInInjectionContext(injectGenerateVideo)

  type TOutput = InferGenerationOutputFromReturn<
    VideoGenerateResult,
    TTransformed
  >

  const destroyRef = inject(DestroyRef)
  const injector = inject(Injector)
  const clientId = options.id || `injectGenerateVideo-${nextId++}`

  const result = signal<TOutput | null>(null)
  const jobId = signal<string | null>(null)
  const videoStatus = signal<VideoStatusInfo | null>(null)
  const isLoading = signal(false)
  const error = signal<Error | undefined>(undefined)
  const status = signal<GenerationClientState>('idle')

  const bodySource =
    options.body !== undefined ? toReactive(options.body) : undefined

  const baseOptions = {
    id: clientId,
    ...(bodySource !== undefined && { body: bodySource() }),
    devtoolsBridgeFactory: createVideoDevtoolsBridge,
    devtools: {
      ...options.devtools,
      framework: 'angular',
      hookName: 'injectGenerateVideo',
      outputKind: 'video' as const,
    },
    // The transform's raw return type (`TTransformed`) and the stored output
    // (`TOutput`, with null/void/undefined stripped) are identical at runtime;
    // the cast bridges the relationship that the conditional type hides.
    onResult: ((r: VideoGenerateResult) => options.onResult?.(r)) as (
      result: VideoGenerateResult,
    ) => TOutput | null | void,
    onError: (e: Error) => options.onError?.(e),
    onProgress: (p: number, m?: string) => options.onProgress?.(p, m),
    onChunk: (c: StreamChunk) => options.onChunk?.(c),
    onJobCreated: (id: string) => options.onJobCreated?.(id),
    onStatusUpdate: (s: VideoStatusInfo) => options.onStatusUpdate?.(s),
    onResultChange: (r: TOutput | null) => result.set(r),
    onLoadingChange: (l: boolean) => isLoading.set(l),
    onErrorChange: (e: Error | undefined) => error.set(e),
    onStatusChange: (s: GenerationClientState) => status.set(s),
    onJobIdChange: (id: string | null) => jobId.set(id),
    onVideoStatusChange: (s: VideoStatusInfo | null) => videoStatus.set(s),
  }

  let client: VideoGenerationClient<TOutput>