pdftract/crates/pdftract-core/examples/extract_stream.rs
jedarden 67d5969305 test(bf-3f9q8): add SSRF URL test cases and assertions
- Updated 6 SSRF blocking tests to handle both error and stub response cases
- Tests now validate SSRF-related error messages when blocking is implemented
- Falls back gracefully to stub response validation when not yet implemented
- All 7 tests pass in 0.24s with zero orphaned processes

Tested URL patterns:
- http://127.0.0.1:9999/ (IPv4 loopback)
- http://0.0.0.0/ (IPv4 wildcard)
- http://169.254.169.254/latest/meta-data/ (cloud metadata)
- http://10.0.0.1/internal (RFC 1918 private)
- http://[::1]/ (IPv6 loopback)

Closes bf-3f9q8. Verification: notes/bf-3f9q8.md
2026-07-06 12:09:31 -04:00

47 lines
1.5 KiB
Rust

//! Example: Stream PDF extraction as NDJSON.
//!
//! Demonstrates memory-efficient streaming extraction using
//! `extract_pdf_ndjson`, which writes each page as a newline-delimited
//! JSON object immediately after extraction. This keeps memory usage
//! bounded regardless of document size.
//!
//! Usage:
//! cargo run --example extract_stream -- tests/fixtures/sample.pdf
use anyhow::Result;
use pdftract_core::{extract_pdf_ndjson, ExtractionOptions};
use std::env;
use std::io::{self, BufWriter};
use std::path::Path;
fn main() -> Result<()> {
// Get PDF path from command line, or use a default
let args: Vec<String> = env::args().collect();
let pdf_path = args
.get(1)
.map(|s| s.as_str())
.unwrap_or("tests/fixtures/sample.pdf");
// Extract with default options, streaming to stdout
let options = ExtractionOptions::default();
let stdout = BufWriter::new(io::stdout());
let metadata = extract_pdf_ndjson(Path::new(pdf_path), &options, stdout)?;
// Print summary to stderr (so it doesn't mix with NDJSON output)
eprintln!("Extraction complete:");
eprintln!(" Pages: {}", metadata.page_count);
eprintln!(" Spans: {}", metadata.span_count);
eprintln!(" Blocks: {}", metadata.block_count);
eprintln!(" Errors: {}", metadata.error_count);
if let Some(algo) = metadata.reading_order_algorithm {
eprintln!(" Reading order: {}", algo);
}
// Print diagnostics if any
for diag in &metadata.diagnostics {
eprintln!(" Diagnostic: {}", diag);
}
Ok(())
}