Function detectCompressionFormat

src/utils/compression.ts:133–147

(
  filePath: string,
)

}

export const detectCompressionFormat = async (
  filePath: string,
): Promise<CompressionFormat | undefined> => {
  const extensionFormat = getCompressionFormatFromExtension(filePath)
  const header = await readFileHeader(filePath)
  const headerFormat = getCompressionFormatFromHeader(header)

  if (extensionFormat && headerFormat && extensionFormat !== headerFormat) {
    throw new Error(
      `Compression mismatch for ${filePath}: extension suggests ${extensionFormat} but header is ${headerFormat}.`,
    )
  }

  return headerFormat ?? extensionFormat
}

export const createCompressionStream = (
  format?: CompressionFormat,