fix: Queue dry-run 默认提示 stdin 输入

src/selftest/cases/75-queue-q2-dispatch.ts

@@ -1,4 +1,5 @@
 import assert from "node:assert/strict";
+import { spawn } from "node:child_process";
 import { chmod, readFile, writeFile } from "node:fs/promises";
 import path from "node:path";
 import { startManagerServer } from "../../mgr/server.js";
@@ -53,6 +54,25 @@ process.exit(1);
   });
   try {
     const client = new ManagerClient(server.baseUrl);
+    const stdinSubmitPlan = await runCliJson(context, server.baseUrl, ["queue", "submit", "--json-stdin", "--dry-run", "--idempotency-key", "queue-q2-cli-stdin-dry-run"], {
+      tenantId: "unidesk",
+      projectId: "pikasTech/unidesk",
+      queue: "dev",
+      title: "stdin queue dry-run task",
+      payload: { prompt: "stdin queue dry-run" },
+    });
+    assert.equal(stdinSubmitPlan.ok, true);
+    assert.equal(((stdinSubmitPlan.data as JsonRecord).action), "queue-submit-plan");
+    assert.equal((((stdinSubmitPlan.data as JsonRecord).jsonInput as JsonRecord).preferred), "--json-stdin");
+    assert.equal(String(((stdinSubmitPlan.data as JsonRecord).next as JsonRecord).confirm).includes("--json-stdin"), true);
+    assert.equal(String(((stdinSubmitPlan.data as JsonRecord).next as JsonRecord).confirm).includes("--idempotency-key <idempotency-key>"), true);
+    assert.equal(String(((stdinSubmitPlan.data as JsonRecord).next as JsonRecord).confirm).includes("--json-file"), false);
+
+    const help = await runCliJson(context, server.baseUrl, ["help"]);
+    const commands = ((help.data as JsonRecord).commands as string[]) ?? [];
+    assert.equal(commands.some((item) => item.includes("queue submit --json-stdin|--json-file")), true);
+    assert.equal(commands.some((item) => item.includes("queue submit --json-file <task.json>|--json-stdin")), false);
+
     const created = await client.post("/api/v1/queue/tasks", {
       tenantId: "unidesk",
       projectId: "pikasTech/unidesk",
@@ -77,6 +97,17 @@ process.exit(1);
       metadata: { source: "queue-q2-self-test" },
       idempotencyKey: "queue-q2-dispatch-self-test",
     }) as QueueTaskRecord;
+    const dispatchPlan = await runCliJson(context, server.baseUrl, ["queue", "dispatch", String(created.id), "--dry-run", "--attempt-id", "attempt_queue_q2_cli_dryrun"]);
+    assert.equal(dispatchPlan.ok, true);
+    assert.equal(((dispatchPlan.data as JsonRecord).action), "queue-dispatch-plan");
+    assert.equal(String(((dispatchPlan.data as JsonRecord).next as JsonRecord).confirm).includes("--json-file"), false);
+    assert.equal(String(((dispatchPlan.data as JsonRecord).next as JsonRecord).confirm).includes("--attempt-id <attempt-id>"), true);
+
+    const dispatchStdinPlan = await runCliJson(context, server.baseUrl, ["queue", "dispatch", String(created.id), "--json-stdin", "--dry-run"], { attemptId: "attempt_queue_q2_cli_stdin_dryrun" });
+    assert.equal(dispatchStdinPlan.ok, true);
+    assert.equal(String(((dispatchStdinPlan.data as JsonRecord).next as JsonRecord).confirm).includes("--json-stdin"), true);
+    assert.equal(String(((dispatchStdinPlan.data as JsonRecord).next as JsonRecord).confirm).includes("--json-file"), false);
+
     const dispatched = await client.post(`/api/v1/queue/tasks/${created.id}/dispatch`, { attemptId: "attempt_queue_q2_selftest" }) as QueueDispatchResult;
     assert.equal(dispatched.action, "queue-dispatch");
     assert.equal(dispatched.mutation, true);
@@ -242,7 +273,7 @@ process.exit(1);
     assert.ok(JSON.stringify(cancelManifest).includes(cancelDispatched.run.id));
     assertNoSecretLeak(dispatched);
     assertNoSecretLeak(cancelled);
-    return { name: "queue-q2-dispatch", tests: ["queue-dispatch-run-command-runner-job", "queue-read-views-refresh-terminal-state", "queue-refresh-from-core-status", "queue-dispatch-no-repeat", "queue-unidesk-ssh-endpoint-auto-env", "queue-blocked-run-state-wins-over-command-failed", "queue-cancel-propagates-to-run-command-session"] };
+    return { name: "queue-q2-dispatch", tests: ["queue-cli-json-stdin-dry-run", "queue-dispatch-run-command-runner-job", "queue-read-views-refresh-terminal-state", "queue-refresh-from-core-status", "queue-dispatch-no-repeat", "queue-unidesk-ssh-endpoint-auto-env", "queue-blocked-run-state-wins-over-command-failed", "queue-cancel-propagates-to-run-command-session"] };
   } finally {
     await new Promise<void>((resolve) => server.server.close(() => resolve()));
   }
@@ -250,6 +281,25 @@ process.exit(1);
 
 export default selfTest;
 
+async function runCliJson(context: { root: string }, managerUrl: string, args: string[], stdinJson?: JsonRecord): Promise<JsonRecord> {
+  const proc = spawn(process.execPath, [`${context.root}/scripts/agentrun-cli.ts`, "--manager-url", managerUrl, ...args], { stdio: ["pipe", "pipe", "pipe"] });
+  if (stdinJson !== undefined) proc.stdin.write(JSON.stringify(stdinJson));
+  proc.stdin.end();
+  const [stdout, stderr, code] = await Promise.all([readStream(proc.stdout), readStream(proc.stderr), new Promise<number | null>((resolve) => proc.on("close", resolve))]);
+  assert.equal(code, 0, stderr || stdout);
+  return JSON.parse(stdout) as JsonRecord;
+}
+
+async function readStream(stream: NodeJS.ReadableStream): Promise<string> {
+  const chunks: Buffer[] = [];
+  stream.on("data", (chunk: Buffer | string) => chunks.push(Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk)));
+  await new Promise<void>((resolve, reject) => {
+    stream.on("end", resolve);
+    stream.on("error", reject);
+  });
+  return Buffer.concat(chunks).toString("utf8");
+}
+
 function runnerEnvValue(manifest: JsonRecord, name: string): unknown {
   const spec = manifest.spec as JsonRecord;
   const template = spec.template as JsonRecord;