refactor(flags): align media command async and concurrent handling

- scope image/video task execution to --async and --concurrent
- add concurrent task fan-out for video edit and video ref
- extend image edit to the async image task path
- refresh e2e coverage and generated command references

Author: XXPermanentXX

docs/agents/stress-batch-tests.md

@@ -126,7 +126,7 @@ pnpm run test:stress -- video-edit --reuse-fixtures -- --count 3
 
 **禁止**对子进程加 `--quiet`（与 `--output json` 并存时可能丢 `urls` / `video_url`）。
 
-**禁止**对视频相关子进程加 `--no-wait`；须阻塞到任务完成（及下载路径正确时落盘）。
+**禁止**对视频相关子进程加 `--async`；须阻塞到任务完成（及下载路径正确时落盘）。
 
 ### 成功 / 失败判定（概要）
 
@@ -192,7 +192,7 @@ pnpm run test:stress -- video-edit --reuse-fixtures -- --count 3
 
 - [ ] `lib/paths.mjs` 解析的 `CLI_PACKAGE` / `MONOREPO_ROOT` 仍正确
 - [ ] 子进程仍为 `node` + `src/main.ts`，未改回裸 `pnpm run dev` 执行任务
-- [ ] 未对子进程加 `--quiet`，视频未加 `--no-wait`
+- [ ] 未对子进程加 `--quiet`，视频未加 `--async`
 - [ ] `parsers.mjs` 与文档中的成功判定一致
 - [ ] 根 `package.json` 仅保留 `test:stress` 入口指向 `run.mjs`
 - [ ] `node --check` 对相关 `.mjs` 通过，`pnpm run test:stress -- list` 可运行

packages/cli/tests/e2e/image-edit.e2e.test.ts

@@ -27,7 +27,32 @@ describe("e2e: image edit", () => {
   test("image edit --help 正常退出", async () => {
     const { stderr, exitCode } = await runCli(["image", "edit", "--help"]);
     expect(exitCode, stderr).toBe(0);
-    expect(stderr).toMatch(/edit|--image|--prompt/i);
+    expect(stderr).toMatch(/edit|--image|--prompt|--async|--concurrent/i);
+  });
+
+  test("image edit --dry-run 接受 async 模型的 --async 与 --concurrent", async () => {
+    const { stdout, stderr, exitCode } = await runCli([
+      "image",
+      "edit",
+      "--dry-run",
+      "--model",
+      "wan2.6-t2i",
+      "--image",
+      "https://example.com/source.png",
+      "--prompt",
+      "Change the background to blue",
+      "--async",
+      "--concurrent",
+      "2",
+      "--output",
+      "json",
+    ]);
+    expect(exitCode, stderr).toBe(0);
+    const data = parseStdoutJson<{ mode?: string; request?: { input?: { messages?: unknown[] } } }>(
+      stdout,
+    );
+    expect(data.mode).toBe("async");
+    expect(data.request?.input?.messages?.length).toBeGreaterThan(0);
   });
 });
 

packages/cli/tests/e2e/video-edit.e2e.test.ts

@@ -24,7 +24,29 @@ describe("e2e: video edit", () => {
   test("video edit --help 正常退出", async () => {
     const { stderr, exitCode } = await runCli(["video", "edit", "--help"]);
     expect(exitCode, stderr).toBe(0);
-    expect(stderr).toMatch(/edit|--video|--prompt|model/i);
+    expect(stderr).toMatch(/edit|--video|--prompt|model|--async|--concurrent/i);
+  });
+
+  test("video edit --dry-run 接受 --async 与 --concurrent", async () => {
+    const { stdout, stderr, exitCode } = await runCli([
+      "video",
+      "edit",
+      "--dry-run",
+      "--video",
+      "https://example.com/input.mp4",
+      "--prompt",
+      "整体色调偏暖",
+      "--async",
+      "--concurrent",
+      "2",
+      "--output",
+      "json",
+    ]);
+    expect(exitCode, stderr).toBe(0);
+    const data = parseStdoutJson<{ request?: { input?: { media?: Array<{ url?: string }> } } }>(
+      stdout,
+    );
+    expect(data.request?.input?.media?.[0]?.url).toBe("https://example.com/input.mp4");
   });
 });
 

packages/cli/tests/e2e/video-ref-r2v.e2e.test.ts

@@ -24,7 +24,29 @@ describe("e2e: video ref (r2v)", () => {
   test("video ref --help 正常退出", async () => {
     const { stderr, exitCode } = await runCli(["video", "ref", "--help"]);
     expect(exitCode, stderr).toBe(0);
-    expect(stderr).toMatch(/ref|--prompt|--image|model/i);
+    expect(stderr).toMatch(/ref|--prompt|--image|model|--async|--concurrent/i);
+  });
+
+  test("video ref --dry-run 接受 --async 与 --concurrent", async () => {
+    const { stdout, stderr, exitCode } = await runCli([
+      "video",
+      "ref",
+      "--dry-run",
+      "--prompt",
+      "Image 1 waves",
+      "--image",
+      "https://example.com/person.png",
+      "--async",
+      "--concurrent",
+      "2",
+      "--output",
+      "json",
+    ]);
+    expect(exitCode, stderr).toBe(0);
+    const data = parseStdoutJson<{ request?: { input?: { media?: Array<{ url?: string }> } } }>(
+      stdout,
+    );
+    expect(data.request?.input?.media?.[0]?.url).toBe("https://example.com/person.png");
   });
 });
 

packages/cli/tests/stress/lib/parsers.mjs

@@ -78,7 +78,7 @@ export function parseImageResult(stdout) {
       const ids = data.task_ids ?? [data.task_id];
       return {
         ok: false,
-        error: `仅返回 task_id，未等待生成完成: ${ids.join(", ")}。请勿使用 --no-wait，或检查 ~/.bailian/config.json 是否开启 async`,
+        error: `仅返回 task_id，未等待生成完成: ${ids.join(", ")}。请勿使用 --async，或检查调用参数是否开启 async`,
       };
     }
     return { ok: false, error: "JSON 中无 urls / saved 字段（可能生成未完成）" };
@@ -169,7 +169,7 @@ export function parseVideoResult(stdout) {
       const ids = taskIds ?? [taskId];
       return {
         ok: false,
-        error: `仅返回 task_id，未等待生成完成: ${ids.join(", ")}。请勿使用 --no-wait，或检查 ~/.bailian/config.json 是否开启 async`,
+        error: `仅返回 task_id，未等待生成完成: ${ids.join(", ")}。请勿使用 --async，或检查调用参数是否开启 async`,
       };
     }
     return { ok: false, error: "JSON 中无 video_url / saved 字段（可能生成未完成）" };