Function writePackStream

src/packFileSerializer.ts:1557–1684

(
  packFiles: NewPackedFile[],
  path: string,
  existingPackToAppend?: Pack,
  dependencyPacks: string[] = [],
)

};
// Stream-based version of writePack with better performance for large files
export const writePackStream = async (
  packFiles: NewPackedFile[],
  path: string,
  existingPackToAppend?: Pack,
  dependencyPacks: string[] = [],
) => {
  let streamWriter: StreamWriter | undefined;
  const timestamp = format(new Date(), "ddMMyy_HHmmss");
  const outPath = existingPackToAppend ? `${path}_${timestamp}` : path;
  try {
    const header = gameToPackHeader[appData.currentGame];
    const byteMask = 3;
    const refFileCount = 0;
    if (packFiles.length < 1) return;
    streamWriter = new StreamWriter(outPath);
    ensurePackFilesReadyForWrite(packFiles);
    const allPackFiles = existingPackToAppend
      ? [
          ...packFiles,
          ...existingPackToAppend.packedFiles.map(
            (pf) =>
              ({
                name: pf.name,
                file_size: pf.file_size,
                readBuffer: true,
              }) as NewPackedFile,
          ),
        ]
      : packFiles;
    allPackFiles.sort((firstPf, secondPf) => {
      return firstPf.name.localeCompare(secondPf.name);
    });
    // Use existing dependency packs if not provided
    const finalDependencyPacks =
      dependencyPacks.length > 0 ? dependencyPacks : existingPackToAppend?.dependencyPacks || [];
    // Calculate pack_file_index_size based on dependency packs
    const pack_file_index_size = finalDependencyPacks.reduce(
      (acc, dep) => acc + Buffer.byteLength(dep, "utf8") + 1,
      0,
    );
    const index_size = allPackFiles.reduce((acc, pack) => acc + new Blob([pack.name]).size + 1 + 5, 0);
    // Use StreamWriter to batch header writes with backpressure handling
    streamWriter.addString(header);
    streamWriter.addInt32(byteMask);
    streamWriter.addInt32(refFileCount);
    streamWriter.addInt32(pack_file_index_size);
    streamWriter.addInt32(allPackFiles.length);
    streamWriter.addInt32(index_size);
    streamWriter.addInt32(0x7fffffff); // header_buffer
    await streamWriter.flush();
    // Write dependency packs
    for (const dep of finalDependencyPacks) {
      streamWriter.addString(dep);
      streamWriter.addInt8(0);
    }
    await streamWriter.flush();
    // Write file index with stream batching
    for (const packFile of allPackFiles) {