夜間に回した並列サブエージェントの記録が、追えなくなった — --forward-subagent-text で増えたログを絞り直す

// filter-subagent-log.mjs
// 使い方: claude -p "..." --output-format stream-json --forward-subagent-text \
//           | node filter-subagent-log.mjs --run-id 2026-07-17-nightly
import { createInterface } from 'node:readline';
import { createWriteStream, mkdirSync, rmSync } from 'node:fs';
 
const runId = process.argv[process.argv.indexOf('--run-id') + 1] ?? String(Date.now());
const dir = `./logs/${runId}`;
mkdirSync(dir, { recursive: true });
 
const out = {
  skeleton: createWriteStream(`${dir}/skeleton.jsonl`),
  body: createWriteStream(`${dir}/body.jsonl`),
  thinking: createWriteStream(`${dir}/thinking.jsonl`),
};
 
const HEAD = 400;   // 本文の先頭に残す文字数
const TAIL = 200;   // 本文の末尾に残す文字数
 
// 中間を落として、落とした量を明示する
function clip(text) {
  if (typeof text !== 'string' || text.length <= HEAD + TAIL) return text;
  const dropped = text.length - HEAD - TAIL;
  return `${text.slice(0, HEAD)}\n…[${dropped} chars clipped]…\n${text.slice(-TAIL)}`;
}
 
// 骨格に入れる種別。ここは削らない
const SKELETON_TYPES = new Set([
  'system', 'result', 'tool_use', 'tool_result', 'subagent_start', 'subagent_stop',
]);
 
let failed = false;
const rl = createInterface({ input: process.stdin, crlfDelay: Infinity });
 
for await (const line of rl) {
  if (!line.trim()) continue;
  let ev;
  try {
    ev = JSON.parse(line);
  } catch {
    // 壊れた行こそ後で効くので、骨格に生のまま逃がす
    out.skeleton.write(JSON.stringify({ type: 'parse_error', raw: line.slice(0, 500) }) + '\n');
    continue;
  }
 
  if (ev.type === 'result' && ev.subtype !== 'success') failed = true;
  if (ev.is_error === true) failed = true;
 
  if (SKELETON_TYPES.has(ev.type)) {
    out.skeleton.write(JSON.stringify(ev) + '\n');
    continue;
  }
 
  const blocks = ev.message?.content ?? [];
  for (const b of blocks) {
    const base = {
      ts: ev.timestamp ?? new Date().toISOString(),
      session_id: ev.session_id,
      parent_tool_use_id: ev.parent_tool_use_id ?? null,
    };
    if (b.type === 'thinking') {
      out.thinking.write(JSON.stringify({ ...base, thinking: b.thinking }) + '\n');
    } else if (b.type === 'text') {
      out.body.write(JSON.stringify({ ...base, text: clip(b.text) }) + '\n');
    }
  }
}
 
// 終了コードが分かってから、思考の扱いを決める
for (const s of Object.values(out)) s.end();
if (!failed) {
  rmSync(`${dir}/thinking.jsonl`, { force: true });
  console.error(`[log] ${runId}: success — thinking を破棄しました`);
} else {
  console.error(`[log] ${runId}: failed — thinking を保持しました`);
}

# 骨格から、親のTask呼び出しを一覧する
jq -r 'select(.type=="tool_use" and .name=="Task")
       | [.id, (.input.description // "-")] | @tsv' logs/$RUN/skeleton.jsonl
 
# 特定のサブエージェントの本文だけを時系列で追う
jq -r --arg id "$TOOL_USE_ID" \
   'select(.parent_tool_use_id==$id) | "\(.ts) \(.text)"' logs/$RUN/body.jsonl

// 相関IDが欠けた行を、直近の親Task呼び出しに寄せる
function attachFallbackParent(events) {
  let lastTaskId = null;
  return events.map((ev) => {
    if (ev.type === 'tool_use' && ev.name === 'Task') lastTaskId = ev.id;
    if (ev.parent_tool_use_id == null && lastTaskId) {
      return { ...ev, parent_tool_use_id: lastTaskId, parent_inferred: true };
    }
    return ev;
  });
}

# 1回目は骨格のみ。失敗したら思考込みで再現を試みる
claude -p "$PROMPT" --output-format stream-json > run1.jsonl || \
claude -p "$PROMPT" --output-format stream-json --forward-subagent-text > run2.jsonl