stream-json 入力で Antigravity CLI を外部から回すとき、会話をどこで切るか

{"type":"user","message":{"role":"user","content":[{"type":"text","text":"アプリ wallpaper-a の ja 向けリリースノートを4行以内でまとめてください"}]}}

agy --print \
    --input-format stream-json \
    --output-format stream-json \
    < jobs.ndjson

// stream-driver.mjs — 外部ドライバから CLI を stream-json で回す
import { spawn } from "node:child_process";
import readline from "node:readline";
 
export async function runBatch(jobs, opts = {}) {
  const cmd = opts.cmd ?? ["agy", "--print", "--input-format", "stream-json", "--output-format", "stream-json"];
  const budget = opts.budgetBytes ?? 40_000; // 1 会話が抱える上限
  const stats = { sessions: 0, turns: 0, peakCarried: 0, splits: [] };
 
  let child = null, rl = null, carried = 0;
 
  const open = () => {
    child = spawn(cmd[0], cmd.slice(1), { stdio: ["pipe", "pipe", "inherit"] });
    rl = readline.createInterface({ input: child.stdout }); // 行境界は readline に任せる
    carried = 0;
    stats.sessions += 1;
  };
  const close = () => { child?.stdin.end(); rl?.close(); child = null; };
 
  // 1 メッセージ送って、そのターンの終端イベントが返るまで待つ
  const sendAndWait = (text) =>
    new Promise((resolve, reject) => {
      const onLine = (line) => {
        let ev;
        try { ev = JSON.parse(line); } catch { return; } // 部分行・装飾行は捨てる
        if (ev.type === "result") { rl.off("line", onLine); resolve(ev); }
        if (ev.type === "error") { rl.off("line", onLine); reject(new Error(ev.reason)); }
      };
      rl.on("line", onLine);
      child.stdin.write(
        JSON.stringify({ type: "user", message: { role: "user", content: [{ type: "text", text }] } }) + "\n"
      );
    });
 
  open();
  for (const job of jobs) {
    const size = Buffer.byteLength(job, "utf8");
    if (carried + size > budget && stats.turns > 0) {
      stats.splits.push({ afterTurn: stats.turns, carried });
      close(); open();                    // 会話を畳んで開き直す
    }
    const ev = await sendAndWait(job);
    carried = ev.carried_bytes ?? carried + size;
    stats.turns += 1;
    stats.peakCarried = Math.max(stats.peakCarried, carried);
  }
  close();
  return stats;
}