Function writeBundle

packages/cli/src/diagnose/bundle.ts:503–563

(opts: WriteBundleOpts)

}

export async function writeBundle(opts: WriteBundleOpts): Promise<string> {
  const { collected, outputPath } = opts;
  const parent = dirname(outputPath);
  if (!existsSync(parent)) {
    throw new Error(
      `ok diagnose bundle: parent directory does not exist: ${parent}. ` +
        'Create it or pass --out with an existing parent.',
    );
  }

  if (collected.redactionMapPayload !== null) {
    const sidecarName = `${basename(outputPath, '.zip')}.docnames.json`;
    const stampedManifest: BundleManifest = {
      ...collected.manifest,
      redaction: {
        ...collected.manifest.redaction,
        applied: true,
        docNameMapSidecar: sidecarName,
      },
    };
    writeFileSync(
      join(collected.stagingDir, 'manifest.json'),
      `${JSON.stringify(stampedManifest, null, 2)}\n`,
    );
  }

  const zipfile = new ZipFile();
  const absStagedFiles = walkStagedFiles(collected.stagingDir);
  for (const absPath of absStagedFiles) {
    const relPath = relativeZipPath(collected.stagingDir, absPath);
    zipfile.addFile(absPath, relPath);
  }
  zipfile.end();

  if (collected.redactionMapPayload !== null) {
    const sidecarName = `${basename(outputPath, '.zip')}.docnames.json`;
    const sidecarPath = join(parent, sidecarName);
    writeFileSync(
      sidecarPath,
      `${JSON.stringify(
        {
          docNameMap: collected.redactionMapPayload.docNameMap,
          docNameCollisions: collected.redactionMapPayload.docNameCollisions,
        },
        null,
        2,
      )}\n`,
      { mode: 0o600 },
    );
  }

  const writer = createWriteStream(outputPath);
  zipfile.outputStream.pipe(writer);
  await new Promise<void>((resolveWait, rejectWait) => {
    writer.on('close', resolveWait);
    writer.on('error', rejectWait);
    zipfile.outputStream.on('error', rejectWait);
  });