Function writeBundle

src/lib/bundle.ts:388–478

(
  ctx: CliFailureContext,
  options: WriteBundleOptions,
)

 * → 10 by default; the original ApiError is preserved when applicable).
 */
export async function writeBundle(
  ctx: CliFailureContext,
  options: WriteBundleOptions,
): Promise<WriteBundleResult> {
  const requestId = options.requestId ?? 'local';
  assertContextIntegrity(ctx, requestId);

  const filtered = options.failedOnly ? applyFailedOnly(ctx) : ctx;
  // Re-check after filtering — in theory a buggy filter could leave a
  // mismatched evidence list. Cheap defense-in-depth.
  assertContextIntegrity(filtered, requestId);

  const dir = resolveBundleDir(options.dir);
  const fetchImpl = options.fetchImpl ?? globalThis.fetch.bind(globalThis);
  const meta = buildMeta(filtered);
  const codeExt = pickCodeExtension(filtered.code.language, filtered.code.framework);

  await mkdir(dir, { recursive: true });
  // Fresh `.tmp/` each run. A previous SIGKILL'd run can leave bytes
  // behind; we don't want to mix them with the new fetch.
  const tmpDir = await freshTmpDir(dir);
  const stepsTmpDir = join(tmpDir, 'steps');
  await mkdir(stepsTmpDir, { recursive: true });

  const filesWritten: string[] = [];

  try {
    // result.json + failure.json + code.<ext> are local writes; no
    // network, no streaming.
    await writeFile(
      join(tmpDir, 'result.json'),
      JSON.stringify(filtered.result, null, 2) + '\n',
      'utf8',
    );
    filesWritten.push('result.json');

    await writeFile(
      join(tmpDir, 'failure.json'),
      JSON.stringify(filtered.failure, null, 2) + '\n',
      'utf8',
    );
    filesWritten.push('failure.json');

    const codeFile = `code.${codeExt}`;
    if (isPresignedUrl(filtered.code.code)) {
      // §6.3 alt: when the `code` field is a presigned URL (>= 100 KB
      // bodies), stream the URL into the file rather than embedding
      // the URL in code.<ext>. M2's backend hasn't shipped the
      // >=100KB branch yet, but the contract supports it.
      await streamUrlToFile(filtered.code.code, join(tmpDir, codeFile), fetchImpl);
    } else {
      await writeFile(join(tmpDir, codeFile), filtered.code.code, 'utf8');
    }
    filesWritten.push(codeFile);

    // Optional video. Wire field is `result.videoUrl` (not in `failure`),
    // and the CLI surfaces it as a top-level on-disk artifact for agent
    // ergonomics — the agent doesn't have to know which sub-object held