refactor: improve file splitting performance and code quality
- Use BytesIO for size checking instead of temporary disk writes (major performance improvement) - Add constant and comment for PDF overhead multiplier in tests - Address code review feedback Co-authored-by: christianlouis <361235+christianlouis@users.noreply.github.com>
This commit is contained in:
+10
-13
@@ -5,6 +5,7 @@ This module provides functionality to split PDF files that exceed a certain size
|
||||
into smaller chunks for processing. Used when MAX_SINGLE_FILE_SIZE is configured.
|
||||
"""
|
||||
|
||||
import io
|
||||
import logging
|
||||
import os
|
||||
from typing import List, Optional
|
||||
@@ -74,18 +75,15 @@ def split_pdf_by_size(pdf_path: str, max_size_bytes: int, output_dir: Optional[s
|
||||
current_writer.add_page(page)
|
||||
current_page_count += 1
|
||||
|
||||
# Write to temporary file to check size
|
||||
temp_output_path = os.path.join(output_dir, f"{base_name}_part{part_number}_temp.pdf")
|
||||
with open(temp_output_path, "wb") as temp_file:
|
||||
current_writer.write(temp_file)
|
||||
|
||||
temp_size = os.path.getsize(temp_output_path)
|
||||
# Check size in memory without writing to disk (performance optimization)
|
||||
temp_buffer = io.BytesIO()
|
||||
current_writer.write(temp_buffer)
|
||||
temp_size = temp_buffer.tell() # Get the size of the buffer
|
||||
temp_buffer.close()
|
||||
|
||||
# If adding this page exceeds the limit (and we have more than 1 page in current chunk)
|
||||
# save the previous chunk and start a new one
|
||||
if temp_size > max_size_bytes and current_page_count > 1:
|
||||
# Remove the temporary file
|
||||
os.remove(temp_output_path)
|
||||
|
||||
# Create a new writer without the last page
|
||||
previous_writer = PdfWriter()
|
||||
@@ -112,18 +110,17 @@ def split_pdf_by_size(pdf_path: str, max_size_bytes: int, output_dir: Optional[s
|
||||
f"Single page (page {page_num + 1}) exceeds size limit "
|
||||
f"({temp_size} > {max_size_bytes}). Keeping as separate file."
|
||||
)
|
||||
# Rename temp file to final name
|
||||
# Save this single page as a separate chunk
|
||||
output_path = os.path.join(output_dir, f"{base_name}_part{part_number}.pdf")
|
||||
os.rename(temp_output_path, output_path)
|
||||
with open(output_path, "wb") as output_file:
|
||||
current_writer.write(output_file)
|
||||
output_files.append(output_path)
|
||||
|
||||
# Start new chunk
|
||||
part_number += 1
|
||||
current_writer = PdfWriter()
|
||||
current_page_count = 0
|
||||
else:
|
||||
# Size is OK, remove temp file and continue
|
||||
os.remove(temp_output_path)
|
||||
# else: Size is OK, continue adding pages to current chunk
|
||||
|
||||
# Save the last chunk if it has any pages
|
||||
if current_page_count > 0:
|
||||
|
||||
@@ -79,11 +79,13 @@ class TestSplitPdfBySize:
|
||||
|
||||
# If we got more than 1 file, verify each file is under the limit (with some margin for PDF overhead)
|
||||
if len(split_files) > 1:
|
||||
# PDF_OVERHEAD_MULTIPLIER: PDFs have structural overhead (headers, metadata, compression)
|
||||
# that can cause files to exceed the target size by ~20-50%. We allow 1.5x (50%) margin.
|
||||
PDF_OVERHEAD_MULTIPLIER = 1.5
|
||||
for split_file in split_files:
|
||||
# Allow some overhead for PDF structure (up to 50% over limit)
|
||||
assert (
|
||||
os.path.getsize(split_file) <= max_size * 1.5
|
||||
), f"Split file {split_file} should respect size limit"
|
||||
os.path.getsize(split_file) <= max_size * PDF_OVERHEAD_MULTIPLIER
|
||||
), f"Split file {split_file} should respect size limit (with PDF overhead allowance)"
|
||||
|
||||
# Cleanup split files
|
||||
for split_file in split_files:
|
||||
|
||||
Reference in New Issue
Block a user