refactor: dedupe dashscope video helpers

extensions/alibaba/video-generation-provider.ts

@@ -2,48 +2,28 @@ import { isProviderApiKeyConfigured } from "openclaw/plugin-sdk/provider-auth";
 import { resolveApiKeyForProvider } from "openclaw/plugin-sdk/provider-auth-runtime";
 import {
   assertOkOrThrowHttpError,
-  fetchWithTimeout,
   postJsonRequest,
   resolveProviderHttpRequestConfig,
 } from "openclaw/plugin-sdk/provider-http";
+import {
+  DEFAULT_VIDEO_GENERATION_DURATION_SECONDS,
+  DEFAULT_VIDEO_GENERATION_TIMEOUT_MS,
+  DEFAULT_VIDEO_RESOLUTION_TO_SIZE,
+  buildDashscopeVideoGenerationInput,
+  buildDashscopeVideoGenerationParameters,
+  downloadDashscopeGeneratedVideos,
+  extractDashscopeVideoUrls,
+  pollDashscopeVideoTaskUntilComplete,
+} from "openclaw/plugin-sdk/video-generation";
 import type {
-  GeneratedVideoAsset,
+  DashscopeVideoGenerationResponse,
   VideoGenerationProvider,
   VideoGenerationRequest,
   VideoGenerationResult,
-  VideoGenerationSourceAsset,
 } from "openclaw/plugin-sdk/video-generation";
 
 const DEFAULT_ALIBABA_VIDEO_BASE_URL = "https://dashscope-intl.aliyuncs.com";
 const DEFAULT_ALIBABA_VIDEO_MODEL = "wan2.6-t2v";
-const DEFAULT_DURATION_SECONDS = 5;
-const DEFAULT_TIMEOUT_MS = 120_000;
-const POLL_INTERVAL_MS = 2_500;
-const MAX_POLL_ATTEMPTS = 120;
-const RESOLUTION_TO_SIZE: Record<string, string> = {
-  "480P": "832*480",
-  "720P": "1280*720",
-  "1080P": "1920*1080",
-};
-
-type AlibabaVideoGenerationResponse = {
-  output?: {
-    task_id?: string;
-    task_status?: string;
-    submit_time?: string;
-    results?: Array<{
-      video_url?: string;
-      orig_prompt?: string;
-      actual_prompt?: string;
-    }>;
-    video_url?: string;
-    code?: string;
-    message?: string;
-  };
-  request_id?: string;
-  code?: string;
-  message?: string;
-};
 
 function resolveAlibabaVideoBaseUrl(req: VideoGenerationRequest): string {
   return req.cfg?.models?.providers?.alibaba?.baseUrl?.trim() || DEFAULT_ALIBABA_VIDEO_BASE_URL;
@@ -53,139 +33,6 @@ function resolveDashscopeAigcApiBaseUrl(baseUrl: string): string {
   return baseUrl.replace(/\/+$/u, "");
 }
 
-function resolveReferenceUrls(
-  inputImages: VideoGenerationSourceAsset[] | undefined,
-  inputVideos: VideoGenerationSourceAsset[] | undefined,
-): string[] {
-  return [...(inputImages ?? []), ...(inputVideos ?? [])]
-    .map((asset) => asset.url?.trim())
-    .filter((value): value is string => Boolean(value));
-}
-
-function assertAlibabaReferenceInputsSupported(
-  inputImages: VideoGenerationSourceAsset[] | undefined,
-  inputVideos: VideoGenerationSourceAsset[] | undefined,
-): void {
-  const unsupported = [...(inputImages ?? []), ...(inputVideos ?? [])].some(
-    (asset) => !asset.url?.trim() && asset.buffer,
-  );
-  if (unsupported) {
-    throw new Error(
-      "Alibaba Wan video generation currently requires remote http(s) URLs for reference images/videos.",
-    );
-  }
-}
-
-function buildAlibabaVideoGenerationInput(req: VideoGenerationRequest): Record<string, unknown> {
-  assertAlibabaReferenceInputsSupported(req.inputImages, req.inputVideos);
-  const input: Record<string, unknown> = {
-    prompt: req.prompt,
-  };
-  const referenceUrls = resolveReferenceUrls(req.inputImages, req.inputVideos);
-  if (
-    referenceUrls.length === 1 &&
-    (req.inputImages?.length ?? 0) === 1 &&
-    !req.inputVideos?.length
-  ) {
-    input.img_url = referenceUrls[0];
-  } else if (referenceUrls.length > 0) {
-    input.reference_urls = referenceUrls;
-  }
-  return input;
-}
-
-function buildAlibabaVideoGenerationParameters(
-  req: VideoGenerationRequest,
-): Record<string, unknown> | undefined {
-  const parameters: Record<string, unknown> = {};
-  const size =
-    req.size?.trim() || (req.resolution ? RESOLUTION_TO_SIZE[req.resolution] : undefined);
-  if (size) {
-    parameters.size = size;
-  }
-  if (req.aspectRatio?.trim()) {
-    parameters.aspect_ratio = req.aspectRatio.trim();
-  }
-  if (typeof req.durationSeconds === "number" && Number.isFinite(req.durationSeconds)) {
-    parameters.duration = Math.max(1, Math.round(req.durationSeconds));
-  }
-  if (typeof req.audio === "boolean") {
-    parameters.enable_audio = req.audio;
-  }
-  if (typeof req.watermark === "boolean") {
-    parameters.watermark = req.watermark;
-  }
-  return Object.keys(parameters).length > 0 ? parameters : undefined;
-}
-
-function extractVideoUrls(payload: AlibabaVideoGenerationResponse): string[] {
-  const urls = [
-    ...(payload.output?.results?.map((entry) => entry.video_url).filter(Boolean) ?? []),
-    payload.output?.video_url,
-  ].filter((value): value is string => typeof value === "string" && value.trim().length > 0);
-  return [...new Set(urls)];
-}
-
-async function pollTaskUntilComplete(params: {
-  taskId: string;
-  headers: Headers;
-  timeoutMs?: number;
-  fetchFn: typeof fetch;
-  baseUrl: string;
-}): Promise<AlibabaVideoGenerationResponse> {
-  for (let attempt = 0; attempt < MAX_POLL_ATTEMPTS; attempt += 1) {
-    const response = await fetchWithTimeout(
-      `${params.baseUrl}/api/v1/tasks/${params.taskId}`,
-      {
-        method: "GET",
-        headers: params.headers,
-      },
-      params.timeoutMs ?? DEFAULT_TIMEOUT_MS,
-      params.fetchFn,
-    );
-    await assertOkOrThrowHttpError(response, "Alibaba Wan video-generation task poll failed");
-    const payload = (await response.json()) as AlibabaVideoGenerationResponse;
-    const status = payload.output?.task_status?.trim().toUpperCase();
-    if (status === "SUCCEEDED") {
-      return payload;
-    }
-    if (status === "FAILED" || status === "CANCELED") {
-      throw new Error(
-        payload.output?.message?.trim() ||
-          payload.message?.trim() ||
-          `Alibaba Wan video generation task ${params.taskId} ${status?.toLowerCase()}`,
-      );
-    }
-    await new Promise((resolve) => setTimeout(resolve, POLL_INTERVAL_MS));
-  }
-  throw new Error(`Alibaba Wan video generation task ${params.taskId} did not finish in time`);
-}
-
-async function downloadGeneratedVideos(params: {
-  urls: string[];
-  timeoutMs?: number;
-  fetchFn: typeof fetch;
-}): Promise<GeneratedVideoAsset[]> {
-  const videos: GeneratedVideoAsset[] = [];
-  for (const [index, url] of params.urls.entries()) {
-    const response = await fetchWithTimeout(
-      url,
-      { method: "GET" },
-      params.timeoutMs ?? DEFAULT_TIMEOUT_MS,
-      params.fetchFn,
-    );
-    await assertOkOrThrowHttpError(response, "Alibaba Wan generated video download failed");
-    const arrayBuffer = await response.arrayBuffer();
-    videos.push({
-      buffer: Buffer.from(arrayBuffer),
-      mimeType: response.headers.get("content-type")?.trim() || "video/mp4",
-      fileName: `video-${index + 1}.mp4`,
-      metadata: { sourceUrl: url },
-    });
-  }
-  return videos;
-}
-
 export function buildAlibabaVideoGenerationProvider(): VideoGenerationProvider {
   return {
     id: "alibaba",
@@ -263,11 +110,17 @@ export function buildAlibabaVideoGenerationProvider(): VideoGenerationProvider {
         headers,
         body: {
           model,
-          input: buildAlibabaVideoGenerationInput(req),
-          parameters: buildAlibabaVideoGenerationParameters({
-            ...req,
-            durationSeconds: req.durationSeconds ?? DEFAULT_DURATION_SECONDS,
+          input: buildDashscopeVideoGenerationInput({
+            providerLabel: "Alibaba Wan",
+            req,
           }),
+          parameters: buildDashscopeVideoGenerationParameters(
+            {
+              ...req,
+              durationSeconds: req.durationSeconds ?? DEFAULT_VIDEO_GENERATION_DURATION_SECONDS,
+            },
+            DEFAULT_VIDEO_RESOLUTION_TO_SIZE,
+          ),
         },
         timeoutMs: req.timeoutMs,
         fetchFn,
@@ -277,26 +130,30 @@ export function buildAlibabaVideoGenerationProvider(): VideoGenerationProvider {
 
       try {
         await assertOkOrThrowHttpError(response, "Alibaba Wan video generation failed");
-        const submitted = (await response.json()) as AlibabaVideoGenerationResponse;
+        const submitted = (await response.json()) as DashscopeVideoGenerationResponse;
         const taskId = submitted.output?.task_id?.trim();
         if (!taskId) {
           throw new Error("Alibaba Wan video generation response missing task_id");
         }
-        const completed = await pollTaskUntilComplete({
+        const completed = await pollDashscopeVideoTaskUntilComplete({
+          providerLabel: "Alibaba Wan",
           taskId,
           headers,
           timeoutMs: req.timeoutMs,
           fetchFn,
           baseUrl: resolveDashscopeAigcApiBaseUrl(baseUrl),
+          defaultTimeoutMs: DEFAULT_VIDEO_GENERATION_TIMEOUT_MS,
         });
-        const urls = extractVideoUrls(completed);
+        const urls = extractDashscopeVideoUrls(completed);
         if (urls.length === 0) {
           throw new Error("Alibaba Wan video generation completed without output video URLs");
         }
-        const videos = await downloadGeneratedVideos({
+        const videos = await downloadDashscopeGeneratedVideos({
+          providerLabel: "Alibaba Wan",
           urls,
           timeoutMs: req.timeoutMs,
           fetchFn,
+          defaultTimeoutMs: DEFAULT_VIDEO_GENERATION_TIMEOUT_MS,
         });
         return {
           videos,

extensions/qwen/video-generation-provider.ts

@@ -2,49 +2,29 @@ import { isProviderApiKeyConfigured } from "openclaw/plugin-sdk/provider-auth";
 import { resolveApiKeyForProvider } from "openclaw/plugin-sdk/provider-auth-runtime";
 import {
   assertOkOrThrowHttpError,
-  fetchWithTimeout,
   postJsonRequest,
   resolveProviderHttpRequestConfig,
 } from "openclaw/plugin-sdk/provider-http";
+import {
+  DEFAULT_VIDEO_GENERATION_DURATION_SECONDS,
+  DEFAULT_VIDEO_GENERATION_TIMEOUT_MS,
+  DEFAULT_VIDEO_RESOLUTION_TO_SIZE,
+  buildDashscopeVideoGenerationInput,
+  buildDashscopeVideoGenerationParameters,
+  downloadDashscopeGeneratedVideos,
+  extractDashscopeVideoUrls,
+  pollDashscopeVideoTaskUntilComplete,
+} from "openclaw/plugin-sdk/video-generation";
 import type {
-  GeneratedVideoAsset,
+  DashscopeVideoGenerationResponse,
   VideoGenerationProvider,
   VideoGenerationRequest,
   VideoGenerationResult,
-  VideoGenerationSourceAsset,
 } from "openclaw/plugin-sdk/video-generation";
 import { QWEN_STANDARD_CN_BASE_URL, QWEN_STANDARD_GLOBAL_BASE_URL } from "./models.js";
 
 const DEFAULT_QWEN_VIDEO_BASE_URL = "https://dashscope-intl.aliyuncs.com";
 const DEFAULT_QWEN_VIDEO_MODEL = "wan2.6-t2v";
-const DEFAULT_DURATION_SECONDS = 5;
-const DEFAULT_REQUEST_TIMEOUT_MS = 120_000;
-const POLL_INTERVAL_MS = 2_500;
-const MAX_POLL_ATTEMPTS = 120;
-const RESOLUTION_TO_SIZE: Record<string, string> = {
-  "480P": "832*480",
-  "720P": "1280*720",
-  "1080P": "1920*1080",
-};
-
-type QwenVideoGenerationResponse = {
-  output?: {
-    task_id?: string;
-    task_status?: string;
-    submit_time?: string;
-    results?: Array<{
-      video_url?: string;
-      orig_prompt?: string;
-      actual_prompt?: string;
-    }>;
-    video_url?: string;
-    code?: string;
-    message?: string;
-  };
-  request_id?: string;
-  code?: string;
-  message?: string;
-};
 
 function resolveQwenVideoBaseUrl(req: VideoGenerationRequest): string {
   const direct = req.cfg?.models?.providers?.qwen?.baseUrl?.trim();
@@ -81,139 +61,6 @@ function resolveDashscopeAigcApiBaseUrl(baseUrl: string): string {
   return baseUrl.replace(/\/+$/u, "");
 }
 
-function resolveReferenceUrls(
-  inputImages: VideoGenerationSourceAsset[] | undefined,
-  inputVideos: VideoGenerationSourceAsset[] | undefined,
-): string[] {
-  return [...(inputImages ?? []), ...(inputVideos ?? [])]
-    .map((asset) => asset.url?.trim())
-    .filter((value): value is string => Boolean(value));
-}
-
-function assertQwenReferenceInputsSupported(
-  inputImages: VideoGenerationSourceAsset[] | undefined,
-  inputVideos: VideoGenerationSourceAsset[] | undefined,
-): void {
-  const unsupported = [...(inputImages ?? []), ...(inputVideos ?? [])].some(
-    (asset) => !asset.url?.trim() && asset.buffer,
-  );
-  if (unsupported) {
-    throw new Error(
-      "Qwen video generation currently requires remote http(s) URLs for reference images/videos.",
-    );
-  }
-}
-
-function buildQwenVideoGenerationInput(req: VideoGenerationRequest): Record<string, unknown> {
-  assertQwenReferenceInputsSupported(req.inputImages, req.inputVideos);
-  const input: Record<string, unknown> = {
-    prompt: req.prompt,
-  };
-  const referenceUrls = resolveReferenceUrls(req.inputImages, req.inputVideos);
-  if (
-    referenceUrls.length === 1 &&
-    (req.inputImages?.length ?? 0) === 1 &&
-    !req.inputVideos?.length
-  ) {
-    input.img_url = referenceUrls[0];
-  } else if (referenceUrls.length > 0) {
-    input.reference_urls = referenceUrls;
-  }
-  return input;
-}
-
-function buildQwenVideoGenerationParameters(
-  req: VideoGenerationRequest,
-): Record<string, unknown> | undefined {
-  const parameters: Record<string, unknown> = {};
-  const size =
-    req.size?.trim() || (req.resolution ? RESOLUTION_TO_SIZE[req.resolution] : undefined);
-  if (size) {
-    parameters.size = size;
-  }
-  if (req.aspectRatio?.trim()) {
-    parameters.aspect_ratio = req.aspectRatio.trim();
-  }
-  if (typeof req.durationSeconds === "number" && Number.isFinite(req.durationSeconds)) {
-    parameters.duration = Math.max(1, Math.round(req.durationSeconds));
-  }
-  if (typeof req.audio === "boolean") {
-    parameters.enable_audio = req.audio;
-  }
-  if (typeof req.watermark === "boolean") {
-    parameters.watermark = req.watermark;
-  }
-  return Object.keys(parameters).length > 0 ? parameters : undefined;
-}
-
-function extractVideoUrls(payload: QwenVideoGenerationResponse): string[] {
-  const urls = [
-    ...(payload.output?.results?.map((entry) => entry.video_url).filter(Boolean) ?? []),
-    payload.output?.video_url,
-  ].filter((value): value is string => typeof value === "string" && value.trim().length > 0);
-  return [...new Set(urls)];
-}
-
-async function pollTaskUntilComplete(params: {
-  taskId: string;
-  headers: Headers;
-  timeoutMs?: number;
-  fetchFn: typeof fetch;
-  baseUrl: string;
-}): Promise<QwenVideoGenerationResponse> {
-  for (let attempt = 0; attempt < MAX_POLL_ATTEMPTS; attempt += 1) {
-    const response = await fetchWithTimeout(
-      `${params.baseUrl}/api/v1/tasks/${params.taskId}`,
-      {
-        method: "GET",
-        headers: params.headers,
-      },
-      params.timeoutMs ?? DEFAULT_REQUEST_TIMEOUT_MS,
-      params.fetchFn,
-    );
-    await assertOkOrThrowHttpError(response, "Qwen video-generation task poll failed");
-    const payload = (await response.json()) as QwenVideoGenerationResponse;
-    const status = payload.output?.task_status?.trim().toUpperCase();
-    if (status === "SUCCEEDED") {
-      return payload;
-    }
-    if (status === "FAILED" || status === "CANCELED") {
-      throw new Error(
-        payload.output?.message?.trim() ||
-          payload.message?.trim() ||
-          `Qwen video generation task ${params.taskId} ${status.toLowerCase()}`,
-      );
-    }
-    await new Promise((resolve) => setTimeout(resolve, POLL_INTERVAL_MS));
-  }
-  throw new Error(`Qwen video generation task ${params.taskId} did not finish in time`);
-}
-
-async function downloadGeneratedVideos(params: {
-  urls: string[];
-  timeoutMs?: number;
-  fetchFn: typeof fetch;
-}): Promise<GeneratedVideoAsset[]> {
-  const videos: GeneratedVideoAsset[] = [];
-  for (const [index, url] of params.urls.entries()) {
-    const response = await fetchWithTimeout(
-      url,
-      { method: "GET" },
-      params.timeoutMs ?? DEFAULT_REQUEST_TIMEOUT_MS,
-      params.fetchFn,
-    );
-    await assertOkOrThrowHttpError(response, "Qwen generated video download failed");
-    const arrayBuffer = await response.arrayBuffer();
-    videos.push({
-      buffer: Buffer.from(arrayBuffer),
-      mimeType: response.headers.get("content-type")?.trim() || "video/mp4",
-      fileName: `video-${index + 1}.mp4`,
-      metadata: { sourceUrl: url },
-    });
-  }
-  return videos;
-}
-
 export function buildQwenVideoGenerationProvider(): VideoGenerationProvider {
   return {
     id: "qwen",
@@ -291,11 +138,17 @@ export function buildQwenVideoGenerationProvider(): VideoGenerationProvider {
         headers,
         body: {
           model,
-          input: buildQwenVideoGenerationInput(req),
-          parameters: buildQwenVideoGenerationParameters({
-            ...req,
-            durationSeconds: req.durationSeconds ?? DEFAULT_DURATION_SECONDS,
+          input: buildDashscopeVideoGenerationInput({
+            providerLabel: "Qwen",
+            req,
           }),
+          parameters: buildDashscopeVideoGenerationParameters(
+            {
+              ...req,
+              durationSeconds: req.durationSeconds ?? DEFAULT_VIDEO_GENERATION_DURATION_SECONDS,
+            },
+            DEFAULT_VIDEO_RESOLUTION_TO_SIZE,
+          ),
         },
         timeoutMs: req.timeoutMs,
         fetchFn,
@@ -305,26 +158,30 @@ export function buildQwenVideoGenerationProvider(): VideoGenerationProvider {
 
       try {
         await assertOkOrThrowHttpError(response, "Qwen video generation failed");
-        const submitted = (await response.json()) as QwenVideoGenerationResponse;
+        const submitted = (await response.json()) as DashscopeVideoGenerationResponse;
         const taskId = submitted.output?.task_id?.trim();
         if (!taskId) {
           throw new Error("Qwen video generation response missing task_id");
         }
-        const completed = await pollTaskUntilComplete({
+        const completed = await pollDashscopeVideoTaskUntilComplete({
+          providerLabel: "Qwen",
           taskId,
           headers,
           timeoutMs: req.timeoutMs,
           fetchFn,
           baseUrl: resolveDashscopeAigcApiBaseUrl(baseUrl),
+          defaultTimeoutMs: DEFAULT_VIDEO_GENERATION_TIMEOUT_MS,
         });
-        const urls = extractVideoUrls(completed);
+        const urls = extractDashscopeVideoUrls(completed);
         if (urls.length === 0) {
           throw new Error("Qwen video generation completed without output video URLs");
         }
-        const videos = await downloadGeneratedVideos({
+        const videos = await downloadDashscopeGeneratedVideos({
+          providerLabel: "Qwen",
           urls,
           timeoutMs: req.timeoutMs,
           fetchFn,
+          defaultTimeoutMs: DEFAULT_VIDEO_GENERATION_TIMEOUT_MS,
         });
         return {
           videos,

src/plugin-sdk/video-generation.ts

@@ -13,3 +13,17 @@ export type {
   VideoGenerationSourceAsset,
   VideoGenerationTransformCapabilities,
 } from "../video-generation/types.js";
+
+export {
+  DEFAULT_VIDEO_GENERATION_DURATION_SECONDS,
+  DEFAULT_VIDEO_GENERATION_TIMEOUT_MS,
+  DEFAULT_VIDEO_RESOLUTION_TO_SIZE,
+  buildDashscopeVideoGenerationInput,
+  buildDashscopeVideoGenerationParameters,
+  downloadDashscopeGeneratedVideos,
+  extractDashscopeVideoUrls,
+  pollDashscopeVideoTaskUntilComplete,
+  resolveVideoGenerationReferenceUrls,
+} from "../video-generation/dashscope-compatible.js";
+
+export type { DashscopeVideoGenerationResponse } from "../video-generation/dashscope-compatible.js";

src/video-generation/dashscope-compatible.ts

@@ -0,0 +1,180 @@
+import { assertOkOrThrowHttpError, fetchWithTimeout } from "openclaw/plugin-sdk/provider-http";
+import type {
+  GeneratedVideoAsset,
+  VideoGenerationRequest,
+  VideoGenerationSourceAsset,
+} from "./types.js";
+
+export const DEFAULT_VIDEO_GENERATION_DURATION_SECONDS = 5;
+export const DEFAULT_VIDEO_GENERATION_TIMEOUT_MS = 120_000;
+export const DEFAULT_VIDEO_RESOLUTION_TO_SIZE: Record<string, string> = {
+  "480P": "832*480",
+  "720P": "1280*720",
+  "1080P": "1920*1080",
+};
+
+const DEFAULT_VIDEO_GENERATION_POLL_INTERVAL_MS = 2_500;
+const DEFAULT_VIDEO_GENERATION_MAX_POLL_ATTEMPTS = 120;
+
+export type DashscopeVideoGenerationResponse = {
+  output?: {
+    task_id?: string;
+    task_status?: string;
+    submit_time?: string;
+    results?: Array<{
+      video_url?: string;
+      orig_prompt?: string;
+      actual_prompt?: string;
+    }>;
+    video_url?: string;
+    code?: string;
+    message?: string;
+  };
+  request_id?: string;
+  code?: string;
+  message?: string;
+};
+
+export function buildDashscopeVideoGenerationInput(params: {
+  providerLabel: string;
+  req: VideoGenerationRequest;
+}): Record<string, unknown> {
+  const unsupported = [...(params.req.inputImages ?? []), ...(params.req.inputVideos ?? [])].some(
+    (asset) => !asset.url?.trim() && asset.buffer,
+  );
+  if (unsupported) {
+    throw new Error(
+      `${params.providerLabel} video generation currently requires remote http(s) URLs for reference images/videos.`,
+    );
+  }
+  const input: Record<string, unknown> = {
+    prompt: params.req.prompt,
+  };
+  const referenceUrls = resolveVideoGenerationReferenceUrls(
+    params.req.inputImages,
+    params.req.inputVideos,
+  );
+  if (
+    referenceUrls.length === 1 &&
+    (params.req.inputImages?.length ?? 0) === 1 &&
+    !params.req.inputVideos?.length
+  ) {
+    input.img_url = referenceUrls[0];
+  } else if (referenceUrls.length > 0) {
+    input.reference_urls = referenceUrls;
+  }
+  return input;
+}
+
+export function resolveVideoGenerationReferenceUrls(
+  inputImages: VideoGenerationSourceAsset[] | undefined,
+  inputVideos: VideoGenerationSourceAsset[] | undefined,
+): string[] {
+  return [...(inputImages ?? []), ...(inputVideos ?? [])]
+    .map((asset) => asset.url?.trim())
+    .filter((value): value is string => Boolean(value));
+}
+
+export function buildDashscopeVideoGenerationParameters(
+  req: VideoGenerationRequest,
+  resolutionToSize: Record<string, string> = DEFAULT_VIDEO_RESOLUTION_TO_SIZE,
+): Record<string, unknown> | undefined {
+  const parameters: Record<string, unknown> = {};
+  const size = req.size?.trim() || (req.resolution ? resolutionToSize[req.resolution] : undefined);
+  if (size) {
+    parameters.size = size;
+  }
+  if (req.aspectRatio?.trim()) {
+    parameters.aspect_ratio = req.aspectRatio.trim();
+  }
+  if (typeof req.durationSeconds === "number" && Number.isFinite(req.durationSeconds)) {
+    parameters.duration = Math.max(1, Math.round(req.durationSeconds));
+  }
+  if (typeof req.audio === "boolean") {
+    parameters.enable_audio = req.audio;
+  }
+  if (typeof req.watermark === "boolean") {
+    parameters.watermark = req.watermark;
+  }
+  return Object.keys(parameters).length > 0 ? parameters : undefined;
+}
+
+export function extractDashscopeVideoUrls(payload: DashscopeVideoGenerationResponse): string[] {
+  const urls = [
+    ...(payload.output?.results?.map((entry) => entry.video_url).filter(Boolean) ?? []),
+    payload.output?.video_url,
+  ].filter((value): value is string => typeof value === "string" && value.trim().length > 0);
+  return [...new Set(urls)];
+}
+
+export async function pollDashscopeVideoTaskUntilComplete(params: {
+  providerLabel: string;
+  taskId: string;
+  headers: Headers;
+  timeoutMs?: number;
+  fetchFn: typeof fetch;
+  baseUrl: string;
+  defaultTimeoutMs?: number;
+}): Promise<DashscopeVideoGenerationResponse> {
+  for (let attempt = 0; attempt < DEFAULT_VIDEO_GENERATION_MAX_POLL_ATTEMPTS; attempt += 1) {
+    const response = await fetchWithTimeout(
+      `${params.baseUrl}/api/v1/tasks/${params.taskId}`,
+      {
+        method: "GET",
+        headers: params.headers,
+      },
+      params.timeoutMs ?? params.defaultTimeoutMs ?? DEFAULT_VIDEO_GENERATION_TIMEOUT_MS,
+      params.fetchFn,
+    );
+    await assertOkOrThrowHttpError(
+      response,
+      `${params.providerLabel} video-generation task poll failed`,
+    );
+    const payload = (await response.json()) as DashscopeVideoGenerationResponse;
+    const status = payload.output?.task_status?.trim().toUpperCase();
+    if (status === "SUCCEEDED") {
+      return payload;
+    }
+    if (status === "FAILED" || status === "CANCELED") {
+      throw new Error(
+        payload.output?.message?.trim() ||
+          payload.message?.trim() ||
+          `${params.providerLabel} video generation task ${params.taskId} ${status.toLowerCase()}`,
+      );
+    }
+    await new Promise((resolve) => setTimeout(resolve, DEFAULT_VIDEO_GENERATION_POLL_INTERVAL_MS));
+  }
+  throw new Error(
+    `${params.providerLabel} video generation task ${params.taskId} did not finish in time`,
+  );
+}
+
+export async function downloadDashscopeGeneratedVideos(params: {
+  providerLabel: string;
+  urls: string[];
+  timeoutMs?: number;
+  fetchFn: typeof fetch;
+  defaultTimeoutMs?: number;
+}): Promise<GeneratedVideoAsset[]> {
+  const videos: GeneratedVideoAsset[] = [];
+  for (const [index, url] of params.urls.entries()) {
+    const response = await fetchWithTimeout(
+      url,
+      { method: "GET" },
+      params.timeoutMs ?? params.defaultTimeoutMs ?? DEFAULT_VIDEO_GENERATION_TIMEOUT_MS,
+      params.fetchFn,
+    );
+    await assertOkOrThrowHttpError(
+      response,
+      `${params.providerLabel} generated video download failed`,
+    );
+    const arrayBuffer = await response.arrayBuffer();
+    videos.push({
+      buffer: Buffer.from(arrayBuffer),
+      mimeType: response.headers.get("content-type")?.trim() || "video/mp4",
+      fileName: `video-${index + 1}.mp4`,
+      metadata: { sourceUrl: url },
+    });
+  }
+  return videos;
+}