feat: add audio model train/deploy

Author: gujieye

AGENTS.md

@@ -105,6 +105,17 @@ CLI 只为「自己能权威解释的错误」发出语义化信号,服务端的
 
 这些 flag 已在 `GLOBAL_OPTIONS`（`packages/core/src/types/command.ts`）中注册，由 `loadConfig` 写入 `config.consoleRegion` / `config.consoleSite` / `config.consoleSwitchAgent`，`callConsoleGateway` 自动读取——命令无需手动提取或传递。
 
+### 5. 禁止单字母变量命名
+
+所有变量、参数、回调形参必须使用有语义的命名,不允许单字母(如 `i`、`m`、`p`、`t`、`e`、`s`)。具体表现:
+
+- 回调参数: `.map((m) => ...)` → `.map((model) => ...)`, `.find((t) => ...)` → `.find((template) => ...)`
+- catch 变量: `catch (e)` → `catch (error)`
+- for-of 循环: `for (const i of items)` → `for (const item of items)`
+- 临时变量: `const s = ...` → `const strategy = ...`
+
+例外: 仅当作用域极小(≤3 行)且语义从上下文完全明确时,可使用 `k`/`v`(Object.entries 的 key/value)。
+
 ## 完成改动后的快速验证
 
 ```sh

packages/commands/src/commands/dataset/upload.ts

@@ -16,13 +16,13 @@ import { failIfMissing } from "bailian-cli-runtime";
 import { emitResult, emitBare } from "bailian-cli-runtime";
 
 export default defineCommand({
-  description: "Upload a dataset file (.jsonl) to Bailian",
+  description: "Upload a dataset file (.jsonl or .zip) to Bailian",
   usageArgs:
-    "--file <path> [--purpose <name>] [--schema <chatml|dpo|cpt>] [--no-validate] [--full-validate]",
+    "--file <path> [--purpose <name>] [--schema <chatml|dpo|cpt|tts>] [--no-validate] [--full-validate]",
   options: [
     {
       flag: "--file <path>",
-      description: "Local .jsonl dataset file (≤300MB)",
+      description: "Local dataset file (.jsonl or .zip, ≤300MB)",
       required: true,
     },
     {
@@ -32,7 +32,7 @@ export default defineCommand({
     {
       flag: "--schema <s>",
       description:
-        'Record schema: "chatml" (SFT), "dpo" (chosen/rejected), or "cpt" (raw text). Default auto-detects per record.',
+        'Record schema: "chatml" (SFT), "dpo" (chosen/rejected), "cpt" (raw text), or "tts" (audio wav_fn/text). Default auto-detects per record.',
     },
     {
       flag: "--no-validate",
@@ -49,21 +49,21 @@ export default defineCommand({
     "--file train.jsonl",
     "--file dpo.jsonl --schema dpo",
     "--file cpt.jsonl --schema cpt",
+    "--file audio.zip --schema tts",
     "--file eval.jsonl --purpose evaluation",
     "--file train.jsonl --full-validate",
     "--file train.jsonl --no-validate",
   ],
   notes: [
-    "Only .jsonl is supported in this release. Three record schemas are",
-    "recognized: chatml = {messages:[...]} (SFT); dpo = {messages:[...],",
-    "chosen, rejected} where chosen/rejected are single assistant messages;",
-    'cpt = {text:"..."} (continual pre-training, raw text). With no --schema,',
-    "a record carrying chosen/rejected is validated as DPO, one with text (and",
-    "no messages) as CPT, otherwise as ChatML. Pass --schema dpo / cpt to",
-    "require that shape on every record, or --schema chatml to ignore the",
-    "preference / text fields. Other purposes may carry a different schema in",
-    "the future and would be served by a purpose-specific validator.",
-    "The dataset upload cap is 300MB per file.",
+    "Supports .jsonl (text) and .zip (audio/image/video archives with a",
+    "data.jsonl manifest). Four record schemas are recognized: chatml =",
+    "{messages:[...]} (SFT); dpo = {messages:[...], chosen, rejected};",
+    'cpt = {text:"..."} (continual pre-training, raw text); tts =',
+    '{wav_fn:"train/xxx.wav", text:"..."} (audio fine-tuning). With no',
+    "--schema, a record carrying wav_fn is validated as TTS, one with",
+    "chosen/rejected as DPO, one with text (and no messages) as CPT,",
+    "otherwise as ChatML. Pass --schema to require a specific shape on",
+    "every record. The dataset upload cap is 300MB per file.",
     "Upload uses the OpenAI-compatible /compatible-mode/v1/files endpoint so",
     "the purpose tag is persisted (the DashScope-native /api/v1/files drops it).",
   ],

packages/commands/src/commands/dataset/validate.ts

@@ -24,12 +24,12 @@ function formatStats(result: ValidationResult): string[] {
 }
 
 export default defineCommand({
-  description: "Locally validate a dataset file (.jsonl) without uploading",
+  description: "Locally validate a dataset file (.jsonl or .zip) without uploading",
   // 纯本地校验，不触网、不需 API key（与 `pipeline validate` 一致）。
   skipDefaultApiKeySetup: true,
-  usageArgs: "--file <path> [--full-validate] [--schema <chatml|dpo|cpt>]",
+  usageArgs: "--file <path> [--full-validate] [--schema <chatml|dpo|cpt|tts>]",
   options: [
-    { flag: "--file <path>", description: "Local .jsonl dataset file", required: true },
+    { flag: "--file <path>", description: "Local dataset file (.jsonl or .zip)", required: true },
     {
       flag: "--full-validate",
       description: "JSON.parse every line instead of sampling (slower)",
@@ -38,26 +38,29 @@ export default defineCommand({
     {
       flag: "--schema <s>",
       description:
-        'Record schema: "chatml" (SFT), "dpo" (chosen/rejected), or "cpt" (raw text). Default auto-detects per record.',
+        'Record schema: "chatml" (SFT), "dpo" (chosen/rejected), "cpt" (raw text), or "tts" (audio wav_fn/text). Default auto-detects per record.',
     },
   ],
   exampleArgs: [
     "--file train.jsonl",
     "--file dpo.jsonl --schema dpo",
     "--file cpt.jsonl --schema cpt",
+    "--file audio.zip --schema tts",
     "--file eval.jsonl --full-validate",
     "--file train.jsonl --output json",
   ],
   notes: [
     "Default scan: every line gets a structural check, then ~160 lines (front 50,",
     "evenly spaced 100, last 10) are JSON.parsed against the active schema.",
     "Schemas: chatml = {messages:[...]} (SFT); dpo = {messages:[...], chosen,",
-    "rejected} where chosen/rejected are single assistant messages; cpt =",
-    '{text:"..."} (continual pre-training, raw text). With no --schema, a',
-    "record carrying chosen/rejected is validated as DPO, one with text (and no",
-    "messages) as CPT, otherwise as ChatML. Pass --schema dpo / cpt to require",
-    "that shape on every record (strict), or --schema chatml to ignore the",
-    "preference / text fields. Use --full-validate to JSON.parse every line.",
+    'rejected}; cpt = {text:"..."} (continual pre-training, raw text);',
+    'tts = {wav_fn:"train/xxx.wav", text:"..."} (audio fine-tuning). With no',
+    "--schema, a record carrying wav_fn is validated as TTS, one with",
+    "chosen/rejected as DPO, one with text (and no messages) as CPT, otherwise",
+    "as ChatML. Pass --schema to require a specific shape on every record.",
+    "ZIP archives (.zip) are validated structurally (data.jsonl present, media",
+    "references resolve) in addition to per-record content checks.",
+    "Use --full-validate to JSON.parse every line.",
   ],
   async run(config: Config, flags: GlobalFlags) {
     const filePath = flags.file as string | undefined;

packages/commands/src/commands/deploy/create.ts

@@ -25,7 +25,7 @@ import { pickPlanStrategy } from "./plans.ts";
 export default defineCommand({
   description: "Create a model deployment",
   usageArgs:
-    "--model <model_name> --name <display_name> [--plan <plan>] [--template-id <id>] [--capacity <n>] [--billing-method <m>] [--input-tpm <n>] [--output-tpm <n>] [--thinking-output-tpm <n>] [--yes]",
+    "--model <model_name> --name <display_name> [--plan <plan>] [--deploy-spec <id>] [--capacity <n>] [--billing-method <m>] [--input-tpm <n>] [--output-tpm <n>] [--thinking-output-tpm <n>] [--yes]",
   options: [
     {
       flag: "--model <name>",
@@ -42,8 +42,8 @@ export default defineCommand({
       description: "Billing plan: lora (default, Token-billed) | ptu (Token-billed) | mu",
     },
     {
-      flag: "--template-id <id>",
-      description: "Template id (only used by plan=mu; auto-picked if omitted)",
+      flag: "--deploy-spec <id>",
+      description: "Deploy spec (only used by plan=mu; auto-picked if omitted)",
     },
     {
       flag: "--capacity <n>",
@@ -76,15 +76,15 @@ export default defineCommand({
     "--model my-qwen-sft --name my-sft-test",
     "--model qwen3.6-flash-2026-04-16 --name my-flash --plan ptu --input-tpm 10000 --output-tpm 1000",
     "--model qwen3-8b --name my-qwen3-mu --plan mu",
-    "--model qwen3-8b --name my-qwen3 --plan mu --template-id MU1 --capacity 2 --yes",
+    "--model qwen3-8b --name my-qwen3 --plan mu --deploy-spec MU1 --capacity 2 --yes",
   ],
   notes: [
     "Plan defaults to `lora` (Token-billed). Pass --plan to override.",
     "For plan=ptu (Token-billed, provisioned throughput), --input-tpm and",
     "--output-tpm are required (the platform rejects creation without an",
     "explicit ptu_capacity despite the doc listing defaults).",
-    "For plan=mu, `capacity`, `billing_method` and `template_id` are required.",
-    "billing_method defaults to POST_PAY (only supported value); template_id",
+    "For plan=mu, `capacity`, `billing_method` and `deploy_spec` are required.",
+    "billing_method defaults to POST_PAY (only supported value); deploy_spec",
     "and capacity are auto-picked from GET /deployments/models when omitted.",
     "Use `bl deploy models --source base` to inspect available templates.",
     "After creation, status starts at PENDING and transitions to RUNNING.",

packages/commands/src/commands/deploy/delete.ts

@@ -60,8 +60,8 @@ export default defineCommand({
             ExitCode.USAGE,
           );
         }
-      } catch (e) {
-        if (e instanceof BailianError) throw e;
+      } catch (error) {
+        if (error instanceof BailianError) throw error;
         // If the get itself failed (e.g. not found), let the DELETE call surface the real error.
       }
     }

packages/commands/src/commands/deploy/list.ts

@@ -60,13 +60,13 @@ export default defineCommand({
       return;
     }
     const headers = ["DEPLOYED_MODEL", "MODEL_NAME", "STATUS", "PLAN", "CAPACITY", "CREATED_AT"];
-    const rows = items.map((i) => [
-      i.deployed_model,
-      i.model_name,
-      i.status,
-      i.plan,
-      i.capacity,
-      i.created_at,
+    const rows = items.map((item) => [
+      item.deployed_model,
+      item.model_name,
+      item.status,
+      item.plan,
+      item.capacity,
+      item.created_at,
     ]);
     for (const line of formatTable(headers, rows)) emitBare(line);
     if (total !== undefined) emitBare(`\nTotal: ${total}`);

packages/commands/src/commands/deploy/models.ts

@@ -74,44 +74,44 @@ export default defineCommand({
     // downstream tooling can drive `bl deploy create --template-id <…>` without
     // a second round-trip. For text: keep the compact one-line summary.
     if (format === "json") {
-      const items = models.map((m) => {
+      const items = models.map((model) => {
         const out: Record<string, unknown> = {
-          model_name: m.model_name ?? "",
+          model_name: model.model_name ?? "",
         };
-        if (m.base_model) out.base_model = m.base_model;
-        if (m.model_source) out.model_source = m.model_source;
-        if (m.supported_plans && m.supported_plans.length > 0) {
-          out.supported_plans = m.supported_plans;
+        if (model.base_model) out.base_model = model.base_model;
+        if (model.model_source) out.model_source = model.model_source;
+        if (model.supported_plans && model.supported_plans.length > 0) {
+          out.supported_plans = model.supported_plans;
         }
-        if (m.plans && m.plans.length > 0) {
-          out.plans = m.plans.map((p) => {
-            const planEntry: Record<string, unknown> = { plan: p.plan ?? "" };
-            if (p.cu_specs && p.cu_specs.length > 0) {
-              planEntry.cu_specs = p.cu_specs;
+        if (model.plans && model.plans.length > 0) {
+          out.plans = model.plans.map((plan) => {
+            const planEntry: Record<string, unknown> = { plan: plan.plan ?? "" };
+            if (plan.cu_specs && plan.cu_specs.length > 0) {
+              planEntry.cu_specs = plan.cu_specs;
             }
-            if (p.templates && p.templates.length > 0) {
+            if (plan.templates && plan.templates.length > 0) {
               // Pull the top 6 fields most useful for `bl deploy create`.
               // Drop noisy/redundant: template_source, template_type,
               // template_version, deploy_spec (typically == template_id).
-              planEntry.templates = p.templates.map((t) => {
+              planEntry.templates = plan.templates.map((template) => {
                 const tpl: Record<string, unknown> = {};
-                if (t.template_id) tpl.template_id = t.template_id;
-                if (t.template_name) tpl.template_name = t.template_name;
-                if (t.charge_type) tpl.charge_type = t.charge_type;
+                if (template.template_id) tpl.template_id = template.template_id;
+                if (template.template_name) tpl.template_name = template.template_name;
+                if (template.charge_type) tpl.charge_type = template.charge_type;
                 // Flatten roles.unified for the common COUPLED case.
-                const unified = t.roles?.unified;
+                const unified = template.roles?.unified;
                 if (unified?.model_unit_spec) tpl.model_unit_spec = unified.model_unit_spec;
                 if (unified?.capacity_unit_per_instance !== undefined)
                   tpl.capacity_unit_per_instance = unified.capacity_unit_per_instance;
                 // Preserve split-role configs (SEPERATED) as-is so callers
                 // can still drive prefill/decode sizing.
-                if (t.roles?.prefill || t.roles?.decode) {
+                if (template.roles?.prefill || template.roles?.decode) {
                   tpl.roles = {
-                    prefill: t.roles?.prefill,
-                    decode: t.roles?.decode,
+                    prefill: template.roles?.prefill,
+                    decode: template.roles?.decode,
                   };
                 }
-                if (t.template_desc) tpl.template_desc = t.template_desc;
+                if (template.template_desc) tpl.template_desc = template.template_desc;
                 return tpl;
               });
             }
@@ -125,19 +125,19 @@ export default defineCommand({
     }
 
     // text / quiet — keep the compact single-line summary table.
-    const textItems = models.map((m) => {
+    const textItems = models.map((model) => {
       let plansSummary = "";
-      if (m.supported_plans && m.supported_plans.length > 0) {
-        plansSummary = m.supported_plans.join(",");
-      } else if (m.plans && m.plans.length > 0) {
-        plansSummary = m.plans
-          .map((p) => {
-            const planName = p.plan ?? "?";
-            if (p.templates && p.templates.length > 0) {
-              return `${planName}(${p.templates.length}t)`;
+      if (model.supported_plans && model.supported_plans.length > 0) {
+        plansSummary = model.supported_plans.join(",");
+      } else if (model.plans && model.plans.length > 0) {
+        plansSummary = model.plans
+          .map((plan) => {
+            const planName = plan.plan ?? "?";
+            if (plan.templates && plan.templates.length > 0) {
+              return `${planName}(${plan.templates.length}t)`;
             }
-            if (p.cu_specs && p.cu_specs.length > 0) {
-              return `${planName}(${p.cu_specs.join("/")})`;
+            if (plan.cu_specs && plan.cu_specs.length > 0) {
+              return `${planName}(${plan.cu_specs.join("/")})`;
             }
             return planName;
           })
@@ -146,9 +146,9 @@ export default defineCommand({
         plansSummary = "-";
       }
       return {
-        model_name: m.model_name ?? "",
-        base_model: m.base_model ?? "",
-        source: m.model_source ?? "",
+        model_name: model.model_name ?? "",
+        base_model: model.base_model ?? "",
+        source: model.model_source ?? "",
         plans: plansSummary,
       };
     });
@@ -158,7 +158,12 @@ export default defineCommand({
       return;
     }
     const headers = ["MODEL_NAME", "BASE_MODEL", "SOURCE", "PLANS"];
-    const rows = textItems.map((i) => [i.model_name, i.base_model, i.source, i.plans]);
+    const rows = textItems.map((item) => [
+      item.model_name,
+      item.base_model,
+      item.source,
+      item.plans,
+    ]);
     for (const line of formatTable(headers, rows)) emitBare(line);
     if (total !== undefined) emitBare(`\nTotal: ${total}`);
   },