Function packageEntries

apps/kimi-code/src/feedback/codebase/packager.ts:34–85

(
  entries: readonly PackageEntry[],
  archivePath: string,
)

}

async function packageEntries(
  entries: readonly PackageEntry[],
  archivePath: string,
): Promise<FeedbackArchive> {
  if (entries.length === 0) {
    throw new Error('Cannot package an empty feedback archive.');
  }
  await mkdir(dirname(archivePath), { recursive: true });

  const zip = new ZipFile();
  const hash = createHash('sha256');
  const output = createWriteStream(archivePath);

  try {
    const done = new Promise<void>((resolvePromise, rejectPromise) => {
      output.on('finish', resolvePromise);
      output.on('error', rejectPromise);
      zip.outputStream.on('error', rejectPromise);
    });

    zip.outputStream.on('data', (chunk: Buffer) => {
      hash.update(chunk);
    });
    zip.outputStream.pipe(output);

    for (const entry of entries) {
      zip.addFile(entry.absolutePath, entry.archivePath, {
        mtime: new Date(entry.mtimeMs),
        mode: 0o100644,
      });
    }
    zip.end();
    await done;

    const archiveStat = await stat(archivePath);
    return {
      path: archivePath,
      size: archiveStat.size,
      sha256: hash.digest('hex'),
      fingerprint: fingerprintEntries(entries),
      fileCount: entries.length,
    };
  } catch (error) {
    // A failed zip (e.g. a source file vanished or became unreadable between
    // scan and packaging) would otherwise leave a partial archive behind in
    // the cache dir. Destroy the stream so the handle is released before we
    // remove the file, then best-effort delete it.
    output.destroy();
    await rm(archivePath, { force: true }).catch(() => {});
    throw error;
  }
}

function fingerprintEntries(entries: readonly PackageEntry[]): string {
  const hash = createHash('sha256');