docling_core/markdown.rs
1//! Markdown serializer for [`DoclingDocument`].
2
3use crate::document::{DoclingDocument, Node, Table};
4
5/// How pictures are rendered (mirrors docling-core's `ImageRefMode`).
6#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
7pub enum ImageMode {
8 /// `<!-- image -->` (docling's default, and the only mode without image data).
9 #[default]
10 Placeholder,
11 /// `` — self-contained.
12 Embedded,
13 /// ``; the bytes are returned for the
14 /// caller to write.
15 Referenced,
16}
17
18/// Serializer state threaded through the render walk.
19struct Ctx {
20 strict: bool,
21 /// Emit compact `| a | b |` tables instead of the padded GitHub serializer.
22 compact_tables: bool,
23 images: ImageMode,
24 artifacts_dir: String,
25 /// (relative path, bytes) for each referenced image — written by the caller.
26 artifacts: Vec<(String, Vec<u8>)>,
27 pic_index: usize,
28 /// Rendering the block content of a rich table cell (docling-core 2.94's
29 /// `in_table_cell`, docling-core#540): a heading has no valid Markdown
30 /// form inside a table, so it renders as plain text without `#` markers.
31 in_table_cell: bool,
32}
33
34/// Render a document to a Markdown string (pictures as placeholders).
35///
36/// `strict` selects the serializer-level behaviours that differ between
37/// docling-legacy output and cleaner Markdown — currently the code-fence
38/// language (legacy drops it, strict keeps it).
39pub fn to_markdown(doc: &DoclingDocument, strict: bool) -> String {
40 to_markdown_images(doc, strict, ImageMode::Placeholder, "artifacts").0
41}
42
43/// Render to Markdown with an explicit picture [`ImageMode`]. Returns the
44/// Markdown and, for [`ImageMode::Referenced`], the `(path, bytes)` of each image
45/// the caller should write (relative to the Markdown file).
46pub fn to_markdown_images(
47 doc: &DoclingDocument,
48 strict: bool,
49 images: ImageMode,
50 artifacts_dir: &str,
51) -> (String, Vec<(String, Vec<u8>)>) {
52 let mut ctx = Ctx {
53 strict,
54 compact_tables: doc.compact_tables,
55 images,
56 artifacts_dir: artifacts_dir.to_string(),
57 artifacts: Vec::new(),
58 pic_index: 0,
59 in_table_cell: false,
60 };
61 let mut blocks: Vec<String> = Vec::new();
62 render(&doc.nodes, &mut blocks, &mut ctx);
63 let mut body = blocks.join("\n\n");
64 // Strict mode only: turn recovered source hyperlinks into Markdown links.
65 // docling's standard pipeline drops them, so doing this in legacy mode would
66 // diverge from docling — hence strict-only, leaving conformance output intact.
67 if strict && !doc.links.is_empty() {
68 body = apply_links(&body, &doc.links);
69 }
70 let md = if body.is_empty() {
71 String::new()
72 } else {
73 format!("{body}\n")
74 };
75 (md, ctx.artifacts)
76}
77
78/// Render the block content of a *rich table cell* to Markdown — what
79/// docling-core's table serializer does for a `RichTableCell`
80/// (`doc_serializer.serialize(item, in_table_cell=True)`): the cell's
81/// paragraphs, lists and flattened nested tables render as in a document, but a
82/// heading loses its `#` markers (docling-core#540 — the Markdown spec has no
83/// headings inside tables). Pictures stay placeholders. The caller flattens the
84/// result into its cell text; the table serializer later turns the newlines
85/// into spaces.
86pub fn to_markdown_table_cell(doc: &DoclingDocument, strict: bool) -> String {
87 let mut ctx = Ctx {
88 strict,
89 compact_tables: doc.compact_tables,
90 images: ImageMode::Placeholder,
91 artifacts_dir: String::new(),
92 artifacts: Vec::new(),
93 pic_index: 0,
94 in_table_cell: true,
95 };
96 let mut blocks: Vec<String> = Vec::new();
97 render(&doc.nodes, &mut blocks, &mut ctx);
98 blocks.join("\n\n")
99}
100
101/// Wrap each recovered link's anchor text in Markdown `[anchor](href)`. Anchors
102/// arrive cleaned (curly quotes/dashes already normalized) but un-escaped, so we
103/// match against the body's HTML-escaped (`&`/`<`/`>`) form, the way prose nodes
104/// were serialized. Links are consumed in document order from a moving cursor, so
105/// a repeated anchor (e.g. two "issues") links its successive occurrences rather
106/// than all pointing at the first. An anchor that can't be located is skipped
107/// (its text may have been split across a line wrap or table cell).
108fn apply_links(body: &str, links: &[(String, String)]) -> String {
109 let mut out = body.to_string();
110 let mut cursor = 0usize;
111 for (anchor, href) in links {
112 let anchor = anchor
113 .replace('&', "&")
114 .replace('<', "<")
115 .replace('>', ">");
116 if anchor.is_empty() {
117 continue;
118 }
119 if let Some(rel) = out[cursor..].find(&anchor) {
120 let at = cursor + rel;
121 // Don't relink inside an already-emitted `](` Markdown link target.
122 let replacement = format!("[{anchor}]({href})");
123 out.replace_range(at..at + anchor.len(), &replacement);
124 cursor = at + replacement.len();
125 }
126 }
127 out
128}
129
130/// Like [`apply_links`] but over a single chunk, consuming from a shared queue so
131/// the same `[anchor](href)` rewriting can be applied incrementally as Markdown is
132/// streamed out. Each queued link is matched (in document order) against `chunk`
133/// and rewritten in place; a link whose anchor is not in this chunk is carried
134/// forward in the queue for a later chunk. Anchors are recovered in document
135/// order and a chunk is always a contiguous run of whole blocks, so this
136/// reproduces [`apply_links`]' single moving cursor: the link lands in whichever
137/// chunk contains its anchor, identically to the buffered path. (A link whose
138/// anchor never appears is carried to the end and dropped — the same no-op
139/// `apply_links` performs for an unlocatable anchor.)
140fn apply_links_chunk(chunk: &str, queue: &mut Vec<(String, String)>) -> String {
141 let mut out = chunk.to_string();
142 let mut cursor = 0usize;
143 let mut carried: Vec<(String, String)> = Vec::new();
144 for (anchor_raw, href) in std::mem::take(queue) {
145 let anchor = anchor_raw
146 .replace('&', "&")
147 .replace('<', "<")
148 .replace('>', ">");
149 if anchor.is_empty() {
150 continue;
151 }
152 if let Some(rel) = out[cursor..].find(&anchor) {
153 let at = cursor + rel;
154 let replacement = format!("[{anchor}]({href})");
155 out.replace_range(at..at + anchor.len(), &replacement);
156 cursor = at + replacement.len();
157 } else {
158 // Not in this chunk; try again when its block is flushed.
159 carried.push((anchor_raw, href));
160 }
161 }
162 *queue = carried;
163 out
164}
165
166/// Incremental Markdown serializer: feed finalized, in-document-order batches of
167/// [`Node`]s and receive Markdown chunks whose concatenation is **byte-identical**
168/// to [`to_markdown_images`] over the same nodes. This is the streaming
169/// counterpart of the buffered serializer — used to emit a document's Markdown in
170/// chunks (e.g. page by page, as the parallel PDF pipeline finishes pages) instead
171/// of building the whole string up front.
172///
173/// [`ImageMode::Placeholder`] and [`ImageMode::Embedded`] render inline.
174/// [`ImageMode::Referenced`] additionally hands each picture's bytes out through
175/// [`take_artifacts`](Self::take_artifacts) — construct with
176/// [`with_artifacts`](Self::with_artifacts) and drain after every push so the
177/// bytes can be written to disk as pages finish instead of accumulating for the
178/// whole document (issue #80's memory-bounded image handling).
179///
180/// Each [`push`](Self::push) must contain whole blocks in reading order: a caller
181/// must not split a run of list items across two pushes (the run would render as
182/// two separate lists). Finalized PDF page batches already satisfy this.
183pub struct MarkdownStreamer {
184 strict: bool,
185 images: ImageMode,
186 compact_tables: bool,
187 /// Whether any non-empty chunk has been emitted yet (drives `\n\n` joins and
188 /// the trailing newline).
189 emitted_any: bool,
190 /// Recovered links not yet placed (strict mode), consumed in document order.
191 links: Vec<(String, String)>,
192 /// Referenced mode: the link prefix, the not-yet-drained `(path, bytes)`
193 /// artifacts, and the running image number (continues across pushes so the
194 /// stream matches the buffered serializer's `image_000000…` numbering).
195 artifacts_dir: String,
196 artifacts: Vec<(String, Vec<u8>)>,
197 pic_index: usize,
198}
199
200impl MarkdownStreamer {
201 /// Create a streamer. `compact_tables` mirrors [`DoclingDocument::compact_tables`].
202 /// For [`ImageMode::Referenced`] use [`with_artifacts`](Self::with_artifacts).
203 pub fn new(strict: bool, images: ImageMode, compact_tables: bool) -> Self {
204 debug_assert!(
205 images != ImageMode::Referenced,
206 "referenced image mode needs an artifacts dir; use with_artifacts"
207 );
208 Self::with_artifacts(strict, images, compact_tables, "artifacts")
209 }
210
211 /// Like [`new`](Self::new) but with the artifacts link prefix, allowing
212 /// [`ImageMode::Referenced`]: pictures render as
213 /// `` and each push's image
214 /// bytes wait in [`take_artifacts`](Self::take_artifacts) for the caller to
215 /// write. The concatenated chunks and the artifact list match the buffered
216 /// [`to_markdown_images`] byte-for-byte.
217 pub fn with_artifacts(
218 strict: bool,
219 images: ImageMode,
220 compact_tables: bool,
221 artifacts_dir: &str,
222 ) -> Self {
223 Self {
224 strict,
225 images,
226 compact_tables,
227 emitted_any: false,
228 links: Vec::new(),
229 artifacts_dir: artifacts_dir.to_string(),
230 artifacts: Vec::new(),
231 pic_index: 0,
232 }
233 }
234
235 /// The `(relative path, bytes)` of images rendered by pushes since the last
236 /// drain ([`ImageMode::Referenced`] only — empty otherwise). Paths are
237 /// relative to the Markdown file, i.e. they start with the configured
238 /// artifacts dir.
239 pub fn take_artifacts(&mut self) -> Vec<(String, Vec<u8>)> {
240 std::mem::take(&mut self.artifacts)
241 }
242
243 /// Render one finalized batch of nodes (plus any links recovered from the same
244 /// span, in document order) into the next Markdown chunk. Returns an empty
245 /// string when the batch produces no output (e.g. empty tables/pictures), in
246 /// which case nothing should be written.
247 pub fn push(&mut self, nodes: &[Node], links: &[(String, String)]) -> String {
248 self.links.extend(links.iter().cloned());
249 let mut ctx = Ctx {
250 strict: self.strict,
251 compact_tables: self.compact_tables,
252 images: self.images,
253 artifacts_dir: std::mem::take(&mut self.artifacts_dir),
254 artifacts: std::mem::take(&mut self.artifacts),
255 pic_index: self.pic_index,
256 in_table_cell: false,
257 };
258 let mut blocks: Vec<String> = Vec::new();
259 render(nodes, &mut blocks, &mut ctx);
260 self.artifacts_dir = std::mem::take(&mut ctx.artifacts_dir);
261 self.artifacts = std::mem::take(&mut ctx.artifacts);
262 self.pic_index = ctx.pic_index;
263 if blocks.is_empty() {
264 return String::new();
265 }
266 let mut body = blocks.join("\n\n");
267 if self.strict && !self.links.is_empty() {
268 body = apply_links_chunk(&body, &mut self.links);
269 }
270 let chunk = if self.emitted_any {
271 format!("\n\n{body}")
272 } else {
273 body
274 };
275 self.emitted_any = true;
276 chunk
277 }
278
279 /// Emit the trailing newline that finishes the document (empty if no content
280 /// was produced). Call exactly once, after the final [`push`](Self::push).
281 pub fn finish(self) -> String {
282 if self.emitted_any {
283 "\n".to_string()
284 } else {
285 String::new()
286 }
287 }
288}
289
290/// In `strict` mode, rewrite inline text for readability rather than byte-for-byte
291/// docling fidelity: undo the legacy `\_` underscore escaping, and tighten stray
292/// spaces around punctuation (`[ 37 , 36 ]` → `[37, 36]`, `( x )` → `(x)`). This
293/// cleans up both the PDF backend's glyph-split spacing and the space the legacy
294/// emphasis serialization leaves before punctuation (`*a* ,` → `*a*,`).
295/// Legacy/default output keeps docling's spacing untouched. Only inline text
296/// nodes pass through here — code blocks and table cells are left alone.
297fn strict_text(text: &str, strict: bool) -> String {
298 if !strict {
299 return text.to_string();
300 }
301 text.replace("\\_", "_")
302 .replace(" ,", ",")
303 .replace(" .", ".")
304 .replace(" ;", ";")
305 .replace(" )", ")")
306 .replace("( ", "(")
307 .replace(" ]", "]")
308 .replace("[ ", "[")
309}
310
311/// docling-core 2.92's `_md_line_breaks` (docling-core#721): a single `\n`
312/// inside an item's text becomes a GFM hard line break (`" \n"`, two trailing
313/// spaces) so renderers honour it; a blank line (`\n\n`) is a paragraph break
314/// and stays as is — the document scope already joins blocks with `\n\n`.
315/// Applied to body text, list items and captions, never to code/formulas.
316fn md_line_breaks(text: &str) -> String {
317 if !text.contains('\n') {
318 return text.to_string();
319 }
320 text.split("\n\n")
321 .map(|para| para.replace('\n', " \n"))
322 .collect::<Vec<_>>()
323 .join("\n\n")
324}
325
326/// Undo [`md_line_breaks`] on a rich table cell's flattened Markdown so the
327/// non-Markdown exports (JSON `text`, LaTeX cells) see the cell's raw line
328/// breaks, as docling's do — a rich cell's text is its Markdown serialization
329/// in our model, and the two trailing spaces are a Markdown-only marker.
330pub(crate) fn strip_hard_breaks(text: &str) -> String {
331 if text.contains(" \n") {
332 text.replace(" \n", "\n")
333 } else {
334 text.to_string()
335 }
336}
337
338/// docling-core's `_heading_line_breaks`: a GFM heading cannot span lines, so a
339/// newline inside heading text collapses to a space (`# Hello World`, not a
340/// broken `# Hello\nWorld`).
341fn heading_line_breaks(text: &str) -> String {
342 text.replace('\n', " ")
343}
344
345fn render(nodes: &[Node], blocks: &mut Vec<String>, ctx: &mut Ctx) {
346 let mut i = 0;
347 while i < nodes.len() {
348 match &nodes[i] {
349 Node::ListItem { .. } => {
350 let start = i;
351 i += 1;
352 loop {
353 match nodes.get(i) {
354 Some(Node::ListItem { .. }) => i += 1,
355 // An empty paragraph between two list items is absorbed
356 // into the run — docling keeps such a ListGroup
357 // contiguous rather than splitting it.
358 Some(Node::Paragraph { text })
359 if text.is_empty()
360 && matches!(nodes.get(i + 1), Some(Node::ListItem { .. })) =>
361 {
362 i += 1
363 }
364 _ => break,
365 }
366 }
367 render_list_run(&nodes[start..i], blocks, ctx.strict);
368 }
369 other => {
370 render_one(other, blocks, ctx);
371 i += 1;
372 }
373 }
374 }
375}
376
377/// Render a contiguous run of list items.
378///
379/// Ordered items use their explicit `number`. A new sibling list (marked by
380/// `first_in_list`) at the same depth is separated by a blank line, matching
381/// docling-core's serializer.
382fn render_list_run(items: &[Node], blocks: &mut Vec<String>, strict: bool) {
383 let mut lines: Vec<String> = Vec::new();
384 // Per level, the previous item's (ordered, number) so we can detect a new
385 // sibling list.
386 let mut prev: Vec<Option<(bool, u64)>> = Vec::new();
387 // Whether the previous top-level item was a multilevel projection — an
388 // ordered `1.2.`-style item rendered as a Markdown bullet (docx's DocLang
389 // overlay says ordered, the flat field says bullet). Word numbers such an
390 // item and its parent-level successor within one list (same `numId`), and
391 // docling keeps them in one group — so the kind-flip / number-continuity
392 // breaks below must not fire across it (docling#3902's
393 // docx_list_blank_spacer: `- 1.2. Sub two` directly followed by
394 // `2. Second section`, no blank line).
395 let mut prev_projected = false;
396
397 for item in items {
398 let Node::ListItem {
399 ordered,
400 number,
401 first_in_list,
402 text,
403 level,
404 marker: _,
405 location: _,
406 dclx,
407 href: _,
408 layer,
409 } = item
410 else {
411 continue;
412 };
413 // A non-body (furniture) list item is omitted from Markdown, matching
414 // docling's content-layer filtering.
415 if layer.is_some() {
416 continue;
417 }
418 let level = *level as usize;
419
420 // Returning to a shallower level ends the deeper sibling lists.
421 prev.truncate(level + 1);
422 while prev.len() <= level {
423 prev.push(None);
424 }
425
426 // A new sibling list at the same depth gets a blank line: the kind flips
427 // (`<ul>`↔`<ol>`), an ordered run breaks (`1, 2` then `42`), or the
428 // backend flagged a fresh list (e.g. Markdown's bullet changing `-`→`*`).
429 // Only at the top level: nested sibling groups are children of a list
430 // item, and docling joins an item's children without blank lines.
431 let eff_ordered = dclx.as_ref().map_or(*ordered, |d| d.ordered);
432 if level == 0 {
433 if let Some((prev_ordered, prev_number)) = prev[level] {
434 // A projected predecessor suppresses both heuristics for an
435 // ordered successor: the flat kind flip is an artifact of the
436 // bullet projection, and the numbering continues the deeper
437 // sequence (`1.2.` → `2.`), not this level's.
438 let same_word_list = prev_projected && eff_ordered;
439 let new_list = *first_in_list
440 || (!same_word_list
441 && (prev_ordered != *ordered || (*ordered && *number != prev_number + 1)));
442 if new_list {
443 lines.push(String::new());
444 }
445 }
446 prev_projected = eff_ordered && !*ordered;
447 }
448
449 let indent = " ".repeat(level);
450 let marker = if *ordered {
451 format!("{number}.")
452 } else {
453 "-".to_string()
454 };
455 lines.push(format!("{indent}{marker} {}", list_item_text(text, strict)));
456 prev[level] = Some((*ordered, *number));
457 }
458
459 // A run consisting only of furniture (content-layer-filtered) items yields no
460 // lines; pushing an empty block here would surface as a stray blank line.
461 if !lines.is_empty() {
462 blocks.push(lines.join("\n"));
463 }
464}
465
466/// A list item's Markdown body. The GFM hard-line-break rule (docling-core#721)
467/// applies to the item's own text; pictures the HTML backend folded into the
468/// item (`"\n[alt\n]<!-- image -->"` per `<img>` inside the `<li>`) are
469/// docling's picture *children* of the item, which its serializer prints after
470/// the item line with plain newlines — so a folded tail keeps its newlines
471/// unmarked. The tail is recognised structurally: every line after the first is
472/// an image marker or an alt caption directly followed by one.
473fn list_item_text(text: &str, strict: bool) -> String {
474 let escaped = strict_text(text, strict);
475 if let Some((own, tail)) = escaped.split_once('\n') {
476 if is_folded_picture_tail(tail) {
477 return format!("{}\n{tail}", md_line_breaks(own));
478 }
479 }
480 md_line_breaks(&escaped)
481}
482
483fn is_folded_picture_tail(tail: &str) -> bool {
484 const MARKER: &str = "<!-- image -->";
485 let mut lines = tail.split('\n').peekable();
486 let mut any = false;
487 while let Some(line) = lines.next() {
488 if line == MARKER {
489 any = true;
490 } else if lines.next() == Some(MARKER) {
491 any = true; // an alt caption line, then its marker
492 } else {
493 return false;
494 }
495 }
496 any
497}
498
499fn render_one(node: &Node, blocks: &mut Vec<String>, ctx: &mut Ctx) {
500 match node {
501 Node::Heading { level, text } => {
502 let text = heading_line_breaks(&strict_text(text, ctx.strict));
503 if ctx.in_table_cell {
504 // docling-core#540: no `#` markers inside a table cell.
505 blocks.push(text);
506 } else {
507 let hashes = "#".repeat((*level).clamp(1, 6) as usize);
508 blocks.push(format!("{hashes} {text}"));
509 }
510 }
511 // An empty body paragraph (docling's blank-line text item) contributes
512 // nothing to Markdown — only DocLang/JSON keep it.
513 Node::Paragraph { text } if text.is_empty() => {}
514 Node::Paragraph { text } => blocks.push(md_line_breaks(&strict_text(text, ctx.strict))),
515 // A standalone caption item renders like a text item; its hyperlink
516 // annotation becomes a Markdown link around the whole caption.
517 Node::Caption { text, .. } if text.is_empty() => {}
518 Node::Caption { text, href } => {
519 let body = md_line_breaks(&strict_text(text, ctx.strict));
520 blocks.push(match href {
521 Some(url) => format!("[{body}]({url})"),
522 None => body,
523 });
524 }
525 Node::CheckboxItem { checked, text } => {
526 let mark = if *checked { "- [x] " } else { "- [ ] " };
527 blocks.push(md_line_breaks(&strict_text(
528 &format!("{mark}{text}"),
529 ctx.strict,
530 )));
531 }
532 Node::Code {
533 language,
534 text,
535 pretty,
536 ..
537 } => {
538 // Legacy docling never emits a language on the fence; strict keeps it.
539 let lang = match language {
540 Some(l) if ctx.strict => l.as_str(),
541 _ => "",
542 };
543 // Strict prefers the line-preserving rendering when the backend
544 // supplied one (PDF); legacy stays on docling's flat `text`.
545 let body = match pretty {
546 Some(p) if ctx.strict => p.as_str(),
547 _ => text.as_str(),
548 };
549 blocks.push(format!("```{lang}\n{body}\n```"));
550 }
551 // A CodeFormula-decoded display formula renders as docling's `$$…$$`
552 // (the un-enriched pipeline emits a placeholder paragraph instead).
553 Node::Formula { latex, .. } => blocks.push(format!("$${latex}$$")),
554 Node::Table(table) => {
555 // docling renders a table's caption as a text line before the grid.
556 // `caption` is already escaped (backend convention), like a paragraph.
557 if let Some(cap) = &table.caption {
558 if !cap.is_empty() {
559 blocks.push(md_line_breaks(&strict_text(cap, ctx.strict)));
560 }
561 }
562 let rendered = render_table(table, ctx.compact_tables);
563 if !rendered.is_empty() {
564 blocks.push(rendered);
565 }
566 }
567 // Classification predictions don't affect docling's Markdown output.
568 Node::Picture { caption, image, .. } => {
569 if let Some(cap) = caption {
570 if !cap.is_empty() {
571 blocks.push(md_line_breaks(cap));
572 }
573 }
574 blocks.push(picture_marker(image.as_ref(), ctx));
575 }
576 // A chart renders as docling's picture-with-meta markdown: the caption,
577 // the placeholder, the humanized classification ("line_chart" ->
578 // "Line chart"), then the chart's data grid as a regular table.
579 Node::Chart {
580 kind,
581 table,
582 caption,
583 ..
584 } => {
585 if let Some(cap) = caption {
586 if !cap.is_empty() {
587 blocks.push(md_line_breaks(cap));
588 }
589 }
590 blocks.push(picture_marker(None, ctx));
591 blocks.push(humanize_label(kind));
592 let rendered = render_table(table, false);
593 if !rendered.is_empty() {
594 blocks.push(rendered);
595 }
596 }
597 // A DocLang-only node is omitted from Markdown.
598 Node::DoclangOnly(_) => {}
599 // A group on a non-body layer (a hidden spreadsheet sheet) renders
600 // nothing, like every other non-body item.
601 Node::Group { layer: Some(_), .. } => {}
602 Node::Group { children, .. } => render(children, blocks, ctx),
603 Node::FieldRegion { items } => {
604 // The region container and each field item carry no text of their
605 // own; docling-core 2.93 (#724) serializes them to nothing (older
606 // releases emitted a `<!-- missing-text -->` marker for each), so
607 // only an item's marker/key/value appear, as separate paragraphs.
608 for item in items {
609 for part in [&item.marker, &item.key, &item.value].into_iter().flatten() {
610 blocks.push(md_line_breaks(&strict_text(part, ctx.strict)));
611 }
612 }
613 }
614 // A rich inline group renders exactly like a paragraph of its Markdown
615 // text — the structured runs are DocLang-only.
616 Node::InlineGroup { md_text, .. } => {
617 blocks.push(md_line_breaks(&strict_text(md_text, ctx.strict)))
618 }
619 // A plain-text backend dump renders verbatim as a single block.
620 Node::TextDump(text) => {
621 if !text.is_empty() {
622 blocks.push(text.clone());
623 }
624 }
625 // Furniture (page headers/footers, HTML `<title>`) is excluded from
626 // Markdown by default, mirroring docling.
627 Node::Furniture { .. } => {}
628 Node::PageFurniture { .. } => {}
629 // A comment lives in the notes layer — omitted like other furniture;
630 // the annotation on a body item is JSON-only, so render the item.
631 Node::CommentSection { .. } => {}
632 Node::Commented { inner, .. } => render_one(inner, blocks, ctx),
633 // Layout provenance is DocLang-only; render the wrapped node.
634 Node::Located { inner, .. } => render_one(inner, blocks, ctx),
635 // Page breaks are DocLang-only; docling omits them from Markdown.
636 Node::PageBreak => {}
637 // Page markers feed the JSON export only.
638 Node::PageInfo { .. } => {}
639 // Runs of adjacent list items are merged by `render`; a stray single
640 // item (a hand-built document, or a `Located` wrapper around one)
641 // still renders as its own one-item list instead of panicking —
642 // `nodes` is public API, so every representable tree must serialize.
643 Node::ListItem { .. } => render_list_run(std::slice::from_ref(node), blocks, ctx.strict),
644 }
645}
646
647/// The Markdown for a picture under the active [`ImageMode`]; Referenced mode also
648/// records the bytes in `ctx.artifacts` for the caller to write.
649/// docling-core's `_humanize_text`: underscores to spaces, first letter
650/// capitalized ("line_chart" -> "Line chart").
651fn humanize_label(label: &str) -> String {
652 let text = label.replace('_', " ");
653 let mut chars = text.chars();
654 match chars.next() {
655 Some(f) => f.to_uppercase().collect::<String>() + chars.as_str(),
656 None => text,
657 }
658}
659
660fn picture_marker(image: Option<&crate::PictureImage>, ctx: &mut Ctx) -> String {
661 match (ctx.images, image) {
662 (ImageMode::Embedded, Some(img)) => format!("", img.data_uri()),
663 (ImageMode::Referenced, Some(img)) => {
664 let path = format!(
665 "{}/image_{:06}.{}",
666 ctx.artifacts_dir,
667 ctx.pic_index,
668 ext_for(&img.mimetype)
669 );
670 ctx.pic_index += 1;
671 ctx.artifacts.push((path.clone(), img.data.clone()));
672 format!("")
673 }
674 // Placeholder, or any mode with no extracted image.
675 _ => "<!-- image -->".to_string(),
676 }
677}
678
679fn ext_for(mimetype: &str) -> &str {
680 match mimetype {
681 "image/jpeg" => "jpg",
682 "image/gif" => "gif",
683 "image/webp" => "webp",
684 "image/bmp" => "bmp",
685 "image/tiff" => "tif",
686 _ => "png",
687 }
688}
689
690/// Render a table. `compact` selects between two serializers:
691///
692/// - **padded** (default) — docling-core's `tabulate(tablefmt="github")`: columns
693/// are padded to a fixed width (header width + a minimum padding of 2, or the
694/// widest data cell); numeric columns (every data cell parses as a number) are
695/// right-aligned, others left-aligned; separators are plain dashes of
696/// `width + 2`. Matches current published docling (DOCX/HTML conformance).
697/// - **compact** — `| a | b |` cells with single-dash `| - | - |` separators, no
698/// width padding. Matches the committed PDF groundtruth corpus, which predates
699/// the padded serializer.
700///
701/// Each cell is first escaped (`\n` → space, `|` → `|`) so it can't break the
702/// table. The header row is the table's leading `column_header` block flattened
703/// to one row ([`Table::header_row_count`] + [`flatten_header_rows`],
704/// docling-core#723); alignment and widths are computed over the body rows.
705/// Whether a table cell counts as a number for column alignment, matching
706/// `tabulate`'s detection: an ordinary float/int (`f64`-parseable, covering
707/// `1e2`/`inf`/`+1.5`) **or** a thousands-separated number like `7,015`.
708fn is_number_cell(t: &str) -> bool {
709 t.parse::<f64>().is_ok() || is_thousands_number(t)
710}
711
712/// A number with comma thousands-separators, per `tabulate`'s
713/// `_float_with_thousands_separators` regex
714/// (`^(([+-]?[0-9]{1,3})(?:,([0-9]{3}))*)?(?(1)\.[0-9]*|\.[0-9]+)?$`): the
715/// integer part is 1–3 digits then any number of `,ddd` groups; the fraction is
716/// optional (and, without an integer part, must have at least one digit).
717fn is_thousands_number(t: &str) -> bool {
718 let b = t.as_bytes();
719 let mut i = 0;
720 let start = i;
721 if i < b.len() && (b[i] == b'+' || b[i] == b'-') {
722 i += 1;
723 }
724 // First digit chunk: 1–3 digits.
725 let d0 = i;
726 while i < b.len() && b[i].is_ascii_digit() && i - d0 < 3 {
727 i += 1;
728 }
729 let has_int = i > d0;
730 if has_int {
731 // Subsequent `,ddd` groups (exactly three digits each).
732 while i + 3 < b.len() + 1
733 && b.get(i) == Some(&b',')
734 && b.get(i + 1).is_some_and(u8::is_ascii_digit)
735 && b.get(i + 2).is_some_and(u8::is_ascii_digit)
736 && b.get(i + 3).is_some_and(u8::is_ascii_digit)
737 {
738 i += 4;
739 }
740 } else {
741 // A sign only counts with an integer part.
742 i = start;
743 }
744 // Optional fraction.
745 if i < b.len() && b[i] == b'.' {
746 i += 1;
747 let f0 = i;
748 while i < b.len() && b[i].is_ascii_digit() {
749 i += 1;
750 }
751 if !has_int && i == f0 {
752 return false; // `.` with no digits and no integer part
753 }
754 } else if !has_int {
755 return false; // neither integer nor fractional part
756 }
757 i == b.len()
758}
759
760/// The single GFM header row for a table: the leading header rows (see
761/// [`Table::header_row_count`]) flattened per column, texts joined with
762/// `" - "` after dropping consecutive duplicates — docling-core's
763/// `_flatten_header_rows` (docling-core#723). The duplicate rule is what
764/// keeps a row-spanning header from being joined to itself (the grid repeats
765/// its text into every row it covers); it is position-based, so two stacked
766/// levels sharing a label collapse too — GFM has one header row, and upstream
767/// accepts that loss. No header rows → one empty header cell per column.
768fn flatten_header_rows(header_rows: &[Vec<String>], num_cols: usize) -> Vec<String> {
769 (0..num_cols)
770 .map(|c| {
771 let mut parts: Vec<&str> = Vec::new();
772 for row in header_rows {
773 let text = row.get(c).map(String::as_str).unwrap_or("");
774 if !text.is_empty() && parts.last() != Some(&text) {
775 parts.push(text);
776 }
777 }
778 parts.join(" - ")
779 })
780 .collect()
781}
782
783pub(crate) fn render_table(table: &Table, compact: bool) -> String {
784 if table.rows.is_empty() {
785 return String::new();
786 }
787 let num_cols = table.rows.iter().map(Vec::len).max().unwrap_or(0);
788 if num_cols == 0 {
789 return String::new();
790 }
791
792 // Escaped, rectangular grid (ragged rows padded with empty cells). The
793 // header block is resolved to the one row GFM allows (docling-core#723);
794 // `tabulate` strips data cells of surrounding whitespace but leaves the
795 // header texts as-is.
796 let num_headers = table.header_row_count().min(table.rows.len());
797 let escaped = |r: usize| -> Vec<String> {
798 (0..num_cols)
799 .map(|c| escape_cell(table.rows[r].get(c).map(String::as_str).unwrap_or("")))
800 .collect()
801 };
802 let header_rows: Vec<Vec<String>> = (0..num_headers).map(escaped).collect();
803 let header = flatten_header_rows(&header_rows, num_cols);
804 let body: Vec<Vec<String>> = (num_headers..table.rows.len())
805 .map(|r| {
806 escaped(r)
807 .into_iter()
808 .map(|c| c.trim().to_string())
809 .collect()
810 })
811 .collect();
812
813 if compact {
814 // Compact: cells joined by " | ", no padding, single-dash separators.
815 let render_row = |row: &[String]| -> String { format!("| {} |", row.join(" | ")) };
816 let mut lines = Vec::with_capacity(body.len() + 2);
817 lines.push(render_row(&header));
818 let sep: Vec<&str> = (0..num_cols).map(|_| "-").collect();
819 lines.push(format!("| {} |", sep.join(" | ")));
820 for row in &body {
821 lines.push(render_row(row));
822 }
823 return lines.join("\n");
824 }
825
826 // Display width (Unicode scalar count — good enough for now).
827 let dw = |s: &str| s.chars().count();
828
829 // A column is right-aligned when at least one body cell is numeric and every
830 // non-empty body cell is numeric — matching `tabulate`'s column typing, where
831 // empty cells are "missing" (ignored) and a number may carry thousands
832 // separators (`7,015`), which a plain `f64` parse rejects.
833 let right: Vec<bool> = (0..num_cols)
834 .map(|c| {
835 let mut any = false;
836 for row in &body {
837 let t = row[c].trim();
838 if t.is_empty() {
839 continue;
840 }
841 if !is_number_cell(t) {
842 return false;
843 }
844 any = true;
845 }
846 any
847 })
848 .collect();
849
850 // Column width = max(header_width + MIN_PADDING(2), max body-cell width).
851 let width: Vec<usize> = (0..num_cols)
852 .map(|c| {
853 let mut w = dw(&header[c]) + 2;
854 for row in &body {
855 w = w.max(dw(&row[c]));
856 }
857 w
858 })
859 .collect();
860
861 let fmt_cell = |s: &str, c: usize| -> String {
862 let pad = " ".repeat(width[c].saturating_sub(dw(s)));
863 let body = if right[c] {
864 format!("{pad}{s}")
865 } else {
866 format!("{s}{pad}")
867 };
868 format!(" {body} ")
869 };
870 let render_row = |row: &[String]| -> String {
871 let cells: Vec<String> = (0..num_cols).map(|c| fmt_cell(&row[c], c)).collect();
872 format!("|{}|", cells.join("|"))
873 };
874
875 let mut lines = Vec::with_capacity(body.len() + 2);
876 lines.push(render_row(&header));
877 let sep: Vec<String> = (0..num_cols).map(|c| "-".repeat(width[c] + 2)).collect();
878 lines.push(format!("|{}|", sep.join("|")));
879 for row in &body {
880 lines.push(render_row(row));
881 }
882 lines.join("\n")
883}
884
885/// Escape a table cell so it can't break the markdown table: newlines become
886/// spaces and pipes become the `|` HTML entity (matches docling-core).
887fn escape_cell(s: &str) -> String {
888 s.replace('\n', " ").replace('|', "|")
889}
890
891#[cfg(test)]
892mod tests {
893 use super::*;
894 use crate::{PictureImage, TableCell, TableStructure};
895
896 #[test]
897 fn renders_headings_paragraphs_and_lists() {
898 let mut doc = DoclingDocument::new("demo");
899 doc.add_heading(1, "Title");
900 doc.add_paragraph("Hello world.");
901 doc.push(Node::ListItem {
902 ordered: false,
903 number: 1,
904 first_in_list: true,
905 text: "first".into(),
906 level: 0,
907 marker: None,
908 location: None,
909 dclx: None,
910 href: None,
911 layer: None,
912 });
913 doc.push(Node::ListItem {
914 ordered: false,
915 number: 2,
916 first_in_list: false,
917 text: "second".into(),
918 level: 0,
919 marker: None,
920 location: None,
921 dclx: None,
922 href: None,
923 layer: None,
924 });
925 let md = doc.export_to_markdown();
926 assert_eq!(md, "# Title\n\nHello world.\n\n- first\n- second\n");
927 }
928
929 /// docling-core 2.92 (#721): a single newline inside an item's text is a
930 /// GFM hard line break, a blank line stays a paragraph break, and a heading
931 /// collapses its newline to a space. Nested-table dumps stay verbatim.
932 #[test]
933 fn single_newlines_become_gfm_hard_line_breaks() {
934 let mut doc = DoclingDocument::new("t");
935 doc.push(Node::Heading {
936 level: 1,
937 text: "Hello\nWorld".into(),
938 });
939 doc.push(Node::Paragraph {
940 text: "line one\nline two\n\npara two".into(),
941 });
942 doc.push(Node::ListItem {
943 ordered: false,
944 number: 1,
945 first_in_list: true,
946 text: "item\ncontinued".into(),
947 level: 0,
948 marker: None,
949 location: None,
950 dclx: None,
951 href: None,
952 layer: None,
953 });
954 doc.push(Node::TextDump("A1 B1 \n\n\nC1".into()));
955 assert_eq!(
956 doc.export_to_markdown(),
957 "# Hello World\n\nline one \nline two\n\npara two\n\n- item \ncontinued\n\nA1 B1 \n\n\nC1\n"
958 );
959 }
960
961 /// docling-core#540: inside a rich table cell a heading is plain text;
962 /// docling-core#724: a field region renders only its items' key/value text.
963 #[test]
964 fn table_cell_mode_and_field_regions() {
965 let mut doc = DoclingDocument::new("t");
966 doc.push(Node::Heading {
967 level: 2,
968 text: "A text".into(),
969 });
970 doc.push(Node::Paragraph {
971 text: "body".into(),
972 });
973 assert_eq!(to_markdown_table_cell(&doc, false), "A text\n\nbody");
974 assert_eq!(doc.export_to_markdown(), "## A text\n\nbody\n");
975
976 let mut doc = DoclingDocument::new("f");
977 doc.push(Node::FieldRegion {
978 items: vec![crate::FieldItem {
979 marker: None,
980 key: Some("Name:".into()),
981 value: Some("John Doe".into()),
982 }],
983 });
984 assert_eq!(doc.export_to_markdown(), "Name:\n\nJohn Doe\n");
985 }
986
987 #[test]
988 fn strict_renders_recovered_links_legacy_does_not() {
989 let mut doc = DoclingDocument::new("cv");
990 doc.add_paragraph("Find me on LinkedIn or GitHub.");
991 doc.links = vec![
992 ("LinkedIn".into(), "https://www.linkedin.com/in/x/".into()),
993 ("GitHub".into(), "https://github.com/x/".into()),
994 ];
995 // Legacy/docling mode: links are left untouched (conformance preserved).
996 assert_eq!(doc.export_to_markdown(), "Find me on LinkedIn or GitHub.\n");
997 // Strict mode: anchors become Markdown links.
998 assert_eq!(
999 doc.export_to_markdown_with(true),
1000 "Find me on [LinkedIn](https://www.linkedin.com/in/x/) or [GitHub](https://github.com/x/).\n"
1001 );
1002 }
1003
1004 #[test]
1005 fn strict_links_match_escaped_anchor_and_consume_in_order() {
1006 let mut doc = DoclingDocument::new("d");
1007 // The PDF assembler HTML-escapes prose, so by serialization time the body
1008 // already carries `&`; the anchor is stored un-escaped. The matcher must
1009 // escape the anchor to find it. Two identical anchors link in document order.
1010 doc.add_paragraph("AI & ML here, and issues here, then issues there.");
1011 doc.links = vec![
1012 ("AI & ML".into(), "https://a/".into()),
1013 ("issues".into(), "https://first/".into()),
1014 ("issues".into(), "https://second/".into()),
1015 ];
1016 assert_eq!(
1017 doc.export_to_markdown_with(true),
1018 "[AI & ML](https://a/) here, and [issues](https://first/) here, then [issues](https://second/) there.\n"
1019 );
1020 }
1021
1022 /// Pictures the HTML backend folds into a list item print after the item
1023 /// line with plain newlines; a `<br>` newline in the item's own text is
1024 /// still a GFM hard line break.
1025 #[test]
1026 fn folded_list_item_pictures_keep_plain_newlines() {
1027 assert_eq!(
1028 list_item_text("Step\n<!-- image -->", false),
1029 "Step\n<!-- image -->"
1030 );
1031 assert_eq!(
1032 list_item_text("Step\nAlt text\n<!-- image -->\n<!-- image -->", false),
1033 "Step\nAlt text\n<!-- image -->\n<!-- image -->"
1034 );
1035 assert_eq!(
1036 list_item_text("line one\nline two", false),
1037 "line one \nline two"
1038 );
1039 }
1040
1041 /// docling-core#723: the header block is the leading run of rows on which a
1042 /// `column_header` cell starts, flattened per column with " - ".
1043 #[test]
1044 fn stacked_header_rows_flatten_into_one() {
1045 let mut t = Table {
1046 rows: vec![
1047 vec!["".into(), "% of Total".into(), "% of Total".into()],
1048 vec!["class".into(), "Train".into(), "Test".into()],
1049 vec!["Caption".into(), "2.04".into(), "1.77".into()],
1050 ],
1051 ..Default::default()
1052 };
1053 t.structure = Some(TableStructure {
1054 header_row: vec![true, true, false],
1055 col_continuation: vec![
1056 vec![false, false, true],
1057 vec![false, false, false],
1058 vec![false, false, false],
1059 ],
1060 ..Default::default()
1061 });
1062 assert_eq!(t.header_row_count(), 2);
1063 assert_eq!(
1064 render_table(&t, true),
1065 "| class | % of Total - Train | % of Total - Test |\n| - | - | - |\n| Caption | 2.04 | 1.77 |"
1066 );
1067 // padded: widths from the flattened header, alignment from body rows
1068 assert_eq!(
1069 render_table(&t, false),
1070 "| class | % of Total - Train | % of Total - Test |\n\
1071 |---------|----------------------|---------------------|\n\
1072 | Caption | 2.04 | 1.77 |"
1073 );
1074 }
1075
1076 /// A header spanning two rows is repeated into the second row by the grid;
1077 /// that row is not a header row unless another header cell starts there.
1078 #[test]
1079 fn vertically_spanning_header_does_not_extend_the_block() {
1080 let mut t = Table {
1081 rows: vec![
1082 vec!["Name".into(), "Value".into()],
1083 vec!["Name".into(), "1".into()],
1084 vec!["x".into(), "2".into()],
1085 ],
1086 ..Default::default()
1087 };
1088 t.structure = Some(TableStructure {
1089 col_header: vec![vec![true, true], vec![true, false], vec![false, false]],
1090 row_continuation: vec![vec![false, false], vec![true, false], vec![false, false]],
1091 ..Default::default()
1092 });
1093 assert_eq!(t.header_row_count(), 1);
1094 assert_eq!(
1095 render_table(&t, true),
1096 "| Name | Value |\n| - | - |\n| Name | 1 |\n| x | 2 |"
1097 );
1098 }
1099
1100 /// Flags that begin on a later row promote nothing: every row stays in the
1101 /// body under an empty header row (tabulate's `headers=["", ""]`).
1102 #[test]
1103 fn header_flags_not_on_row_zero_keep_all_rows_in_the_body() {
1104 let mut t = Table {
1105 rows: vec![
1106 vec!["1".into(), "2".into()],
1107 vec!["a".into(), "b".into()],
1108 vec!["333".into(), "4".into()],
1109 ],
1110 ..Default::default()
1111 };
1112 t.structure = Some(TableStructure {
1113 header_row: vec![false, true, false],
1114 ..Default::default()
1115 });
1116 assert_eq!(t.header_row_count(), 0);
1117 assert_eq!(
1118 render_table(&t, false),
1119 "| | |\n|-----|----|\n| 1 | 2 |\n| a | b |\n| 333 | 4 |"
1120 );
1121 }
1122
1123 /// A pivot table's row headers (`<th rowspan>`) are flagged `column_header`
1124 /// by docling's HTML backend; a row where data cells start alongside them
1125 /// stays in the body (deliberate deviation from docling-core#723, which
1126 /// folds `2025 | January | $134` into the header row).
1127 #[test]
1128 fn row_headers_beside_data_cells_do_not_extend_the_header() {
1129 let mut t = Table {
1130 rows: vec![
1131 vec!["Year".into(), "Month".into()],
1132 vec!["2025".into(), "January".into()],
1133 vec!["2025".into(), "February".into()],
1134 ],
1135 ..Default::default()
1136 };
1137 t.structure = Some(TableStructure {
1138 col_header: vec![vec![true, true], vec![true, false], vec![true, false]],
1139 row_continuation: vec![vec![false, false], vec![false, false], vec![true, false]],
1140 ..Default::default()
1141 });
1142 assert_eq!(t.header_row_count(), 1);
1143 assert_eq!(
1144 render_table(&t, true),
1145 "| Year | Month |\n| - | - |\n| 2025 | January |\n| 2025 | February |"
1146 );
1147 }
1148
1149 /// No `column_header` anywhere (first-class cells without flags) → row 0
1150 /// stays the header, as before.
1151 #[test]
1152 fn unflagged_cells_keep_row_zero_as_header() {
1153 let mut t = Table {
1154 rows: vec![vec!["h".into()], vec!["d".into()]],
1155 ..Default::default()
1156 };
1157 t.cells = Some(
1158 [(0usize, "h"), (1, "d")]
1159 .into_iter()
1160 .map(|(r, text)| TableCell {
1161 text: text.into(),
1162 bbox: None,
1163 start_row: r,
1164 start_col: 0,
1165 row_span: 1,
1166 col_span: 1,
1167 column_header: false,
1168 row_header: false,
1169 row_section: false,
1170 })
1171 .collect(),
1172 );
1173 assert_eq!(t.header_row_count(), 1);
1174 assert_eq!(render_table(&t, true), "| h |\n| - |\n| d |");
1175 }
1176
1177 #[test]
1178 fn renders_compact_table() {
1179 let mut doc = DoclingDocument::new("t");
1180 // The compact form is opt-in (the PDF backend sets it); default output uses
1181 // the padded GitHub serializer (covered by the regression fixtures).
1182 doc.compact_tables = true;
1183 doc.push(Node::Table(Table {
1184 rows: vec![vec!["a".into(), "b".into()], vec!["1".into(), "2".into()]],
1185 location: None,
1186 structure: None,
1187 cell_blocks: None,
1188 cells: None,
1189 caption: None,
1190 }));
1191 let md = doc.export_to_markdown();
1192 assert_eq!(md, "| a | b |\n| - | - |\n| 1 | 2 |\n");
1193 }
1194
1195 #[test]
1196 fn renders_padded_github_table_by_default() {
1197 let mut doc = DoclingDocument::new("t");
1198 doc.push(Node::Table(Table {
1199 rows: vec![vec!["a".into(), "b".into()], vec!["1".into(), "2".into()]],
1200 location: None,
1201 structure: None,
1202 cell_blocks: None,
1203 cells: None,
1204 caption: None,
1205 }));
1206 let md = doc.export_to_markdown();
1207 // Numeric data columns are right-aligned; columns padded to header+2.
1208 assert_eq!(md, "| a | b |\n|-----|-----|\n| 1 | 2 |\n");
1209 }
1210
1211 #[test]
1212 fn strict_unescapes_inline_underscores_legacy_keeps_them() {
1213 let mut doc = DoclingDocument::new("t");
1214 doc.add_heading(1, "a\\_b");
1215 doc.add_paragraph("x\\_y");
1216 doc.push(Node::ListItem {
1217 ordered: false,
1218 number: 1,
1219 first_in_list: true,
1220 text: "i\\_j".into(),
1221 level: 0,
1222 marker: None,
1223 location: None,
1224 dclx: None,
1225 href: None,
1226 layer: None,
1227 });
1228 // Legacy reproduces docling's `\_` escaping byte-for-byte.
1229 assert_eq!(doc.export_to_markdown(), "# a\\_b\n\nx\\_y\n\n- i\\_j\n");
1230 // Strict prefers literal underscores (Rust-only readability mode).
1231 assert_eq!(doc.export_to_markdown_with(true), "# a_b\n\nx_y\n\n- i_j\n");
1232 }
1233
1234 /// Drive a document's nodes through [`MarkdownStreamer`] in the given page
1235 /// splits and assert the concatenated chunks equal the buffered serializer.
1236 fn assert_stream_matches(
1237 doc: &DoclingDocument,
1238 strict: bool,
1239 images: ImageMode,
1240 splits: &[usize],
1241 ) {
1242 let (want, want_artifacts) = to_markdown_images(doc, strict, images, "artifacts");
1243 let mut streamer =
1244 MarkdownStreamer::with_artifacts(strict, images, doc.compact_tables, "artifacts");
1245 let mut got = String::new();
1246 let mut got_artifacts = Vec::new();
1247 let mut start = 0;
1248 for &end in splits {
1249 // Links only matter in strict mode; feed them all with the first batch
1250 // that has content (document order is preserved by the queue).
1251 let links = if start == 0 {
1252 doc.links.as_slice()
1253 } else {
1254 &[]
1255 };
1256 got.push_str(&streamer.push(&doc.nodes[start..end], links));
1257 // Referenced mode: drain per push, as a real caller writing files
1258 // page by page would — numbering must continue across drains.
1259 got_artifacts.extend(streamer.take_artifacts());
1260 start = end;
1261 }
1262 got.push_str(&streamer.push(
1263 &doc.nodes[start..],
1264 if start == 0 {
1265 doc.links.as_slice()
1266 } else {
1267 &[]
1268 },
1269 ));
1270 got_artifacts.extend(streamer.take_artifacts());
1271 got.push_str(&streamer.finish());
1272 assert_eq!(
1273 got, want,
1274 "streamed output diverged (splits={splits:?}, strict={strict})"
1275 );
1276 assert_eq!(
1277 got_artifacts, want_artifacts,
1278 "streamed artifacts diverged (splits={splits:?}, strict={strict})"
1279 );
1280 }
1281
1282 #[test]
1283 fn streaming_is_byte_identical_to_buffered() {
1284 let mut doc = DoclingDocument::new("d");
1285 doc.add_heading(1, "Title");
1286 doc.add_paragraph("First paragraph.");
1287 doc.push(Node::ListItem {
1288 ordered: false,
1289 number: 1,
1290 first_in_list: true,
1291 text: "a".into(),
1292 level: 0,
1293 marker: None,
1294 location: None,
1295 dclx: None,
1296 href: None,
1297 layer: None,
1298 });
1299 doc.push(Node::ListItem {
1300 ordered: false,
1301 number: 2,
1302 first_in_list: false,
1303 text: "b".into(),
1304 level: 0,
1305 marker: None,
1306 location: None,
1307 dclx: None,
1308 href: None,
1309 layer: None,
1310 });
1311 doc.push(Node::Code {
1312 language: Some("rust".into()),
1313 text: "let x = 1;".into(),
1314 orig: None,
1315 pretty: None,
1316 });
1317 doc.push(Node::Table(Table {
1318 rows: vec![vec!["a".into(), "b".into()], vec!["1".into(), "2".into()]],
1319 location: None,
1320 structure: None,
1321 cell_blocks: None,
1322 cells: None,
1323 caption: None,
1324 }));
1325 doc.push(Node::Picture {
1326 caption: Some("Fig 1".into()),
1327 caption_href: None,
1328 image: Some(PictureImage {
1329 mimetype: "image/png".into(),
1330 width: 2,
1331 height: 2,
1332 data: b"png-one".to_vec(),
1333 }),
1334 classification: None,
1335 });
1336 doc.add_paragraph("Last paragraph.");
1337 // A second embedded picture, so referenced mode must keep numbering
1338 // (`image_000001`) across chunk boundaries.
1339 doc.push(Node::Picture {
1340 caption: None,
1341 caption_href: None,
1342 image: Some(PictureImage {
1343 mimetype: "image/png".into(),
1344 width: 2,
1345 height: 2,
1346 data: b"png-two".to_vec(),
1347 }),
1348 classification: None,
1349 });
1350
1351 // A run of list items must never straddle a split, so try splits that fall
1352 // on safe block boundaries (the streaming PDF assembler guarantees this).
1353 for &strict in &[false, true] {
1354 for &images in &[
1355 ImageMode::Placeholder,
1356 ImageMode::Embedded,
1357 ImageMode::Referenced,
1358 ] {
1359 for splits in [&[][..], &[1][..], &[2][..], &[4][..], &[1, 4, 6, 7][..]] {
1360 assert_stream_matches(&doc, strict, images, splits);
1361 }
1362 }
1363 }
1364 }
1365
1366 #[test]
1367 fn streaming_applies_recovered_links_in_strict_mode() {
1368 let mut doc = DoclingDocument::new("d");
1369 doc.add_paragraph("See LinkedIn for details.");
1370 doc.add_paragraph("And GitHub too.");
1371 doc.links = vec![
1372 ("LinkedIn".into(), "https://lnkd/".into()),
1373 ("GitHub".into(), "https://gh/".into()),
1374 ];
1375 // The second anchor lives in the second block, so it must be carried across
1376 // the page boundary and placed when that block streams out.
1377 assert_stream_matches(&doc, true, ImageMode::Placeholder, &[1]);
1378 }
1379
1380 #[test]
1381 fn strict_tightens_punctuation_spacing_legacy_keeps_it() {
1382 let mut doc = DoclingDocument::new("t");
1383 doc.add_paragraph("see [ 37 , 36 ] and ( x ) .");
1384 // Legacy keeps docling's spacing byte-for-byte.
1385 assert_eq!(doc.export_to_markdown(), "see [ 37 , 36 ] and ( x ) .\n");
1386 // Strict tightens punctuation for readable Markdown.
1387 assert_eq!(doc.export_to_markdown_with(true), "see [37, 36] and (x).\n");
1388 }
1389}