stella_docx_kernel/projection/

ooxml.rs

use std::collections::{BTreeSet, HashMap, HashSet};

use quick_xml::XmlVersion;
use quick_xml::escape::resolve_predefined_entity;
use quick_xml::events::{BytesStart, Event};
use quick_xml::reader::NsReader;
use unicode_script::{Script, UnicodeScript};

use crate::projection::compatibility::{CompatibilityAction, MarkupCompatibility};
use crate::projection::namespaces::OoxmlNamespace;
use crate::projection::review::{
    AttributedRevision, ReviewDetail, ReviewFactSet, ReviewFactUnknownReason, ReviewPoint,
    ReviewSpan, RevisionContent, RevisionFactKind, RevisionPayload,
};
use crate::projection::structure::{
    ParagraphProperties, RawBookmarkRange, RawInternalReference, StructuralFactUnknownReason,
    StyleSheet, TableStyleSelection, TextProperties, TextStyleInput,
};
use crate::projection::styles::{
    parse_alignment, parse_indentation, parse_level_attribute, parse_outline_level_attribute,
    parse_u32_attribute, semantic_highlight_value, word_style_id,
};
use crate::{FormattingCompleteness, FormattingUnknownReason, ParagraphContainer, ProjectionError};

#[derive(Clone, Copy, Debug, Eq, Hash, PartialEq)]
pub struct PackageParagraphId(u32);

impl PackageParagraphId {
    #[must_use]
    pub fn parse(value: &str) -> Option<Self> {
        if value.len() != 8 || !value.bytes().all(|byte| byte.is_ascii_hexdigit()) {
            return None;
        }
        let value = u32::from_str_radix(value, 16).ok()?;
        (value != 0 && i32::try_from(value).is_ok()).then_some(Self(value))
    }

    #[must_use]
    pub const fn value(self) -> u32 {
        self.0
    }
}

#[derive(Clone, Copy, Debug, Eq, Ord, PartialEq, PartialOrd)]
pub enum TextStyle {
    Bold,
    Highlight,
    Superscript,
}

#[derive(Clone, Debug, Eq, PartialEq)]
pub struct TextFormattingSpan {
    pub start_utf16: u32,
    pub end_utf16: u32,
    pub style: TextStyle,
}

#[derive(Clone, Debug, Eq, PartialEq)]
pub struct ParagraphStructure {
    pub table_ordinal: usize,
    pub row: usize,
    pub column: usize,
}

#[derive(Clone, Copy, Debug, Default, Eq, PartialEq)]
pub enum RevisionView {
    #[default]
    Current,
    Original,
}

#[derive(Clone, Copy, Debug, Default, Eq, PartialEq)]
pub enum TextMaterialization {
    #[default]
    WordHost,
    ReadablePlainText,
}

#[derive(Clone, Copy, Debug, Eq, Ord, PartialEq, PartialOrd)]
pub enum RevisionUnsupportedReason {
    IncompatibleParagraphMerge,
    StructuralTableRevision,
    UnsupportedRevisionMarkup,
}

#[derive(Clone, Debug, Eq, PartialEq)]
pub enum RevisionProjectionStatus {
    Complete,
    Incomplete(Vec<RevisionUnsupportedReason>),
}

impl RevisionProjectionStatus {
    #[must_use]
    pub const fn is_complete(&self) -> bool {
        matches!(self, Self::Complete)
    }
}

/// How a tracked paragraph mark changes the paragraph break. A moved-away
/// mark (`w:moveFrom`) behaves like a deleted one and a moved-here mark
/// (`w:moveTo`) like an inserted one, in both review views.
#[derive(Clone, Copy, Debug, Eq, PartialEq)]
enum ParagraphMarkRevision {
    /// `w:ins` or `w:moveTo`: the break exists only in the current view.
    Added,
    /// `w:del` or `w:moveFrom`: the break exists only in the original view.
    Removed,
}

impl ParagraphMarkRevision {
    const fn from_element(name: &[u8]) -> Option<Self> {
        match name {
            b"ins" | b"moveTo" => Some(Self::Added),
            b"del" | b"moveFrom" => Some(Self::Removed),
            _ => None,
        }
    }
}

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub(super) enum TextControl {
    Tab,
    LineBreak,
    PageBreak,
    ColumnBreak,
    CarriageReturn,
    NoteReference,
    SoftHyphen,
    NoBreakHyphen,
}

impl TextControl {
    pub(super) const fn materialize(
        self,
        materialization: TextMaterialization,
    ) -> Option<&'static str> {
        match materialization {
            TextMaterialization::WordHost => Some(match self {
                Self::Tab => "\t",
                Self::LineBreak => "\u{000b}",
                Self::PageBreak => "\u{000c}",
                Self::ColumnBreak => "\u{000e}",
                Self::CarriageReturn => "\r",
                // Footnote and endnote reference marks both materialize as U+0002.
                Self::NoteReference => "\u{0002}",
                Self::SoftHyphen => "\u{001f}",
                Self::NoBreakHyphen => "\u{001e}",
            }),
            TextMaterialization::ReadablePlainText => match self {
                Self::Tab => Some("\t"),
                Self::LineBreak | Self::PageBreak | Self::ColumnBreak | Self::CarriageReturn => {
                    Some("\n")
                }
                Self::NoteReference => None,
                Self::SoftHyphen => Some("\u{00ad}"),
                Self::NoBreakHyphen => Some("\u{2011}"),
            },
        }
    }
}

pub(super) struct RawProjectedParagraph {
    pub ordinal: usize,
    pub package_paragraph_id: Option<PackageParagraphId>,
    pub text: String,
    utf16_len: u32,
    pub formatting: Vec<TextFormattingSpan>,
    pub structure: Option<ParagraphStructure>,
    pub container: ParagraphContainer,
    pub properties: ParagraphProperties,
}

pub(super) struct RawDocumentProjection {
    pub paragraphs: Vec<RawProjectedParagraph>,
    pub bookmarks: Result<Vec<RawBookmarkRange>, StructuralFactUnknownReason>,
    pub references: Result<Vec<RawInternalReference>, StructuralFactUnknownReason>,
    pub formatting_completeness: FormattingCompleteness,
    pub revision_status: RevisionProjectionStatus,
    pub review_revisions: Option<ReviewFactSet<AttributedRevision>>,
    pub review_comment_anchors: HashMap<String, ReviewSpan>,
}

struct ParagraphBuilder {
    package_paragraph_id: Option<PackageParagraphId>,
    text: String,
    utf16_len: u32,
    formatting: Vec<TextFormattingSpan>,
    structure: Option<ParagraphStructure>,
    container: ParagraphContainer,
    properties: ParagraphProperties,
    resolved_text_base: Option<Result<TextProperties, ()>>,
    paragraph_mark_revision: Option<ParagraphMarkRevision>,
    paragraph_review_indices: Vec<usize>,
}

impl ParagraphBuilder {
    fn append(&mut self, text: &str, styles: TextProperties) -> Result<(), ProjectionError> {
        let units = u32::try_from(text.encode_utf16().count())
            .map_err(|_| ProjectionError::InvalidDocumentXml)?;
        let end = self
            .utf16_len
            .checked_add(units)
            .ok_or(ProjectionError::InvalidDocumentXml)?;
        self.append_bold(text, styles, end)?;
        if styles.highlighted == Some(true) {
            self.append_style(end, TextStyle::Highlight);
        }
        if styles.superscript == Some(true) {
            self.append_style(end, TextStyle::Superscript);
        }
        self.text.push_str(text);
        self.utf16_len = end;
        Ok(())
    }

    fn append_bold(
        &mut self,
        text: &str,
        styles: TextProperties,
        end_utf16: u32,
    ) -> Result<(), ProjectionError> {
        if styles.force_complex_script == Some(true) || styles.right_to_left == Some(true) {
            if styles.complex_script_bold == Some(true) {
                self.append_style(end_utf16, TextStyle::Bold);
            }
            return Ok(());
        }

        let regular_bold = styles.bold == Some(true);
        let complex_bold = styles.complex_script_bold == Some(true);
        if regular_bold == complex_bold {
            if regular_bold {
                self.append_style(end_utf16, TextStyle::Bold);
            }
            return Ok(());
        }

        let mut slot = text
            .chars()
            .find_map(character_bold_slot)
            .unwrap_or(BoldSlot::Regular);
        let mut range_start = self.utf16_len;
        let mut position = self.utf16_len;
        for character in text.chars() {
            let character_slot = character_bold_slot(character).unwrap_or(slot);
            if character_slot != slot {
                if slot.enabled(regular_bold, complex_bold) {
                    self.append_style_range(range_start, position, TextStyle::Bold);
                }
                range_start = position;
                slot = character_slot;
            }
            let character_units = if character.len_utf16() == 1 { 1 } else { 2 };
            position = position
                .checked_add(character_units)
                .ok_or(ProjectionError::InvalidDocumentXml)?;
        }
        if slot.enabled(regular_bold, complex_bold) {
            self.append_style_range(range_start, position, TextStyle::Bold);
        }
        if position != end_utf16 {
            return Err(ProjectionError::InvalidDocumentXml);
        }
        Ok(())
    }

    fn resolve_text_base(&mut self, styles: &StyleSheet) -> Result<TextProperties, ()> {
        if let Some(resolved) = self.resolved_text_base {
            return resolved;
        }
        let resolved = styles.resolve_text(TextStyleInput {
            paragraph: &self.properties,
            character_style_id: None,
            direct: TextProperties::default(),
        });
        self.resolved_text_base = Some(resolved);
        resolved
    }

    fn append_style(&mut self, end_utf16: u32, style: TextStyle) {
        self.append_style_range(self.utf16_len, end_utf16, style);
    }

    fn append_style_range(&mut self, start_utf16: u32, end_utf16: u32, style: TextStyle) {
        if start_utf16 >= end_utf16 {
            return;
        }
        append_formatting_span(
            &mut self.formatting,
            TextFormattingSpan {
                start_utf16,
                end_utf16,
                style,
            },
        );
    }

    fn truncate(&mut self, utf8_len: usize, utf16_len: u32) {
        self.text.truncate(utf8_len);
        self.utf16_len = utf16_len;
        self.formatting.retain(|span| span.start_utf16 < utf16_len);
        for span in &mut self.formatting {
            span.end_utf16 = span.end_utf16.min(utf16_len);
        }
    }
}

#[derive(Clone, Copy, Eq, PartialEq)]
enum BoldSlot {
    Regular,
    Complex,
}

impl BoldSlot {
    const fn enabled(self, regular: bool, complex: bool) -> bool {
        match self {
            Self::Regular => regular,
            Self::Complex => complex,
        }
    }
}

#[allow(clippy::too_many_lines)] // Keep HarfBuzz's Unicode 17 shaper table visible and auditable.
fn character_bold_slot(character: char) -> Option<BoldSlot> {
    match character.script() {
        Script::Common | Script::Inherited => None,
        // This positive set tracks the Unicode 17 scripts that HarfBuzz's
        // src/hb-ot-shaper.hh routes through its Arabic, Hebrew, Indic, Khmer,
        // Myanmar, Thai, or Universal Shaping Engine paths. Hangul remains in
        // the regular OOXML bold slot: its dedicated shaper does not make it a
        // complex-script run.
        Script::Adlam
        | Script::Ahom
        | Script::Arabic
        | Script::Balinese
        | Script::Batak
        | Script::Beria_Erfe
        | Script::Bengali
        | Script::Bhaiksuki
        | Script::Brahmi
        | Script::Buginese
        | Script::Buhid
        | Script::Chakma
        | Script::Cham
        | Script::Chorasmian
        | Script::Cypro_Minoan
        | Script::Devanagari
        | Script::Dives_Akuru
        | Script::Dogra
        | Script::Duployan
        | Script::Egyptian_Hieroglyphs
        | Script::Elymaic
        | Script::Garay
        | Script::Grantha
        | Script::Gujarati
        | Script::Gunjala_Gondi
        | Script::Gurung_Khema
        | Script::Gurmukhi
        | Script::Hanifi_Rohingya
        | Script::Hanunoo
        | Script::Hebrew
        | Script::Javanese
        | Script::Kaithi
        | Script::Kannada
        | Script::Kawi
        | Script::Kayah_Li
        | Script::Kharoshthi
        | Script::Khmer
        | Script::Khitan_Small_Script
        | Script::Khojki
        | Script::Khudawadi
        | Script::Kirat_Rai
        | Script::Lao
        | Script::Lepcha
        | Script::Limbu
        | Script::Mahajani
        | Script::Makasar
        | Script::Malayalam
        | Script::Mandaic
        | Script::Manichaean
        | Script::Marchen
        | Script::Masaram_Gondi
        | Script::Medefaidrin
        | Script::Meetei_Mayek
        | Script::Miao
        | Script::Modi
        | Script::Mongolian
        | Script::Multani
        | Script::Myanmar
        | Script::Nag_Mundari
        | Script::Nandinagari
        | Script::Newa
        | Script::Nko
        | Script::Nyiakeng_Puachue_Hmong
        | Script::Old_Sogdian
        | Script::Old_Uyghur
        | Script::Ol_Onal
        | Script::Oriya
        | Script::Pahawh_Hmong
        | Script::Phags_Pa
        | Script::Psalter_Pahlavi
        | Script::Rejang
        | Script::Saurashtra
        | Script::Sharada
        | Script::Siddham
        | Script::Sidetic
        | Script::Sinhala
        | Script::Sogdian
        | Script::Soyombo
        | Script::Sundanese
        | Script::Sunuwar
        | Script::Syloti_Nagri
        | Script::Syriac
        | Script::Tagalog
        | Script::Tagbanwa
        | Script::Tai_Le
        | Script::Tai_Tham
        | Script::Tai_Viet
        | Script::Tai_Yo
        | Script::Tamil
        | Script::Tangsa
        | Script::Takri
        | Script::Telugu
        | Script::Thaana
        | Script::Thai
        | Script::Tibetan
        | Script::Tifinagh
        | Script::Tirhuta
        | Script::Todhri
        | Script::Tolong_Siki
        | Script::Toto
        | Script::Tulu_Tigalari
        | Script::Vithkuqi
        | Script::Wancho
        | Script::Yezidi
        | Script::Zanabazar_Square => Some(BoldSlot::Complex),
        _ => Some(BoldSlot::Regular),
    }
}

struct RunFrame {
    text: String,
    direct_styles: TextProperties,
    character_style_id: Option<String>,
    hidden: bool,
    direct_child_count: usize,
    property_review_indices: Vec<usize>,
}

struct RunPropertiesFrame {
    run_frame: usize,
    hidden_eligible: bool,
}

#[derive(Clone, Copy)]
struct ContainerReview {
    paragraph_start: usize,
    property_review: Option<usize>,
    grid_review: Option<usize>,
    exception_review: Option<usize>,
}

struct TableFrame {
    ordinal: usize,
    next_row: usize,
    style_id: Option<String>,
    review: ContainerReview,
}

struct RowFrame {
    table_ordinal: usize,
    row: usize,
    next_column: usize,
    review: ContainerReview,
}

#[derive(Clone, Copy)]
struct CellFrame {
    table_ordinal: usize,
    row: usize,
    column: usize,
    review: ContainerReview,
}

struct SdtFrame {
    placeholder: bool,
    text_utf8_start: usize,
    text_utf16_start: u32,
}

#[derive(Clone, Copy)]
enum PseudoTextKind {
    Text { preserve_space: bool },
    MathText,
    Instruction,
}

struct PseudoTextFrame {
    kind: PseudoTextKind,
    text: String,
}

impl PseudoTextFrame {
    const fn text(preserve_space: bool) -> Self {
        Self {
            kind: PseudoTextKind::Text { preserve_space },
            text: String::new(),
        }
    }

    const fn instruction() -> Self {
        Self {
            kind: PseudoTextKind::Instruction,
            text: String::new(),
        }
    }

    const fn math_text() -> Self {
        Self {
            kind: PseudoTextKind::MathText,
            text: String::new(),
        }
    }
}

#[derive(Clone, Copy)]
enum FieldSource {
    Projected(ReviewPoint),
    Hidden,
    Unsupported,
}

struct FieldFrame {
    source: FieldSource,
    instruction: String,
    separated: bool,
}

#[derive(Clone, Debug)]
enum BookmarkPoint {
    Paragraph(ReviewPoint),
    ParagraphBoundary(usize),
}

#[derive(Clone, Debug)]
struct PendingBookmarkRange {
    id: u32,
    name: String,
    start: BookmarkPoint,
    end: BookmarkPoint,
}

fn resolve_bookmark_ranges(
    paragraphs: &[RawProjectedParagraph],
    ranges: Vec<PendingBookmarkRange>,
) -> Option<Vec<RawBookmarkRange>> {
    ranges
        .into_iter()
        .map(|range| {
            let same_boundary = matches!(
                (&range.start, &range.end),
                (
                    BookmarkPoint::ParagraphBoundary(start),
                    BookmarkPoint::ParagraphBoundary(end)
                ) if start == end
            );
            let start = resolve_bookmark_point(paragraphs, &range.start, BoundarySide::Start)?;
            let end = resolve_bookmark_point(
                paragraphs,
                &range.end,
                if same_boundary {
                    BoundarySide::Start
                } else {
                    BoundarySide::End
                },
            )?;
            bookmark_points_are_ordered(&start, &end).then_some(RawBookmarkRange {
                id: range.id,
                name: range.name,
                start,
                end,
            })
        })
        .collect()
}

#[derive(Clone, Copy)]
enum BoundarySide {
    Start,
    End,
}

fn resolve_bookmark_point(
    paragraphs: &[RawProjectedParagraph],
    point: &BookmarkPoint,
    side: BoundarySide,
) -> Option<ReviewPoint> {
    let boundary = match point {
        BookmarkPoint::Paragraph(point) => return Some(*point),
        BookmarkPoint::ParagraphBoundary(boundary) => boundary,
    };
    if *boundary > paragraphs.len() || paragraphs.is_empty() {
        return None;
    }
    match side {
        BoundarySide::Start => paragraphs.get(*boundary).map_or_else(
            || paragraph_end(paragraphs.last()?),
            |paragraph| {
                Some(ReviewPoint {
                    paragraph_ordinal: paragraph.ordinal,
                    utf8: 0,
                    utf16: 0,
                })
            },
        ),
        BoundarySide::End => boundary.checked_sub(1).map_or_else(
            || {
                Some(ReviewPoint {
                    paragraph_ordinal: paragraphs.first()?.ordinal,
                    utf8: 0,
                    utf16: 0,
                })
            },
            |paragraph| paragraph_end(paragraphs.get(paragraph)?),
        ),
    }
}

fn paragraph_end(paragraph: &RawProjectedParagraph) -> Option<ReviewPoint> {
    Some(ReviewPoint {
        paragraph_ordinal: paragraph.ordinal,
        utf8: u32::try_from(paragraph.text.len()).ok()?,
        utf16: paragraph.utf16_len,
    })
}

const fn bookmark_points_are_ordered(start: &ReviewPoint, end: &ReviewPoint) -> bool {
    start.paragraph_ordinal < end.paragraph_ordinal
        || (start.paragraph_ordinal == end.paragraph_ordinal
            && start.utf8 <= end.utf8
            && start.utf16 <= end.utf16)
}

#[derive(Clone, Copy)]
enum OwnedRevisionSpan {
    Paragraph(ReviewSpan),
    Content(ReviewSpan),
}

struct RevisionFrame {
    review_index: Option<usize>,
    start: Option<ReviewPoint>,
    suppressed: bool,
    text: String,
}

#[derive(Default)]
enum ReviewRevisionCollection {
    #[default]
    Disabled,
    Complete {
        maximum_facts: usize,
        remaining_detail_bytes: usize,
        revisions: Vec<AttributedRevision>,
    },
    LimitExceeded,
}

#[derive(Clone, Copy)]
pub(super) struct ReviewProjectionLimits {
    pub maximum_facts: usize,
    pub maximum_detail_bytes: usize,
}

#[derive(Clone, Copy)]
enum SnapshotOwner {
    Run { frame: usize, hidden_eligible: bool },
    Paragraph,
    ParagraphMark,
    Table,
    Row,
    Cell,
    Grid,
    Section,
    TableExceptions,
    Unsupported,
}

#[derive(Clone, Copy)]
enum SnapshotStatus {
    AwaitingRoot,
    Applied,
    Unsupported,
}

struct SnapshotFrame {
    owner: SnapshotOwner,
    status: SnapshotStatus,
}

enum Frame {
    Other,
    Body,
    BlockContent,
    Table(TableFrame),
    Row(RowFrame),
    Cell(CellFrame),
    Paragraph,
    Run(RunFrame),
    RunProperties(RunPropertiesFrame),
    ParagraphProperties,
    ParagraphMarkProperties,
    TableProperties,
    TableGrid,
    TableRowProperties,
    TableCellProperties,
    TablePropertyExceptions,
    SectionProperties,
    NumberingProperties,
    Hyperlink(Option<RawInternalReference>),
    Revision(RevisionFrame),
    ChangeSnapshot(SnapshotFrame),
    SnapshotIgnored,
    Math,
    MathRun,
    Textbox,
    Sdt(SdtFrame),
    PseudoText(PseudoTextFrame),
}

impl Frame {
    const fn paragraph_context(&self) -> Option<(ParagraphContainer, Option<ParagraphStructure>)> {
        match self {
            Self::Body => Some((ParagraphContainer::Body, None)),
            Self::Cell(cell) => Some((
                ParagraphContainer::TableCell,
                Some(ParagraphStructure {
                    table_ordinal: cell.table_ordinal,
                    row: cell.row,
                    column: cell.column,
                }),
            )),
            Self::Other
            | Self::BlockContent
            | Self::Table(_)
            | Self::Row(_)
            | Self::Paragraph
            | Self::Run(_)
            | Self::RunProperties(_)
            | Self::ParagraphProperties
            | Self::ParagraphMarkProperties
            | Self::TableProperties
            | Self::TableGrid
            | Self::TableRowProperties
            | Self::TableCellProperties
            | Self::TablePropertyExceptions
            | Self::SectionProperties
            | Self::NumberingProperties
            | Self::Hyperlink(_)
            | Self::Revision(_)
            | Self::ChangeSnapshot(_)
            | Self::SnapshotIgnored
            | Self::Math
            | Self::MathRun
            | Self::Textbox
            | Self::Sdt(_)
            | Self::PseudoText(_) => None,
        }
    }
}

#[allow(clippy::too_many_lines)] // A single streaming event loop keeps XML parsing one-pass.
pub(super) fn project_document_xml(
    xml: &[u8],
    maximum_paragraphs: usize,
    revision_view: RevisionView,
    text_materialization: TextMaterialization,
    styles: Result<&StyleSheet, FormattingUnknownReason>,
    review_limits: Option<ReviewProjectionLimits>,
) -> Result<RawDocumentProjection, ProjectionError> {
    let mut reader = NsReader::from_reader(xml);
    reader.config_mut().check_end_names = true;
    let mut state = ProjectionState {
        maximum_paragraphs,
        revision_view,
        text_materialization,
        bookmarks_complete: true,
        references_complete: true,
        formatting_completeness: FormattingCompleteness::from_styles(styles.map(|_| ())),
        review_revisions: review_limits.map_or(ReviewRevisionCollection::Disabled, |limits| {
            ReviewRevisionCollection::Complete {
                maximum_facts: limits.maximum_facts,
                remaining_detail_bytes: limits.maximum_detail_bytes,
                revisions: Vec::new(),
            }
        }),
        ..ProjectionState::default()
    };
    let mut compatibility = MarkupCompatibility::default();
    loop {
        match reader
            .read_event()
            .map_err(|_| ProjectionError::InvalidDocumentXml)?
        {
            Event::Start(element) => {
                let (namespace, _) = reader.resolver().resolve_element(element.name());
                let namespace = OoxmlNamespace::from_resolved(&namespace);
                if compatibility.start(&reader, namespace, &element)?
                    == CompatibilityAction::Process
                {
                    state.start(&reader, namespace, &element)?;
                }
            }
            Event::Empty(element) => {
                let (namespace, _) = reader.resolver().resolve_element(element.name());
                let namespace = OoxmlNamespace::from_resolved(&namespace);
                if compatibility.empty(&reader, namespace, &element)?
                    == CompatibilityAction::Process
                {
                    state.start(&reader, namespace, &element)?;
                    state.end(styles)?;
                }
            }
            Event::Text(text) => {
                if !compatibility.is_suppressed()
                    && matches!(state.frames.last(), Some(Frame::PseudoText(_)))
                {
                    let decoded = text.xml_content(XmlVersion::Implicit1_0);
                    state.append_pseudo_content(&decoded)?;
                }
            }
            Event::CData(text) => {
                if !compatibility.is_suppressed()
                    && matches!(state.frames.last(), Some(Frame::PseudoText(_)))
                {
                    let decoded = text.xml_content(XmlVersion::Implicit1_0);
                    state.append_pseudo_content(&decoded)?;
                }
            }
            Event::GeneralRef(reference) => {
                if !compatibility.is_suppressed()
                    && matches!(state.frames.last(), Some(Frame::PseudoText(_)))
                {
                    let resolved_character = reference
                        .resolve_char_ref()
                        .map_err(|_| ProjectionError::InvalidDocumentXml)?;
                    let resolved = if let Some(character) = resolved_character {
                        character.to_string()
                    } else {
                        let name = reference.as_ref();
                        resolve_predefined_entity(name)
                            .ok_or(ProjectionError::InvalidDocumentXml)?
                            .to_owned()
                    };
                    state.append_pseudo_content(&resolved)?;
                }
            }
            Event::End(element) => {
                let (namespace, local_name) = reader.resolver().resolve_element(element.name());
                if compatibility.end(
                    OoxmlNamespace::from_resolved(&namespace),
                    local_name.as_ref().as_bytes(),
                )? == CompatibilityAction::Process
                {
                    state.end(styles)?;
                }
            }
            Event::Eof => break,
            _ => {}
        }
    }
    if !state.body_seen {
        return Err(ProjectionError::MissingDocumentBody);
    }
    if state.current_paragraph.is_some() || !state.frames.is_empty() || !compatibility.is_complete()
    {
        return Err(ProjectionError::InvalidDocumentXml);
    }
    let mut bookmarks = if state.bookmarks_complete && state.open_bookmarks.is_empty() {
        resolve_bookmark_ranges(&state.paragraphs, state.bookmarks)
            .ok_or(StructuralFactUnknownReason::IncompleteBookmarkRanges)
    } else {
        Err(StructuralFactUnknownReason::IncompleteBookmarkRanges)
    };
    let paragraph_origins = if state.paragraph_mark_revisions.is_empty() {
        None
    } else {
        normalize_paragraph_revision_view(
            &mut state.paragraphs,
            &mut state.paragraph_mark_revisions,
            state.revision_view,
            &mut state.revision_unsupported,
        )?
    };
    if let Some(origins) = paragraph_origins {
        if let Ok(ranges) = &mut bookmarks {
            for range in ranges {
                relocate_block_point(&origins, &mut range.start)?;
                relocate_block_point(&origins, &mut range.end)?;
            }
        }
        for reference in &mut state.references {
            relocate_block_point(&origins, &mut reference.source)?;
        }
        state.review_comment_anchors.retain(|_, anchor| {
            relocate_review_span(&origins, *anchor).is_some_and(|relocated| {
                *anchor = relocated;
                true
            })
        });
        if let ReviewRevisionCollection::Complete { revisions, .. } = &mut state.review_revisions {
            for revision in revisions {
                let ReviewDetail::Known(content) = &mut revision.content else {
                    continue;
                };
                match relocate_review_span(&origins, content.span) {
                    Some(span) => content.span = span,
                    None => {
                        revision.content =
                            ReviewDetail::Unknown(ReviewFactUnknownReason::UnsupportedLocation);
                    }
                }
            }
        }
    }
    let references = if state.references_complete && state.fields.is_empty() {
        Ok(state.references)
    } else {
        Err(StructuralFactUnknownReason::UnsupportedInternalReferences)
    };
    Ok(RawDocumentProjection {
        paragraphs: state.paragraphs,
        bookmarks,
        references,
        formatting_completeness: state.formatting_completeness,
        revision_status: if state.revision_unsupported.is_empty() {
            RevisionProjectionStatus::Complete
        } else {
            RevisionProjectionStatus::Incomplete(state.revision_unsupported.into_iter().collect())
        },
        review_revisions: match state.review_revisions {
            ReviewRevisionCollection::Disabled => None,
            ReviewRevisionCollection::Complete { revisions, .. } => {
                Some(ReviewFactSet::Known(revisions))
            }
            ReviewRevisionCollection::LimitExceeded => Some(ReviewFactSet::Unknown(
                ReviewFactUnknownReason::ResourceLimit,
            )),
        },
        review_comment_anchors: state.review_comment_anchors,
    })
}

#[derive(Default)]
struct BookmarkQueue {
    starts: Vec<Option<(String, BookmarkPoint)>>,
    cursor: usize,
}

#[derive(Default)]
struct ProjectionState {
    frames: Vec<Frame>,
    paragraphs: Vec<RawProjectedParagraph>,
    current_paragraph: Option<ParagraphBuilder>,
    body_seen: bool,
    next_table_ordinal: usize,
    maximum_paragraphs: usize,
    open_bookmarks: HashMap<u32, BookmarkQueue>,
    bookmarks: Vec<PendingBookmarkRange>,
    references: Vec<RawInternalReference>,
    bookmarks_complete: bool,
    references_complete: bool,
    formatting_completeness: FormattingCompleteness,
    fields: Vec<FieldFrame>,
    paragraph_mark_revisions: HashMap<usize, ParagraphMarkRevision>,
    revision_view: RevisionView,
    text_materialization: TextMaterialization,
    revision_unsupported: BTreeSet<RevisionUnsupportedReason>,
    review_revisions: ReviewRevisionCollection,
    open_review_comment_anchors: HashMap<String, ReviewPoint>,
    review_comment_anchors: HashMap<String, ReviewSpan>,
    invalid_review_comment_anchors: HashSet<String>,
}

impl ProjectionState {
    #[allow(clippy::too_many_lines)] // The frame transition table is one streaming state machine.
    fn start(
        &mut self,
        reader: &NsReader<&[u8]>,
        namespace: OoxmlNamespace,
        element: &BytesStart<'_>,
    ) -> Result<(), ProjectionError> {
        let local_name = element.local_name();
        let name = if namespace == OoxmlNamespace::Wordprocessing {
            local_name.as_ref().as_bytes()
        } else {
            b""
        };
        let direct_run_child = if let Some(Frame::Run(run)) = self.frames.last_mut() {
            let child = run.direct_child_count;
            run.direct_child_count = run
                .direct_child_count
                .checked_add(1)
                .ok_or(ProjectionError::InvalidDocumentXml)?;
            let frame_index = self
                .frames
                .len()
                .checked_sub(1)
                .ok_or(ProjectionError::InvalidDocumentXml)?;
            Some((frame_index, child))
        } else {
            None
        };

        if name == b"body" {
            if self.body_seen {
                return Err(ProjectionError::InvalidDocumentXml);
            }
            self.body_seen = true;
            self.frames.push(Frame::Body);
            return Ok(());
        }
        if !self.inside_body() {
            self.frames.push(Frame::Other);
            return Ok(());
        }
        let inside_snapshot = self.inside_change_snapshot();
        if inside_snapshot && self.start_snapshot_child(name)? {
            return Ok(());
        }
        let attributed_revision = if inside_snapshot {
            None
        } else {
            self.record_attributed_revision(reader, element, name)?
        };
        if name == b"txbxContent" {
            self.frames.push(Frame::Textbox);
            return Ok(());
        }
        if self.inside_textbox() {
            if matches!(
                name,
                b"commentRangeStart" | b"commentRangeEnd" | b"commentReference"
            ) {
                self.suppress_review_comment_anchor(reader, element)?;
            }
            self.frames.push(Frame::Other);
            return Ok(());
        }
        match name {
            b"commentRangeStart" => self.start_review_comment_anchor(reader, element)?,
            b"commentRangeEnd" => self.end_review_comment_anchor(reader, element)?,
            b"commentReference" => self.record_review_comment_reference(reader, element)?,
            _ => {}
        }
        if is_change_snapshot(name) {
            if let Some(review_index) = attributed_revision {
                match (name, self.frames.last()) {
                    (b"rPrChange", Some(Frame::RunProperties(properties))) => {
                        let run_frame = properties.run_frame;
                        if let Some(Frame::Run(run)) = self.frames.get_mut(run_frame) {
                            run.property_review_indices.push(review_index);
                        } else if self.inside_paragraph_mark_properties()
                            && let Some(paragraph) = self.current_paragraph.as_mut()
                        {
                            paragraph.paragraph_review_indices.push(review_index);
                        }
                    }
                    (b"pPrChange", Some(Frame::ParagraphProperties)) => {
                        if let Some(paragraph) = self.current_paragraph.as_mut() {
                            paragraph.paragraph_review_indices.push(review_index);
                        }
                    }
                    _ => self.record_container_property_revision(name, review_index)?,
                }
            }
            let owner = self.snapshot_owner(name);
            self.frames.push(Frame::ChangeSnapshot(SnapshotFrame {
                owner,
                status: SnapshotStatus::AwaitingRoot,
            }));
            return Ok(());
        }
        if is_unsupported_revision_markup(name) {
            self.revision_unsupported
                .insert(RevisionUnsupportedReason::UnsupportedRevisionMarkup);
            self.frames.push(Frame::Other);
            return Ok(());
        }
        if namespace == OoxmlNamespace::OfficeMath {
            let frame = match local_name.as_ref().as_bytes() {
                b"oMath" | b"oMathPara" if self.current_paragraph.is_some() => {
                    // Math text participates in paragraph offsets, but OMML run
                    // properties form a separate formatting hierarchy.
                    self.formatting_completeness.mark_formatting_unread();
                    Frame::Math
                }
                b"r" if self.frames.iter().any(|frame| matches!(frame, Frame::Math)) => {
                    Frame::MathRun
                }
                b"t" if matches!(self.frames.last(), Some(Frame::MathRun)) => {
                    Frame::PseudoText(PseudoTextFrame::math_text())
                }
                _ => Frame::Other,
            };
            self.frames.push(frame);
            return Ok(());
        }

        let frame = match name {
            b"tbl" => {
                let ordinal = self.next_table_ordinal;
                self.next_table_ordinal = self
                    .next_table_ordinal
                    .checked_add(1)
                    .ok_or(ProjectionError::InvalidDocumentXml)?;
                Frame::Table(TableFrame {
                    ordinal,
                    next_row: 0,
                    style_id: None,
                    review: ContainerReview {
                        paragraph_start: self.paragraphs.len(),
                        property_review: None,
                        grid_review: None,
                        exception_review: None,
                    },
                })
            }
            b"tr" => {
                let Some(table) = enclosing_table(&mut self.frames) else {
                    self.frames.push(Frame::Other);
                    return Ok(());
                };
                let row = table.next_row;
                table.next_row = table
                    .next_row
                    .checked_add(1)
                    .ok_or(ProjectionError::InvalidDocumentXml)?;
                Frame::Row(RowFrame {
                    table_ordinal: table.ordinal,
                    row,
                    next_column: 0,
                    review: ContainerReview {
                        paragraph_start: self.paragraphs.len(),
                        property_review: None,
                        grid_review: None,
                        exception_review: None,
                    },
                })
            }
            b"tc" => {
                let Some(row) = enclosing_row(&mut self.frames) else {
                    self.frames.push(Frame::Other);
                    return Ok(());
                };
                let column = row.next_column;
                row.next_column = row
                    .next_column
                    .checked_add(1)
                    .ok_or(ProjectionError::InvalidDocumentXml)?;
                Frame::Cell(CellFrame {
                    table_ordinal: row.table_ordinal,
                    row: row.row,
                    column,
                    review: ContainerReview {
                        paragraph_start: self.paragraphs.len(),
                        property_review: None,
                        grid_review: None,
                        exception_review: None,
                    },
                })
            }
            b"p" => {
                if self.current_paragraph.is_some() {
                    self.frames.push(Frame::Other);
                    return Ok(());
                }
                if self.paragraphs.len() >= self.maximum_paragraphs {
                    return Err(ProjectionError::TooManyParagraphs);
                }
                let package_paragraph_id = attribute_2010(reader, element, b"paraId")?
                    .as_deref()
                    .and_then(PackageParagraphId::parse);
                let (container, structure) = self
                    .frames
                    .iter()
                    .rev()
                    .find_map(Frame::paragraph_context)
                    .ok_or(ProjectionError::InvalidDocumentXml)?;
                self.current_paragraph = Some(ParagraphBuilder {
                    package_paragraph_id,
                    text: String::new(),
                    utf16_len: 0,
                    formatting: Vec::new(),
                    structure,
                    container,
                    properties: ParagraphProperties {
                        table_style: self
                            .frames
                            .iter()
                            .rev()
                            .find_map(|frame| {
                                if let Frame::Table(table) = frame {
                                    Some(table.style_id.clone().map_or(
                                        TableStyleSelection::Default,
                                        TableStyleSelection::Explicit,
                                    ))
                                } else {
                                    None
                                }
                            })
                            .unwrap_or_default(),
                        ..ParagraphProperties::default()
                    },
                    resolved_text_base: None,
                    paragraph_mark_revision: None,
                    paragraph_review_indices: Vec::new(),
                });
                Frame::Paragraph
            }
            b"r" if self.current_paragraph.is_some() => Frame::Run(RunFrame {
                text: String::new(),
                direct_styles: TextProperties::default(),
                character_style_id: None,
                hidden: false,
                direct_child_count: 0,
                property_review_indices: Vec::new(),
            }),
            b"rPr" => {
                let Some((run_frame, child_index)) = direct_run_child else {
                    self.frames.push(Frame::RunProperties(RunPropertiesFrame {
                        run_frame: usize::MAX,
                        hidden_eligible: false,
                    }));
                    return Ok(());
                };
                Frame::RunProperties(RunPropertiesFrame {
                    run_frame,
                    hidden_eligible: child_index == 0,
                })
            }
            b"sdtContent" | b"customXml" => Frame::BlockContent,
            b"pPr" => Frame::ParagraphProperties,
            b"tblStyle" if matches!(self.frames.last(), Some(Frame::TableProperties)) => {
                if let Some(table) = enclosing_table(&mut self.frames) {
                    table.style_id = word_style_id(attribute(reader, element, b"val")?);
                }
                Frame::Other
            }
            b"tblPr" => Frame::TableProperties,
            b"tblGrid" => Frame::TableGrid,
            b"trPr" => Frame::TableRowProperties,
            b"tcPr" => Frame::TableCellProperties,
            b"tblPrEx" => Frame::TablePropertyExceptions,
            b"sectPr" => Frame::SectionProperties,
            b"pStyle" if matches!(self.frames.last(), Some(Frame::ParagraphProperties)) => {
                if let Some(paragraph) = self.current_paragraph.as_mut() {
                    paragraph.properties.style_id =
                        word_style_id(attribute(reader, element, b"val")?);
                    paragraph.resolved_text_base = None;
                }
                Frame::Other
            }
            b"ind" if matches!(self.frames.last(), Some(Frame::ParagraphProperties)) => {
                if let Some(paragraph) = self.current_paragraph.as_mut() {
                    paragraph.properties.indentation = parse_indentation(reader, element)?;
                }
                Frame::Other
            }
            // `w:jc` is also legal under `w:trPr` and `w:tblPr`, where it means
            // row or table justification. Only a direct child of `w:pPr` is
            // paragraph alignment.
            b"jc" if matches!(self.frames.last(), Some(Frame::ParagraphProperties)) => {
                if let Some(paragraph) = self.current_paragraph.as_mut() {
                    paragraph.properties.alignment = Some(parse_alignment(reader, element)?);
                }
                Frame::Other
            }
            b"outlineLvl" if matches!(self.frames.last(), Some(Frame::ParagraphProperties)) => {
                if let Some(paragraph) = self.current_paragraph.as_mut() {
                    paragraph.properties.outline_level =
                        Some(parse_outline_level_attribute(reader, element)?);
                }
                Frame::Other
            }
            b"numPr" if matches!(self.frames.last(), Some(Frame::ParagraphProperties)) => {
                if let Some(paragraph) = self.current_paragraph.as_mut() {
                    paragraph.properties.numbering.present = true;
                }
                Frame::NumberingProperties
            }
            b"numId" if matches!(self.frames.last(), Some(Frame::NumberingProperties)) => {
                if let Some(paragraph) = self.current_paragraph.as_mut() {
                    paragraph.properties.numbering.num_id =
                        Some(parse_u32_attribute(reader, element)?);
                }
                Frame::Other
            }
            b"ilvl" if matches!(self.frames.last(), Some(Frame::NumberingProperties)) => {
                if let Some(paragraph) = self.current_paragraph.as_mut() {
                    paragraph.properties.numbering.level =
                        Some(parse_level_attribute(reader, element)?);
                }
                Frame::Other
            }
            b"bookmarkStart" => {
                self.start_bookmark(reader, element)?;
                Frame::Other
            }
            b"bookmarkEnd" => {
                self.end_bookmark(reader, element)?;
                Frame::Other
            }
            b"hyperlink" => {
                if self.pseudo_text_is_suppressed() {
                    self.frames.push(Frame::Hyperlink(None));
                    return Ok(());
                }
                let anchor = attribute(reader, element, b"anchor")?;
                let reference =
                    anchor
                        .clone()
                        .filter(|anchor| !anchor.is_empty())
                        .and_then(|anchor| {
                            self.current_point().map(|source| RawInternalReference {
                                reference_id: anchor,
                                source,
                            })
                        });
                if anchor.is_some() && reference.is_none() {
                    self.references_complete = false;
                }
                Frame::Hyperlink(reference)
            }
            b"fldSimple" => {
                self.simple_field(reader, element)?;
                Frame::Other
            }
            b"fldChar" => {
                self.field_character(reader, element)?;
                Frame::Other
            }
            b"instrText" | b"delInstrText" => Frame::PseudoText(PseudoTextFrame::instruction()),
            b"ins" | b"del" | b"moveFrom" | b"moveTo" => {
                if self.inside_table_row_properties() {
                    self.revision_unsupported
                        .insert(RevisionUnsupportedReason::StructuralTableRevision);
                    Frame::Other
                } else if self.inside_paragraph_mark_properties() {
                    if let Some(paragraph) = self.current_paragraph.as_mut() {
                        paragraph.paragraph_mark_revision =
                            ParagraphMarkRevision::from_element(name)
                                .or(paragraph.paragraph_mark_revision);
                        paragraph
                            .paragraph_review_indices
                            .extend(attributed_revision);
                    }
                    Frame::Other
                } else {
                    Frame::Revision(RevisionFrame {
                        review_index: attributed_revision,
                        start: self.current_review_point(),
                        suppressed: revision_is_suppressed(name, self.revision_view),
                        text: String::new(),
                    })
                }
            }
            b"cellIns" | b"cellDel" | b"cellMerge" => {
                self.revision_unsupported
                    .insert(RevisionUnsupportedReason::StructuralTableRevision);
                Frame::Other
            }
            b"sdt" => {
                let (text_utf8_start, text_utf16_start) =
                    self.current_paragraph.as_ref().map_or((0, 0), |paragraph| {
                        (paragraph.text.len(), paragraph.utf16_len)
                    });
                Frame::Sdt(SdtFrame {
                    placeholder: false,
                    text_utf8_start,
                    text_utf16_start,
                })
            }
            b"showingPlcHdr" => {
                if on_off_element_enabled(reader, element)? {
                    self.mark_placeholder();
                }
                Frame::Other
            }
            b"vanish" => {
                if on_off_element_enabled(reader, element)? {
                    self.mark_hidden_run();
                }
                Frame::Other
            }
            b"rStyle" => {
                let style_id = word_style_id(attribute(reader, element, b"val")?);
                if matches!(style_id.as_deref(), Some("HideTWBInt" | "HideTWBExt")) {
                    self.mark_hidden_run();
                }
                self.set_run_character_style(style_id);
                Frame::Other
            }
            b"b" => {
                self.mark_bold_run(on_off_element_enabled(reader, element)?);
                Frame::Other
            }
            b"bCs" => {
                self.mark_complex_script_bold_run(on_off_element_enabled(reader, element)?);
                Frame::Other
            }
            b"cs" => {
                self.mark_complex_script_run(on_off_element_enabled(reader, element)?);
                Frame::Other
            }
            b"rtl" => {
                self.mark_right_to_left_run(on_off_element_enabled(reader, element)?);
                Frame::Other
            }
            b"highlight" => {
                if let Some(highlighted) = attribute(reader, element, b"val")?
                    .as_deref()
                    .and_then(semantic_highlight_value)
                {
                    self.mark_highlighted_run(highlighted);
                }
                Frame::Other
            }
            b"vertAlign" => {
                match attribute(reader, element, b"val")?.as_deref() {
                    Some("superscript") => self.mark_superscript_run(true),
                    Some("baseline" | "subscript") => self.mark_superscript_run(false),
                    _ => {}
                }
                Frame::Other
            }
            b"t" | b"delText" => {
                Frame::PseudoText(PseudoTextFrame::text(preserves_xml_space(reader, element)?))
            }
            b"tab" | b"ptab" => {
                self.append_text_control(TextControl::Tab)?;
                Frame::Other
            }
            b"br" => {
                let control = match attribute(reader, element, b"type")?.as_deref() {
                    Some("page") => TextControl::PageBreak,
                    Some("column") => TextControl::ColumnBreak,
                    _ => TextControl::LineBreak,
                };
                self.append_text_control(control)?;
                Frame::Other
            }
            b"cr" => {
                self.append_text_control(TextControl::CarriageReturn)?;
                Frame::Other
            }
            b"footnoteReference" | b"endnoteReference" => {
                let visible =
                    attribute(reader, element, b"customMarkFollows")?.is_none_or(|value| {
                        matches!(value.to_ascii_lowercase().as_str(), "0" | "false" | "off")
                    });
                if visible {
                    self.append_text_control(TextControl::NoteReference)?;
                }
                Frame::Other
            }
            b"softHyphen" => {
                self.append_text_control(TextControl::SoftHyphen)?;
                Frame::Other
            }
            b"noBreakHyphen" => {
                self.append_text_control(TextControl::NoBreakHyphen)?;
                Frame::Other
            }
            b"sym" => {
                if let Some(value) = attribute(reader, element, b"char")? {
                    let font = attribute(reader, element, b"font")?;
                    self.append_pseudo_text(&symbol_text(&value, font.as_deref()))?;
                }
                Frame::Other
            }
            _ => Frame::Other,
        };
        self.frames.push(frame);
        Ok(())
    }

    fn end(
        &mut self,
        styles: Result<&StyleSheet, FormattingUnknownReason>,
    ) -> Result<(), ProjectionError> {
        let frame = self
            .frames
            .pop()
            .ok_or(ProjectionError::InvalidDocumentXml)?;
        match frame {
            Frame::Paragraph => self.finish_paragraph(styles)?,
            Frame::Table(table) => self.finish_container_review(table.review)?,
            Frame::Row(row) => self.finish_container_review(row.review)?,
            Frame::Cell(cell) => self.finish_container_review(cell.review)?,
            Frame::Hyperlink(Some(reference)) => self.references.push(reference),
            Frame::PseudoText(frame) => match frame.kind {
                PseudoTextKind::Text { preserve_space } => {
                    let text = if preserve_space {
                        frame.text.as_str()
                    } else {
                        trim_xml_whitespace(&frame.text)
                    };
                    self.append_pseudo_text(text)?;
                }
                PseudoTextKind::MathText => self.append_pseudo_text(&frame.text)?,
                PseudoTextKind::Instruction => self.append_field_instruction(&frame.text),
            },
            Frame::Run(run) => {
                let start = self.current_review_point();
                if !run.hidden
                    && !self.pseudo_text_is_suppressed()
                    && let Some(paragraph) = self.current_paragraph.as_mut()
                {
                    let mut effective = match styles {
                        Ok(styles) => {
                            let resolved = if run.character_style_id.is_none()
                                && run.direct_styles == TextProperties::default()
                            {
                                paragraph.resolve_text_base(styles)
                            } else {
                                styles.resolve_text(TextStyleInput {
                                    paragraph: &paragraph.properties,
                                    character_style_id: run.character_style_id.as_deref(),
                                    direct: run.direct_styles,
                                })
                            };
                            resolved.unwrap_or_else(|()| {
                                self.formatting_completeness.mark_styles_unread();
                                run.direct_styles
                            })
                        }
                        Err(_) => run.direct_styles,
                    };
                    // Highlight spans describe direct run markup, never style inheritance.
                    effective.highlighted = run.direct_styles.highlighted;
                    paragraph.append(&run.text, effective)?;
                }
                if let (Some(start), Some(end)) = (start, self.current_review_point()) {
                    self.locate_owned_revisions(
                        &run.property_review_indices,
                        OwnedRevisionSpan::Content(ReviewSpan { start, end }),
                    )?;
                }
            }
            Frame::ChangeSnapshot(snapshot) => {
                if self.revision_view == RevisionView::Original
                    && !matches!(snapshot.status, SnapshotStatus::Applied)
                {
                    self.revision_unsupported
                        .insert(RevisionUnsupportedReason::UnsupportedRevisionMarkup);
                }
            }
            Frame::Revision(revision) => self.finish_attributed_revision(revision)?,
            _ => {}
        }
        Ok(())
    }

    fn snapshot_owner(&self, name: &[u8]) -> SnapshotOwner {
        match (name, self.frames.last()) {
            (b"rPrChange", Some(Frame::RunProperties(properties))) => {
                if matches!(self.frames.get(properties.run_frame), Some(Frame::Run(_))) {
                    SnapshotOwner::Run {
                        frame: properties.run_frame,
                        hidden_eligible: properties.hidden_eligible,
                    }
                } else if self.inside_paragraph_mark_properties() {
                    SnapshotOwner::ParagraphMark
                } else {
                    SnapshotOwner::Unsupported
                }
            }
            (b"pPrChange", Some(Frame::ParagraphProperties))
                if self.current_paragraph.is_some() =>
            {
                SnapshotOwner::Paragraph
            }
            (b"tblPrChange", Some(Frame::TableProperties))
                if matches!(self.frames.iter().rev().nth(1), Some(Frame::Table(_))) =>
            {
                SnapshotOwner::Table
            }
            (b"trPrChange", Some(Frame::TableRowProperties))
                if matches!(self.frames.iter().rev().nth(1), Some(Frame::Row(_))) =>
            {
                SnapshotOwner::Row
            }
            (b"tcPrChange", Some(Frame::TableCellProperties))
                if matches!(self.frames.iter().rev().nth(1), Some(Frame::Cell(_))) =>
            {
                SnapshotOwner::Cell
            }
            (b"tblGridChange", Some(Frame::TableGrid))
                if matches!(self.frames.iter().rev().nth(1), Some(Frame::Table(_))) =>
            {
                SnapshotOwner::Grid
            }
            (b"sectPrChange", Some(Frame::SectionProperties))
                if matches!(
                    self.frames.iter().rev().nth(1),
                    Some(Frame::Body | Frame::ParagraphProperties)
                ) =>
            {
                SnapshotOwner::Section
            }
            (b"tblPrExChange", Some(Frame::TablePropertyExceptions))
                if matches!(self.frames.iter().rev().nth(1), Some(Frame::Row(_))) =>
            {
                SnapshotOwner::TableExceptions
            }
            _ => SnapshotOwner::Unsupported,
        }
    }

    fn start_snapshot_child(&mut self, name: &[u8]) -> Result<bool, ProjectionError> {
        if self.revision_view == RevisionView::Current {
            self.frames.push(Frame::SnapshotIgnored);
            return Ok(true);
        }
        if let Some(Frame::ChangeSnapshot(snapshot)) = self.frames.last_mut() {
            let owner = snapshot.owner;
            let matches_root = matches!(
                (owner, name),
                (
                    SnapshotOwner::Run { .. } | SnapshotOwner::ParagraphMark,
                    b"rPr"
                ) | (SnapshotOwner::Paragraph, b"pPr")
                    | (SnapshotOwner::Table, b"tblPr")
                    | (SnapshotOwner::Row, b"trPr")
                    | (SnapshotOwner::Cell, b"tcPr")
                    | (SnapshotOwner::Grid, b"tblGrid")
                    | (SnapshotOwner::Section, b"sectPr")
                    | (SnapshotOwner::TableExceptions, b"tblPrEx")
            );
            if !matches_root || !matches!(snapshot.status, SnapshotStatus::AwaitingRoot) {
                snapshot.status = SnapshotStatus::Unsupported;
                self.frames.push(Frame::SnapshotIgnored);
                return Ok(true);
            }
            snapshot.status = SnapshotStatus::Applied;
            let frame = self.restore_snapshot_owner(owner)?;
            self.frames.push(frame);
            return Ok(true);
        }
        if matches!(self.frames.last(), Some(Frame::ParagraphMarkProperties))
            && matches!(name, b"moveFrom" | b"moveTo")
        {
            self.revision_unsupported
                .insert(RevisionUnsupportedReason::UnsupportedRevisionMarkup);
            self.frames.push(Frame::SnapshotIgnored);
            return Ok(true);
        }
        let supported_property = matches!(
            (self.frames.last(), name),
            (
                Some(Frame::RunProperties(_)),
                b"rStyle"
                    | b"b"
                    | b"bCs"
                    | b"cs"
                    | b"rtl"
                    | b"highlight"
                    | b"vertAlign"
                    | b"vanish"
            ) | (
                Some(Frame::ParagraphProperties),
                b"pStyle" | b"ind" | b"jc" | b"outlineLvl" | b"numPr"
            ) | (Some(Frame::NumberingProperties), b"numId" | b"ilvl")
                | (Some(Frame::TableProperties), b"tblStyle")
                | (Some(Frame::ParagraphMarkProperties), b"ins" | b"del")
        );
        if supported_property {
            return Ok(false);
        }
        self.frames.push(Frame::SnapshotIgnored);
        Ok(true)
    }

    fn restore_snapshot_owner(&mut self, owner: SnapshotOwner) -> Result<Frame, ProjectionError> {
        match owner {
            SnapshotOwner::Run {
                frame,
                hidden_eligible,
            } => {
                let Some(Frame::Run(run)) = self.frames.get_mut(frame) else {
                    return Err(ProjectionError::InvalidDocumentXml);
                };
                run.direct_styles = TextProperties::default();
                run.character_style_id = None;
                run.hidden = false;
                Ok(Frame::RunProperties(RunPropertiesFrame {
                    run_frame: frame,
                    hidden_eligible,
                }))
            }
            SnapshotOwner::Paragraph => {
                // CT_PPrBase excludes the independent paragraph-mark properties.
                let paragraph = self
                    .current_paragraph
                    .as_mut()
                    .ok_or(ProjectionError::InvalidDocumentXml)?;
                paragraph.properties = ParagraphProperties {
                    table_style: std::mem::take(&mut paragraph.properties.table_style),
                    ..ParagraphProperties::default()
                };
                paragraph.resolved_text_base = None;
                Ok(Frame::ParagraphProperties)
            }
            SnapshotOwner::Table => {
                let table =
                    enclosing_table(&mut self.frames).ok_or(ProjectionError::InvalidDocumentXml)?;
                table.style_id = None;
                Ok(Frame::TableProperties)
            }
            SnapshotOwner::Row => Ok(Frame::TableRowProperties),
            SnapshotOwner::Cell => Ok(Frame::TableCellProperties),
            SnapshotOwner::Grid => Ok(Frame::TableGrid),
            SnapshotOwner::Section => Ok(Frame::SectionProperties),
            SnapshotOwner::TableExceptions => Ok(Frame::TablePropertyExceptions),
            SnapshotOwner::ParagraphMark => {
                let paragraph = self
                    .current_paragraph
                    .as_mut()
                    .ok_or(ProjectionError::InvalidDocumentXml)?;
                paragraph.paragraph_mark_revision = None;
                Ok(Frame::ParagraphMarkProperties)
            }
            SnapshotOwner::Unsupported => Err(ProjectionError::InvalidDocumentXml),
        }
    }

    fn record_container_property_revision(
        &mut self,
        name: &[u8],
        review_index: usize,
    ) -> Result<(), ProjectionError> {
        let valid_parent = matches!(
            (name, self.frames.last()),
            (b"tblPrChange", Some(Frame::TableProperties))
                | (b"tblGridChange", Some(Frame::TableGrid))
                | (b"trPrChange", Some(Frame::TableRowProperties))
                | (b"tcPrChange", Some(Frame::TableCellProperties))
                | (b"tblPrExChange", Some(Frame::TablePropertyExceptions))
        );
        if !valid_parent {
            return Ok(());
        }
        let review = self
            .frames
            .iter_mut()
            .rev()
            .find_map(|frame| match (name, frame) {
                (b"tblPrChange" | b"tblGridChange", Frame::Table(table)) => Some(&mut table.review),
                (b"trPrChange" | b"tblPrExChange", Frame::Row(row)) => Some(&mut row.review),
                (b"tcPrChange", Frame::Cell(cell)) => Some(&mut cell.review),
                _ => None,
            });
        if let Some(review) = review {
            let slot = match name {
                b"tblGridChange" => &mut review.grid_review,
                b"tblPrExChange" => &mut review.exception_review,
                _ => &mut review.property_review,
            };
            if slot.replace(review_index).is_some() {
                return Err(ProjectionError::InvalidDocumentXml);
            }
        }
        Ok(())
    }

    fn finish_container_review(&mut self, review: ContainerReview) -> Result<(), ProjectionError> {
        if review.paragraph_start >= self.paragraphs.len() {
            return Ok(());
        }
        let end = self
            .paragraphs
            .last()
            .and_then(paragraph_end)
            .ok_or(ProjectionError::InvalidDocumentXml)?;
        for review_index in [
            review.property_review,
            review.grid_review,
            review.exception_review,
        ]
        .into_iter()
        .flatten()
        {
            self.locate_owned_revisions(
                std::slice::from_ref(&review_index),
                OwnedRevisionSpan::Content(ReviewSpan {
                    start: paragraph_start(review.paragraph_start),
                    end,
                }),
            )?;
        }
        Ok(())
    }

    fn finish_paragraph(
        &mut self,
        styles: Result<&StyleSheet, FormattingUnknownReason>,
    ) -> Result<(), ProjectionError> {
        let mut paragraph = self
            .current_paragraph
            .take()
            .ok_or(ProjectionError::InvalidDocumentXml)?;
        if styles.is_ok_and(|styles| paragraph.resolve_text_base(styles).is_err()) {
            self.formatting_completeness.mark_styles_unread();
        }
        let ordinal = self.paragraphs.len();
        if let Some(revision) = paragraph.paragraph_mark_revision {
            self.paragraph_mark_revisions.insert(ordinal, revision);
        }
        let mark = ReviewPoint {
            paragraph_ordinal: ordinal,
            utf8: u32::try_from(paragraph.text.len())
                .map_err(|_| ProjectionError::InvalidDocumentXml)?,
            utf16: paragraph.utf16_len,
        };
        self.locate_owned_revisions(
            &paragraph.paragraph_review_indices,
            OwnedRevisionSpan::Paragraph(ReviewSpan {
                start: paragraph_start(ordinal),
                end: mark,
            }),
        )?;
        self.paragraphs.push(RawProjectedParagraph {
            ordinal: self.paragraphs.len(),
            package_paragraph_id: paragraph.package_paragraph_id,
            text: paragraph.text,
            utf16_len: paragraph.utf16_len,
            formatting: paragraph.formatting,
            structure: paragraph.structure,
            container: paragraph.container,
            properties: paragraph.properties,
        });
        Ok(())
    }

    fn record_attributed_revision(
        &mut self,
        reader: &NsReader<&[u8]>,
        element: &BytesStart<'_>,
        name: &[u8],
    ) -> Result<Option<usize>, ProjectionError> {
        let Some(kind) = revision_fact_kind(name) else {
            return Ok(None);
        };
        let ReviewRevisionCollection::Complete {
            maximum_facts,
            revisions,
            ..
        } = &mut self.review_revisions
        else {
            return Ok(None);
        };
        if revisions.len() >= *maximum_facts {
            self.review_revisions = ReviewRevisionCollection::LimitExceeded;
            return Ok(None);
        }
        let review_index = revisions.len();
        revisions.push(AttributedRevision {
            kind,
            author: attribute(reader, element, b"author")?.unwrap_or_default(),
            date: attribute(reader, element, b"date")?,
            revision_id: attribute(reader, element, b"id")?,
            content: ReviewDetail::Unknown(ReviewFactUnknownReason::UnsupportedLocation),
        });
        Ok(Some(review_index))
    }

    fn finish_attributed_revision(
        &mut self,
        revision: RevisionFrame,
    ) -> Result<(), ProjectionError> {
        let (Some(review_index), Some(start), Some(end)) = (
            revision.review_index,
            revision.start,
            self.current_review_point(),
        ) else {
            return Ok(());
        };
        let ReviewRevisionCollection::Complete { revisions, .. } = &mut self.review_revisions
        else {
            return Ok(());
        };
        let attributed = revisions
            .get_mut(review_index)
            .ok_or(ProjectionError::InvalidDocumentXml)?;
        attributed.content = ReviewDetail::Known(RevisionContent {
            span: ReviewSpan { start, end },
            payload: RevisionPayload::from_text(revision.text),
        });
        Ok(())
    }

    fn locate_owned_revisions(
        &mut self,
        review_indices: &[usize],
        owner: OwnedRevisionSpan,
    ) -> Result<(), ProjectionError> {
        let ReviewRevisionCollection::Complete { revisions, .. } = &mut self.review_revisions
        else {
            return Ok(());
        };
        for &review_index in review_indices {
            let revision = revisions
                .get_mut(review_index)
                .ok_or(ProjectionError::InvalidDocumentXml)?;
            let span = match owner {
                OwnedRevisionSpan::Content(span) => span,
                OwnedRevisionSpan::Paragraph(span) => {
                    if revision.kind == RevisionFactKind::ParagraphPropertiesChange {
                        span
                    } else {
                        ReviewSpan {
                            start: span.end,
                            end: span.end,
                        }
                    }
                }
            };
            let payload = match revision.kind {
                RevisionFactKind::RunPropertiesChange
                | RevisionFactKind::ParagraphPropertiesChange
                | RevisionFactKind::TablePropertiesChange
                | RevisionFactKind::TablePropertiesExceptionChange
                | RevisionFactKind::TableRowPropertiesChange
                | RevisionFactKind::TableCellPropertiesChange
                | RevisionFactKind::TableGridChange => RevisionPayload::FormattingOnly,
                _ => RevisionPayload::ParagraphMark,
            };
            revision.content = ReviewDetail::Known(RevisionContent { span, payload });
        }
        Ok(())
    }

    fn inside_body(&self) -> bool {
        self.frames.iter().any(|frame| matches!(frame, Frame::Body))
    }

    fn inside_textbox(&self) -> bool {
        self.frames
            .iter()
            .any(|frame| matches!(frame, Frame::Textbox))
    }

    fn inside_change_snapshot(&self) -> bool {
        self.frames
            .iter()
            .any(|frame| matches!(frame, Frame::ChangeSnapshot(_)))
    }

    fn inside_paragraph_mark_properties(&self) -> bool {
        self.current_paragraph.is_some()
            && self
                .frames
                .iter()
                .any(|frame| matches!(frame, Frame::ParagraphProperties))
            && !self
                .frames
                .iter()
                .any(|frame| matches!(frame, Frame::Run(_)))
    }

    fn inside_table_row_properties(&self) -> bool {
        self.frames
            .iter()
            .any(|frame| matches!(frame, Frame::TableRowProperties))
    }

    fn pseudo_text_is_suppressed(&self) -> bool {
        self.frames.iter().any(|frame| {
            matches!(
                frame,
                Frame::ParagraphProperties
                    | Frame::RunProperties(_)
                    | Frame::ChangeSnapshot(_)
                    | Frame::Textbox
            ) || matches!(frame, Frame::Revision(revision) if revision.suppressed)
                || matches!(frame, Frame::Sdt(sdt) if sdt.placeholder)
        })
    }

    fn pseudo_text_is_structurally_suppressed(&self) -> bool {
        self.frames.iter().any(|frame| {
            matches!(
                frame,
                Frame::ParagraphProperties
                    | Frame::RunProperties(_)
                    | Frame::ChangeSnapshot(_)
                    | Frame::Textbox
            ) || matches!(frame, Frame::Sdt(sdt) if sdt.placeholder)
        })
    }

    fn append_pseudo_text(&mut self, text: &str) -> Result<(), ProjectionError> {
        if self.current_paragraph.is_none()
            || self.pseudo_text_is_structurally_suppressed()
            || self
                .frames
                .iter()
                .rev()
                .any(|frame| matches!(frame, Frame::Run(run) if run.hidden))
        {
            return Ok(());
        }
        self.append_review_text(text);
        if self.pseudo_text_is_suppressed() {
            return Ok(());
        }
        if let Some(run) = self.frames.iter_mut().rev().find_map(|frame| match frame {
            Frame::Run(run) => Some(run),
            _ => None,
        }) {
            run.text.push_str(text);
            return Ok(());
        }
        self.current_paragraph
            .as_mut()
            .ok_or(ProjectionError::InvalidDocumentXml)?
            .append(text, TextProperties::default())
    }

    fn append_review_text(&mut self, text: &str) {
        let ReviewRevisionCollection::Complete {
            remaining_detail_bytes,
            ..
        } = &mut self.review_revisions
        else {
            return;
        };
        let mut limit_exceeded = false;
        for frame in &mut self.frames {
            if let Frame::Revision(revision) = frame
                && revision.review_index.is_some()
            {
                let Some(remaining) = remaining_detail_bytes.checked_sub(text.len()) else {
                    limit_exceeded = true;
                    break;
                };
                *remaining_detail_bytes = remaining;
                revision.text.push_str(text);
            }
        }
        if limit_exceeded {
            self.review_revisions = ReviewRevisionCollection::LimitExceeded;
        }
    }

    fn current_review_point(&self) -> Option<ReviewPoint> {
        let paragraph = self.current_paragraph.as_ref()?;
        let run_text = if self.pseudo_text_is_suppressed() {
            None
        } else {
            self.frames.iter().rev().find_map(|frame| match frame {
                Frame::Run(run) if !run.hidden => Some(run.text.as_str()),
                _ => None,
            })
        };
        let run_utf8 = run_text.map_or(0, str::len);
        let run_utf16 = run_text.map_or(0, |text| text.encode_utf16().count());
        Some(ReviewPoint {
            paragraph_ordinal: self.paragraphs.len(),
            utf8: u32::try_from(paragraph.text.len().checked_add(run_utf8)?).ok()?,
            utf16: paragraph
                .utf16_len
                .checked_add(u32::try_from(run_utf16).ok()?)?,
        })
    }

    fn next_paragraph_start_review_point(&self) -> Option<ReviewPoint> {
        if self.current_paragraph.is_some() {
            return self.current_review_point();
        }
        self.inside_body().then_some(ReviewPoint {
            paragraph_ordinal: self.paragraphs.len(),
            utf8: 0,
            utf16: 0,
        })
    }

    fn previous_paragraph_end_review_point(&self) -> Option<ReviewPoint> {
        if self.current_paragraph.is_some() {
            return self.current_review_point();
        }
        self.paragraphs.last().and_then(paragraph_end)
    }

    fn review_comment_id(
        reader: &NsReader<&[u8]>,
        element: &BytesStart<'_>,
    ) -> Result<Option<String>, ProjectionError> {
        attribute(reader, element, b"id")
    }

    fn start_review_comment_anchor(
        &mut self,
        reader: &NsReader<&[u8]>,
        element: &BytesStart<'_>,
    ) -> Result<(), ProjectionError> {
        let (Some(comment_id), Some(point)) = (
            Self::review_comment_id(reader, element)?,
            self.next_paragraph_start_review_point(),
        ) else {
            return Ok(());
        };
        if self.invalid_review_comment_anchors.contains(&comment_id) {
            return Ok(());
        }
        if self
            .open_review_comment_anchors
            .insert(comment_id.clone(), point)
            .is_some()
        {
            self.open_review_comment_anchors.remove(&comment_id);
            self.review_comment_anchors.remove(&comment_id);
            self.invalid_review_comment_anchors.insert(comment_id);
        }
        Ok(())
    }

    fn suppress_review_comment_anchor(
        &mut self,
        reader: &NsReader<&[u8]>,
        element: &BytesStart<'_>,
    ) -> Result<(), ProjectionError> {
        let Some(comment_id) = Self::review_comment_id(reader, element)? else {
            return Ok(());
        };
        self.open_review_comment_anchors.remove(&comment_id);
        self.review_comment_anchors.remove(&comment_id);
        self.invalid_review_comment_anchors.insert(comment_id);
        Ok(())
    }

    fn end_review_comment_anchor(
        &mut self,
        reader: &NsReader<&[u8]>,
        element: &BytesStart<'_>,
    ) -> Result<(), ProjectionError> {
        let (Some(comment_id), Some(end)) = (
            Self::review_comment_id(reader, element)?,
            self.previous_paragraph_end_review_point(),
        ) else {
            return Ok(());
        };
        if self.invalid_review_comment_anchors.contains(&comment_id) {
            return Ok(());
        }
        let Some(start) = self.open_review_comment_anchors.remove(&comment_id) else {
            self.review_comment_anchors.remove(&comment_id);
            self.invalid_review_comment_anchors.insert(comment_id);
            return Ok(());
        };
        if self
            .review_comment_anchors
            .insert(comment_id.clone(), ReviewSpan { start, end })
            .is_some()
        {
            self.review_comment_anchors.remove(&comment_id);
            self.invalid_review_comment_anchors.insert(comment_id);
        }
        Ok(())
    }

    fn record_review_comment_reference(
        &mut self,
        reader: &NsReader<&[u8]>,
        element: &BytesStart<'_>,
    ) -> Result<(), ProjectionError> {
        let (Some(comment_id), Some(point)) = (
            Self::review_comment_id(reader, element)?,
            self.current_review_point(),
        ) else {
            return Ok(());
        };
        if self.invalid_review_comment_anchors.contains(&comment_id) {
            return Ok(());
        }
        if !self.review_comment_anchors.contains_key(&comment_id)
            && !self.open_review_comment_anchors.contains_key(&comment_id)
        {
            self.review_comment_anchors.insert(
                comment_id,
                ReviewSpan {
                    start: point,
                    end: point,
                },
            );
        }
        Ok(())
    }

    fn append_pseudo_content(&mut self, text: &str) -> Result<(), ProjectionError> {
        let Some(Frame::PseudoText(frame)) = self.frames.last_mut() else {
            return Err(ProjectionError::InvalidDocumentXml);
        };
        frame.text.push_str(text);
        Ok(())
    }

    fn append_text_control(&mut self, control: TextControl) -> Result<(), ProjectionError> {
        if let Some(text) = control.materialize(self.text_materialization) {
            self.append_pseudo_text(text)?;
        }
        Ok(())
    }

    fn append_field_instruction(&mut self, text: &str) {
        let Some(field) = self.fields.last_mut() else {
            self.references_complete = false;
            return;
        };
        if matches!(field.source, FieldSource::Hidden) {
            return;
        }
        if field.separated || field.instruction.len().saturating_add(text.len()) > 4096 {
            self.references_complete = false;
            return;
        }
        field.instruction.push_str(text);
    }

    fn simple_field(
        &mut self,
        reader: &NsReader<&[u8]>,
        element: &BytesStart<'_>,
    ) -> Result<(), ProjectionError> {
        let instruction = attribute(reader, element, b"instr")?;
        let source = self.current_field_source();
        if matches!(source, FieldSource::Hidden) {
            return Ok(());
        }
        let Some(instruction) = instruction.filter(|value| value.len() <= 4096) else {
            self.references_complete = false;
            return Ok(());
        };
        self.record_field_reference(&instruction, source);
        Ok(())
    }

    fn field_character(
        &mut self,
        reader: &NsReader<&[u8]>,
        element: &BytesStart<'_>,
    ) -> Result<(), ProjectionError> {
        match attribute(reader, element, b"fldCharType")?.as_deref() {
            Some("begin") => self.fields.push(FieldFrame {
                source: self.current_field_source(),
                instruction: String::new(),
                separated: false,
            }),
            Some("separate") => {
                let Some(mut field) = self.fields.pop() else {
                    self.references_complete = false;
                    return Ok(());
                };
                if field.separated {
                    self.references_complete = false;
                } else {
                    self.record_field_reference(&field.instruction, field.source);
                    field.separated = true;
                }
                self.fields.push(field);
            }
            Some("end") => {
                let Some(field) = self.fields.pop() else {
                    self.references_complete = false;
                    return Ok(());
                };
                if !field.separated {
                    self.record_field_reference(&field.instruction, field.source);
                }
            }
            _ => self.references_complete = false,
        }
        Ok(())
    }

    fn current_field_source(&self) -> FieldSource {
        if self.pseudo_text_is_suppressed() {
            return FieldSource::Hidden;
        }
        self.current_review_point()
            .map_or(FieldSource::Unsupported, FieldSource::Projected)
    }

    fn record_field_reference(&mut self, instruction: &str, source: FieldSource) {
        if matches!(source, FieldSource::Hidden) {
            return;
        }
        match internal_reference_target(instruction) {
            Ok(Some(reference_id)) => {
                let FieldSource::Projected(source) = source else {
                    self.references_complete = false;
                    return;
                };
                self.references.push(RawInternalReference {
                    reference_id,
                    source,
                });
            }
            Ok(None) => {}
            Err(()) => self.references_complete = false,
        }
    }

    fn current_point(&self) -> Option<ReviewPoint> {
        if self.current_paragraph.is_some() {
            return self.current_review_point();
        }
        if !matches!(self.frames.last(), Some(Frame::Body)) {
            return None;
        }
        self.paragraphs
            .last()
            .map_or(Some(paragraph_start(0)), paragraph_end)
    }

    fn current_bookmark_point(&self) -> Option<BookmarkPoint> {
        if self.current_paragraph.is_some() {
            return self.current_point().map(BookmarkPoint::Paragraph);
        }
        matches!(
            self.frames.last(),
            Some(
                Frame::Body
                    | Frame::BlockContent
                    | Frame::Table(_)
                    | Frame::Row(_)
                    | Frame::Cell(_)
            )
        )
        .then(|| BookmarkPoint::ParagraphBoundary(self.paragraphs.len()))
    }

    fn start_bookmark(
        &mut self,
        reader: &NsReader<&[u8]>,
        element: &BytesStart<'_>,
    ) -> Result<(), ProjectionError> {
        let id = attribute(reader, element, b"id")?.and_then(|value| value.parse::<u32>().ok());
        let name = attribute(reader, element, b"name")?;
        let point = self.current_bookmark_point();
        let (Some(id), Some(name), Some(point)) = (id, name, point) else {
            self.bookmarks_complete = false;
            return Ok(());
        };
        if name.is_empty() {
            self.bookmarks_complete = false;
            return Ok(());
        }
        self.open_bookmarks
            .entry(id)
            .or_default()
            .starts
            .push(Some((name, point)));
        Ok(())
    }

    fn end_bookmark(
        &mut self,
        reader: &NsReader<&[u8]>,
        element: &BytesStart<'_>,
    ) -> Result<(), ProjectionError> {
        let id = attribute(reader, element, b"id")?.and_then(|value| value.parse::<u32>().ok());
        let point = self.current_bookmark_point();
        let (Some(id), Some(end)) = (id, point) else {
            self.bookmarks_complete = false;
            return Ok(());
        };
        let Some(queue) = self.open_bookmarks.get_mut(&id) else {
            self.bookmarks_complete = false;
            return Ok(());
        };
        let Some((name, start)) = queue.starts.get_mut(queue.cursor).and_then(Option::take) else {
            self.bookmarks_complete = false;
            return Ok(());
        };
        queue.cursor = queue
            .cursor
            .checked_add(1)
            .ok_or(ProjectionError::InvalidDocumentXml)?;
        if queue.cursor == queue.starts.len() {
            self.open_bookmarks.remove(&id);
        }
        self.bookmarks.push(PendingBookmarkRange {
            id,
            name,
            start,
            end,
        });
        Ok(())
    }

    fn mark_placeholder(&mut self) {
        let Some(sdt) = self.frames.iter_mut().rev().find_map(|frame| match frame {
            Frame::Sdt(sdt) => Some(sdt),
            _ => None,
        }) else {
            return;
        };
        sdt.placeholder = true;
        if let Some(paragraph) = self.current_paragraph.as_mut() {
            paragraph.truncate(sdt.text_utf8_start, sdt.text_utf16_start);
        }
    }

    fn mark_hidden_run(&mut self) {
        let Some((run_frame, hidden_eligible)) =
            self.frames.iter().rev().find_map(|frame| match frame {
                Frame::RunProperties(properties) => {
                    Some((properties.run_frame, properties.hidden_eligible))
                }
                _ => None,
            })
        else {
            return;
        };
        if !hidden_eligible || run_frame == usize::MAX {
            return;
        }
        if let Some(Frame::Run(run)) = self.frames.get_mut(run_frame) {
            run.hidden = true;
        }
    }

    fn set_run_character_style(&mut self, style_id: Option<String>) {
        let Some(Frame::RunProperties(properties)) = self.frames.last() else {
            return;
        };
        let run_frame = properties.run_frame;
        if let Some(Frame::Run(run)) = self.frames.get_mut(run_frame) {
            run.character_style_id = style_id;
        }
    }

    fn mark_bold_run(&mut self, enabled: bool) {
        let Some(Frame::RunProperties(properties)) = self.frames.last() else {
            return;
        };
        let run_frame = properties.run_frame;
        if let Some(Frame::Run(run)) = self.frames.get_mut(run_frame) {
            run.direct_styles.bold = Some(enabled);
        }
    }

    fn mark_complex_script_bold_run(&mut self, enabled: bool) {
        let Some(Frame::RunProperties(properties)) = self.frames.last() else {
            return;
        };
        let run_frame = properties.run_frame;
        if let Some(Frame::Run(run)) = self.frames.get_mut(run_frame) {
            run.direct_styles.complex_script_bold = Some(enabled);
        }
    }

    fn mark_complex_script_run(&mut self, enabled: bool) {
        let Some(Frame::RunProperties(properties)) = self.frames.last() else {
            return;
        };
        let run_frame = properties.run_frame;
        if let Some(Frame::Run(run)) = self.frames.get_mut(run_frame) {
            run.direct_styles.force_complex_script = Some(enabled);
        }
    }

    fn mark_right_to_left_run(&mut self, enabled: bool) {
        let Some(Frame::RunProperties(properties)) = self.frames.last() else {
            return;
        };
        let run_frame = properties.run_frame;
        if let Some(Frame::Run(run)) = self.frames.get_mut(run_frame) {
            run.direct_styles.right_to_left = Some(enabled);
        }
    }

    fn mark_highlighted_run(&mut self, enabled: bool) {
        let Some(Frame::RunProperties(properties)) = self.frames.last() else {
            return;
        };
        let run_frame = properties.run_frame;
        if let Some(Frame::Run(run)) = self.frames.get_mut(run_frame) {
            run.direct_styles.highlighted = Some(enabled);
        }
    }

    fn mark_superscript_run(&mut self, enabled: bool) {
        let Some(Frame::RunProperties(properties)) = self.frames.last() else {
            return;
        };
        let run_frame = properties.run_frame;
        if let Some(Frame::Run(run)) = self.frames.get_mut(run_frame) {
            run.direct_styles.superscript = Some(enabled);
        }
    }
}

const fn revision_fact_kind(name: &[u8]) -> Option<RevisionFactKind> {
    match name {
        b"ins" => Some(RevisionFactKind::Insertion),
        b"del" => Some(RevisionFactKind::Deletion),
        b"moveFrom" => Some(RevisionFactKind::MoveFrom),
        b"moveTo" => Some(RevisionFactKind::MoveTo),
        b"cellIns" => Some(RevisionFactKind::CellInsertion),
        b"cellDel" => Some(RevisionFactKind::CellDeletion),
        b"cellMerge" => Some(RevisionFactKind::CellMerge),
        b"pPrChange" => Some(RevisionFactKind::ParagraphPropertiesChange),
        b"rPrChange" => Some(RevisionFactKind::RunPropertiesChange),
        b"sectPrChange" => Some(RevisionFactKind::SectionPropertiesChange),
        b"tblPrChange" => Some(RevisionFactKind::TablePropertiesChange),
        b"tblPrExChange" => Some(RevisionFactKind::TablePropertiesExceptionChange),
        b"trPrChange" => Some(RevisionFactKind::TableRowPropertiesChange),
        b"tcPrChange" => Some(RevisionFactKind::TableCellPropertiesChange),
        b"tblGridChange" => Some(RevisionFactKind::TableGridChange),
        b"customXmlDelRangeStart" => Some(RevisionFactKind::CustomXmlDeletionRangeStart),
        b"customXmlDelRangeEnd" => Some(RevisionFactKind::CustomXmlDeletionRangeEnd),
        b"customXmlInsRangeStart" => Some(RevisionFactKind::CustomXmlInsertionRangeStart),
        b"customXmlInsRangeEnd" => Some(RevisionFactKind::CustomXmlInsertionRangeEnd),
        b"customXmlMoveFromRangeStart" => Some(RevisionFactKind::CustomXmlMoveFromRangeStart),
        b"customXmlMoveFromRangeEnd" => Some(RevisionFactKind::CustomXmlMoveFromRangeEnd),
        b"customXmlMoveToRangeStart" => Some(RevisionFactKind::CustomXmlMoveToRangeStart),
        b"customXmlMoveToRangeEnd" => Some(RevisionFactKind::CustomXmlMoveToRangeEnd),
        _ => None,
    }
}

fn enclosing_table(frames: &mut [Frame]) -> Option<&mut TableFrame> {
    for frame in frames.iter_mut().rev() {
        match frame {
            Frame::Table(table) => return Some(table),
            Frame::Row(_) | Frame::Cell(_) | Frame::Paragraph | Frame::Run(_) => return None,
            _ => {}
        }
    }
    None
}

fn enclosing_row(frames: &mut [Frame]) -> Option<&mut RowFrame> {
    for frame in frames.iter_mut().rev() {
        match frame {
            Frame::Row(row) => return Some(row),
            Frame::Table(_) | Frame::Cell(_) | Frame::Paragraph | Frame::Run(_) => return None,
            _ => {}
        }
    }
    None
}

const fn revision_is_suppressed(name: &[u8], view: RevisionView) -> bool {
    match view {
        RevisionView::Current => matches!(name, b"del" | b"moveFrom"),
        RevisionView::Original => matches!(name, b"ins" | b"moveTo"),
    }
}

const fn is_change_snapshot(name: &[u8]) -> bool {
    matches!(
        name,
        b"pPrChange"
            | b"rPrChange"
            | b"sectPrChange"
            | b"tblPrChange"
            | b"tblPrExChange"
            | b"trPrChange"
            | b"tcPrChange"
            | b"tblGridChange"
    )
}

const fn is_unsupported_revision_markup(name: &[u8]) -> bool {
    matches!(
        name,
        b"customXmlDelRangeStart"
            | b"customXmlDelRangeEnd"
            | b"customXmlInsRangeStart"
            | b"customXmlInsRangeEnd"
            | b"customXmlMoveFromRangeStart"
            | b"customXmlMoveFromRangeEnd"
            | b"customXmlMoveToRangeStart"
            | b"customXmlMoveToRangeEnd"
    )
}

const fn paragraph_break_is_removed(
    revision: Option<ParagraphMarkRevision>,
    view: RevisionView,
) -> bool {
    matches!(
        (revision, view),
        (Some(ParagraphMarkRevision::Removed), RevisionView::Current)
            | (Some(ParagraphMarkRevision::Added), RevisionView::Original)
    )
}

// Share the compiled coalescer between run projection and paragraph joins.
#[inline(never)]
fn append_formatting_span(spans: &mut Vec<TextFormattingSpan>, span: TextFormattingSpan) {
    if let Some(adjacent) = spans
        .iter_mut()
        .rev()
        .find(|previous| previous.style == span.style)
        && adjacent.end_utf16 == span.start_utf16
    {
        adjacent.end_utf16 = span.end_utf16;
        return;
    }
    spans.push(span);
}

/// Merges paragraphs whose break the selected view removes. When any merge
/// happens, returns where each source paragraph starts in the merged text, so
/// review points recorded against source paragraphs can be translated.
fn normalize_paragraph_revision_view(
    paragraphs: &mut Vec<RawProjectedParagraph>,
    paragraph_mark_revisions: &mut HashMap<usize, ParagraphMarkRevision>,
    view: RevisionView,
    unsupported: &mut BTreeSet<RevisionUnsupportedReason>,
) -> Result<Option<Vec<ReviewPoint>>, ProjectionError> {
    let mut normalized: Vec<RawProjectedParagraph> = Vec::with_capacity(paragraphs.len());
    let mut origins = Vec::with_capacity(paragraphs.len());
    let mut merge_previous = false;
    let mut merged_any = false;

    for (source_ordinal, mut paragraph) in std::mem::take(paragraphs).into_iter().enumerate() {
        let merge_next =
            paragraph_break_is_removed(paragraph_mark_revisions.remove(&source_ordinal), view);
        if merge_previous {
            let previous = normalized
                .last_mut()
                .ok_or(ProjectionError::InvalidDocumentXml)?;
            if previous.structure != paragraph.structure {
                unsupported.insert(RevisionUnsupportedReason::IncompatibleParagraphMerge);
                paragraph.ordinal = normalized.len();
                origins.push(paragraph_start(paragraph.ordinal));
                normalized.push(paragraph);
                merge_previous = merge_next;
                continue;
            }
            let utf16_offset = previous.utf16_len;
            origins.push(ReviewPoint {
                paragraph_ordinal: previous.ordinal,
                utf8: u32::try_from(previous.text.len())
                    .map_err(|_| ProjectionError::InvalidDocumentXml)?,
                utf16: utf16_offset,
            });
            for mut span in paragraph.formatting {
                span.start_utf16 = span
                    .start_utf16
                    .checked_add(utf16_offset)
                    .ok_or(ProjectionError::InvalidDocumentXml)?;
                span.end_utf16 = span
                    .end_utf16
                    .checked_add(utf16_offset)
                    .ok_or(ProjectionError::InvalidDocumentXml)?;
                append_formatting_span(&mut previous.formatting, span);
            }
            previous.text.push_str(&paragraph.text);
            previous.utf16_len = previous
                .utf16_len
                .checked_add(paragraph.utf16_len)
                .ok_or(ProjectionError::InvalidDocumentXml)?;
            merge_previous = merge_next;
            merged_any = true;
            continue;
        }

        paragraph.ordinal = normalized.len();
        origins.push(paragraph_start(paragraph.ordinal));
        normalized.push(paragraph);
        merge_previous = merge_next;
    }

    *paragraphs = normalized;
    Ok(merged_any.then_some(origins))
}

const fn paragraph_start(paragraph_ordinal: usize) -> ReviewPoint {
    ReviewPoint {
        paragraph_ordinal,
        utf8: 0,
        utf16: 0,
    }
}

/// Translates a point recorded against a source paragraph into the merged
/// paragraph coordinates. `None` means the point names no source paragraph.
fn relocate_review_point(origins: &[ReviewPoint], point: ReviewPoint) -> Option<ReviewPoint> {
    let origin = origins.get(point.paragraph_ordinal)?;
    Some(ReviewPoint {
        paragraph_ordinal: origin.paragraph_ordinal,
        utf8: origin.utf8.checked_add(point.utf8)?,
        utf16: origin.utf16.checked_add(point.utf16)?,
    })
}

fn relocate_block_point(
    origins: &[ReviewPoint],
    point: &mut ReviewPoint,
) -> Result<(), ProjectionError> {
    *point = relocate_review_point(origins, *point).ok_or(ProjectionError::InvalidDocumentXml)?;
    Ok(())
}

fn relocate_review_span(origins: &[ReviewPoint], span: ReviewSpan) -> Option<ReviewSpan> {
    Some(ReviewSpan {
        start: relocate_review_point(origins, span.start)?,
        end: relocate_review_point(origins, span.end)?,
    })
}

fn internal_reference_target(instruction: &str) -> Result<Option<String>, ()> {
    let tokens = field_tokens(instruction)?;
    let Some(command) = tokens.first() else {
        return Err(());
    };
    if ["REF", "PAGEREF", "NOTEREF"]
        .iter()
        .any(|candidate| command.eq_ignore_ascii_case(candidate))
    {
        return tokens
            .get(1)
            .filter(|target| !target.is_empty() && !target.starts_with('\\'))
            .cloned()
            .map(Some)
            .ok_or(());
    }
    if command.eq_ignore_ascii_case("HYPERLINK") {
        for (index, token) in tokens.iter().enumerate().skip(1) {
            if token.eq_ignore_ascii_case("\\l") {
                return tokens
                    .get(index.checked_add(1).ok_or(())?)
                    .filter(|target| !target.is_empty())
                    .cloned()
                    .map(Some)
                    .ok_or(());
            }
        }
    }
    Ok(None)
}

fn field_tokens(instruction: &str) -> Result<Vec<String>, ()> {
    let mut tokens = Vec::new();
    let mut token = String::new();
    let mut quoted = false;
    for character in instruction.chars() {
        match character {
            '"' => quoted = !quoted,
            whitespace if whitespace.is_whitespace() && !quoted => {
                if !token.is_empty() {
                    tokens.push(std::mem::take(&mut token));
                }
            }
            _ => token.push(character),
        }
    }
    if quoted {
        return Err(());
    }
    if !token.is_empty() {
        tokens.push(token);
    }
    Ok(tokens)
}

fn attribute(
    reader: &NsReader<&[u8]>,
    element: &BytesStart<'_>,
    name: &[u8],
) -> Result<Option<String>, ProjectionError> {
    for attribute in element.attributes() {
        let attribute = attribute.map_err(|_| ProjectionError::InvalidDocumentXml)?;
        let (namespace, local_name) = reader.resolver().resolve_attribute(attribute.key);
        if OoxmlNamespace::from_resolved(&namespace) == OoxmlNamespace::Wordprocessing
            && local_name.as_ref().as_bytes() == name
        {
            return attribute
                .normalized_value(XmlVersion::Implicit1_0)
                .map(|value| Some(value.into_owned()))
                .map_err(|_| ProjectionError::InvalidDocumentXml);
        }
    }
    Ok(None)
}

fn preserves_xml_space(
    reader: &NsReader<&[u8]>,
    element: &BytesStart<'_>,
) -> Result<bool, ProjectionError> {
    const XML_NAMESPACE: &[u8] = b"http://www.w3.org/XML/1998/namespace";

    for attribute in element.attributes() {
        let attribute = attribute.map_err(|_| ProjectionError::InvalidDocumentXml)?;
        let (namespace, local_name) = reader.resolver().resolve_attribute(attribute.key);
        if matches!(
            namespace,
            quick_xml::name::ResolveResult::Bound(namespace)
                if namespace.as_ref().as_bytes() == XML_NAMESPACE
        ) && local_name.as_ref().as_bytes() == b"space"
        {
            let value = attribute
                .normalized_value(XmlVersion::Implicit1_0)
                .map_err(|_| ProjectionError::InvalidDocumentXml)?;
            return match value.as_ref() {
                "default" => Ok(false),
                "preserve" => Ok(true),
                _ => Err(ProjectionError::InvalidDocumentXml),
            };
        }
    }
    Ok(false)
}

fn on_off_element_enabled(
    reader: &NsReader<&[u8]>,
    element: &BytesStart<'_>,
) -> Result<bool, ProjectionError> {
    Ok(attribute(reader, element, b"val")?
        .is_none_or(|value| !matches!(value.to_ascii_lowercase().as_str(), "0" | "false" | "off")))
}

fn trim_xml_whitespace(value: &str) -> &str {
    value.trim_matches(['\u{0009}', '\u{000a}', '\u{000d}', '\u{0020}'])
}

fn attribute_2010(
    reader: &NsReader<&[u8]>,
    element: &BytesStart<'_>,
    name: &[u8],
) -> Result<Option<String>, ProjectionError> {
    for attribute in element.attributes() {
        let attribute = attribute.map_err(|_| ProjectionError::InvalidDocumentXml)?;
        let (namespace, local_name) = reader.resolver().resolve_attribute(attribute.key);
        if OoxmlNamespace::from_resolved(&namespace) == OoxmlNamespace::Wordprocessing2010
            && local_name.as_ref().as_bytes() == name
        {
            return attribute
                .normalized_value(XmlVersion::Implicit1_0)
                .map(|value| Some(value.into_owned()))
                .map_err(|_| ProjectionError::InvalidDocumentXml);
        }
    }
    Ok(None)
}

fn symbol_text(value: &str, font: Option<&str>) -> String {
    let prefix = value
        .chars()
        .take_while(char::is_ascii_hexdigit)
        .collect::<String>();
    let Some(code) = (!prefix.is_empty())
        .then(|| u32::from_str_radix(&prefix, 16).ok())
        .flatten()
    else {
        return value.to_owned();
    };
    if let Some(replacement) = normalized_font_symbol(font, code) {
        return replacement.to_owned();
    }
    char::from_u32(code).unwrap_or('\u{fffd}').to_string()
}

struct FontSymbolMapping {
    font: &'static str,
    encoded: u32,
    unicode: &'static str,
}

// OOXML resolves w:sym through its named symbol font rather than the run font:
// https://learn.microsoft.com/dotnet/api/documentformat.openxml.wordprocessing.symbolchar
// Unicode's Wingdings mapping identifies the corresponding black-circle glyph:
// https://www.unicode.org/L2/L2011/11196-n4022-wingdings.pdf
// Keep this compatibility table explicit; unsupported font/code pairs preserve
// their encoded value instead of guessing from the glyph shape.
const FONT_SYMBOL_MAPPINGS: &[FontSymbolMapping] = &[FontSymbolMapping {
    font: "Wingdings",
    encoded: 0xF06C,
    unicode: "●",
}];

fn normalized_font_symbol(font: Option<&str>, encoded: u32) -> Option<&'static str> {
    let font = font?;
    FONT_SYMBOL_MAPPINGS
        .iter()
        .find(|mapping| mapping.encoded == encoded && mapping.font.eq_ignore_ascii_case(font))
        .map(|mapping| mapping.unicode)
}

#[cfg(test)]
mod collision_tests {
    use super::*;
    use proptest::prelude::*;
    use std::fmt::Write as _;

    fn project_bookmarks(body: &str) -> Result<RawDocumentProjection, TestCaseError> {
        let xml = format!(
            r#"<w:document xmlns:w="http://schemas.openxmlformats.org/wordprocessingml/2006/main"><w:body><w:p>{body}</w:p></w:body></w:document>"#
        );
        project_document_xml(
            xml.as_bytes(),
            32,
            RevisionView::Current,
            TextMaterialization::WordHost,
            Err(FormattingUnknownReason::DocumentPartOnly),
            None,
        )
        .map_err(|error| TestCaseError::fail(format!("unexpected fixture error: {error:?}")))
    }

    proptest! {
        #[test]
        fn balanced_duplicate_ranges_retain_all_content(id in 0_u32..100_000, count in 1_usize..24, overlap in any::<bool>()) {
            let end = format!(r#"<w:bookmarkEnd w:id="{id}"/>"#);
            let text = r"<w:r><w:t>Content</w:t></w:r>";
            let body = if overlap {
                let mut starts = String::new();
                for index in 0..count {
                    write!(starts, r#"<w:bookmarkStart w:id="{id}" w:name="target{index}"/>"#).map_err(|error| TestCaseError::fail(format!("fixture XML write failed: {error:?}")))?;
                }
                format!("{starts}{text}{}", end.repeat(count))
            } else {
                let mut ranges = String::new();
                for index in 0..count {
                    write!(ranges, r#"<w:bookmarkStart w:id="{id}" w:name="target{index}"/>{text}{end}"#).map_err(|error| TestCaseError::fail(format!("fixture XML write failed: {error:?}")))?;
                }
                ranges
            };
            let output = project_bookmarks(&body)?;
            let bookmarks = output.bookmarks.map_err(|error| TestCaseError::fail(format!("unexpected fixture error: {error:?}")))?;
            prop_assert_eq!(bookmarks.len(), count);
            prop_assert_eq!(&output.paragraphs.first().ok_or_else(|| TestCaseError::fail("fixture has one paragraph"))?.text, &"Content".repeat(if overlap { 1 } else { count }));
            for (index, bookmark) in bookmarks.iter().enumerate() {
                prop_assert_eq!(bookmark.id, id);
                prop_assert_eq!(&bookmark.name, &format!("target{index}"));
            }
        }
    }

    #[test]
    fn unmatched_colliding_ranges_remain_unknown() -> Result<(), TestCaseError> {
        let start = r#"<w:bookmarkStart w:id="37" w:name="target"/>"#;
        let end = r#"<w:bookmarkEnd w:id="37"/>"#;
        prop_assert!(
            project_bookmarks(&format!("{start}{start}{end}"))?
                .bookmarks
                .is_err(),
            "unmatched colliding range must remain unknown"
        );
        prop_assert!(
            project_bookmarks(&format!("{start}{end}{end}"))?
                .bookmarks
                .is_err(),
            "unmatched colliding range must remain unknown"
        );
        Ok(())
    }
}