use lopdf::{Document, SaveOptions, Object};
fn main() {
println!("Final Object Stream Compression Test\n");
println!("{}", "=".repeat(60));
let mut doc = Document::with_version("1.5");
let font1 = doc.add_object(lopdf::dictionary! {
"Type" => "Font",
"Subtype" => "Type1",
"BaseFont" => "Helvetica"
});
let font2 = doc.add_object(lopdf::dictionary! {
"Type" => "Font",
"Subtype" => "Type1",
"BaseFont" => "Times-Roman"
});
let page_id = doc.add_object(lopdf::dictionary! {
"Type" => "Page",
"MediaBox" => vec![0.into(), 0.into(), 612.into(), 792.into()],
"Contents" => lopdf::Object::Array(vec![]),
"Resources" => lopdf::dictionary! {
"Font" => lopdf::dictionary! {
"F1" => font1,
"F2" => font2
}
}
});
let pages_id = doc.add_object(lopdf::dictionary! {
"Type" => "Pages",
"Kids" => vec![page_id.into()],
"Count" => 1
});
let catalog_id = doc.add_object(lopdf::dictionary! {
"Type" => "Catalog",
"Pages" => pages_id
});
doc.trailer.set("Root", catalog_id);
for i in 0..10 {
doc.add_object(lopdf::dictionary! {
"Type" => "Annot",
"Subtype" => "Text",
"Contents" => format!("Annotation {}", i)
});
}
println!("Created test document with:");
println!(" - 2 Font objects (should be compressed)");
println!(" - 1 Page object (should NOT be compressed)");
println!(" - 1 Pages object (should NOT be compressed)");
println!(" - 1 Catalog object (should NOT be compressed)");
println!(" - 10 Annotation objects (should be compressed)");
let options = SaveOptions {
use_object_streams: true,
use_xref_streams: true,
..Default::default()
};
let mut buffer = Vec::new();
doc.save_with_options(&mut buffer, options).unwrap();
println!("\nSaved with object streams: {} bytes", buffer.len());
let loaded = Document::load_mem(&buffer).unwrap();
println!("\nAnalyzing saved document:");
println!(" Total objects: {}", loaded.objects.len());
let mut obj_stream_count = 0;
let mut compressed_count = 0;
for (_id, obj) in &loaded.objects {
if let Object::Stream(stream) = obj {
if let Ok(type_obj) = stream.dict.get(b"Type") {
if let Ok(type_name) = type_obj.as_name() {
if type_name == b"ObjStm" {
obj_stream_count += 1;
if let Ok(n) = stream.dict.get(b"N").and_then(|o| o.as_i64()) {
compressed_count += n as usize;
}
}
}
}
}
}
println!(" Object streams: {}", obj_stream_count);
println!(" Compressed objects: {}", compressed_count);
println!("\nVerifying critical objects:");
if let Ok(root_ref) = loaded.trailer.get(b"Root") {
if let Object::Reference(cat_id) = root_ref {
check_not_compressed(&loaded, *cat_id, "Catalog");
}
}
if let Ok(catalog) = loaded.catalog() {
if let Ok(pages_ref) = catalog.get(b"Pages") {
if let Object::Reference(pages_id) = pages_ref {
check_not_compressed(&loaded, *pages_id, "Pages tree");
}
}
}
let pages = loaded.get_pages();
for (num, &page_id) in pages.iter() {
check_not_compressed(&loaded, page_id, &format!("Page {}", num));
}
println!("\n{}", "=".repeat(60));
println!("Test complete! Object streams are working correctly.");
}
fn check_not_compressed(doc: &Document, id: (u32, u16), name: &str) {
if let Some(xref_entry) = doc.reference_table.get(id.0) {
match xref_entry {
lopdf::xref::XrefEntry::Normal { .. } => {
println!(" ✓ {} is NOT compressed", name);
}
lopdf::xref::XrefEntry::Compressed { container, index } => {
println!(" ✗ ERROR: {} is compressed in stream {} at index {}!", name, container, index);
}
_ => {}
}
}
}