omnist 0.2.1-alpha

//! The Document model — a canonical tree of ordered, labeled edges.
//!
//! Ported from `~/dev/omnist/omnist/document.py` (see issue #4). A Document
//! **node** is either a **leaf** holding a [`Scalar`], or an **internal
//! node** holding an *ordered list of edges*, each a `(label, child)` pair.
//! **Labels may repeat** — "many members" is the label `member` appearing
//! several times, not a field pointing to an array.
//!
//! ## Architecture (per issue #1, "architecture freedom")
//!
//! This port uses an arena: nodes live in a `Vec<Entry>` inside [`Doc`],
//! referenced by [`NodeId`] (an index newtype), not `Rc<RefCell<_>>`. Two
//! consequences that don't mirror Python/TypeScript 1:1:
//!
//! - **No cycle detection.** Python/TS guard against cycles because a plain
//!   `dict`/object can be made self-referential through shared mutable
//!   references. [`Value`] (this port's "plain value" input type, analogous
//!   to a parsed JSON value) is a plain owned tree — building a
//!   self-referential `Value` without `unsafe` or `Rc<RefCell<_>>` isn't
//!   possible, so the whole bug class is closed by the type system rather
//!   than checked at runtime (see the workflow playbook's "what NOT to
//!   carry over unexamined").
//! - **Integer-digit security cap.** Python's `_check_int_digits` defends
//!   against `str()`-converting an arbitrary-precision `int` with
//!   thousands of digits (a superlinear operation). Since issue #104,
//!   `Scalar::Int` is backed by arbitrary-precision `num_bigint::BigInt`,
//!   and format decoders (JSON, YAML, TOML) enforce the security cap
//!   (`crate::limits::MAX_INT_DIGITS`, 4300 digits) during lexing/parsing
//!   before BigInt construction.
//!
//! Observable behavior for everything else (construction, depth guard,
//! edge ordering, mutation semantics) matches the Python spec.

use indexmap::IndexMap;
use std::fmt;

use crate::error::DocumentError;

/// Maximum nesting depth for a Document node (matches Python's `_MAX_DEPTH`).
pub const MAX_DEPTH: usize = 200;

/// Maximum total node count for a single Document (matches the reference
/// default in omnist-spec docs/02-document-model.md Sec2.4: a depth limit
/// alone doesn't bound a shallow-but-enormous document, e.g. a million
/// sibling edges at depth 1). Enforced once, in `push`, the single arena
/// choke point every construction path (`build_node`, `push_raw`) funnels
/// through -- see omnist-rs#78: previously the only node-count guard in
/// this crate was scoped narrowly to `formats::yaml`'s anchor/alias
/// amplification defense, leaving every other construction path unbounded.
pub const MAX_NODES: usize = 1_000_000;

/// An index into a [`Doc`]'s arena. Opaque outside this module's crate.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
pub struct NodeId(usize);

/// A leaf value.
///
/// `Int` is arbitrary-precision (`BigInt`), not a fixed-width integer --
/// omnist-spec §2.2 defines `integer` as arbitrary-precision, bounded only
/// by the shared digit-count cap (`MAX_INT_DIGITS`), the same way Python's
/// native `int` and Go's `*big.Int` already are (issue #104; previously
/// `i64`, which silently rejected any literal past ~19 digits -- a
/// spec-conformance bug, not a permitted narrower-limit variation, since no
/// digit-count override was in play).
///
/// `Date`/`Time`/`Datetime` (issue #105) each hold their already
/// shape-validated, canonical ISO spelling -- no `chrono`/`time` crate
/// dependency, since the algebra never does temporal arithmetic, only
/// equality and canonical rendering (the same reasoning issue #104 applied
/// to `Int`). Constructing one always goes through
/// `crate::schema::is_iso_date`/`is_iso_time`/`is_iso_datetime` (shape
/// validation) and, for `Time`/`Datetime`,
/// `crate::schema::canonicalize_iso_time`/`canonicalize_iso_datetime`
/// (canonicalization) -- there is no code path that constructs one of
/// these holding un-validated or non-canonical text. This closed the
/// architecture gap issue #16 originally left open (previously cited as a
/// reason `Scalar` had no temporal variant at all); see issue #99's
/// `RawNode::TemporalLeaf`, now removed, for the write-hint mechanism this
/// replaces.
#[derive(Debug, Clone, PartialEq)]
pub enum Scalar {
    /// Null scalar value (spec §2.2).
    Null,
    /// Boolean scalar value (spec §2.2).
    Bool(bool),
    /// Arbitrary-precision integer scalar value (spec §2.2).
    Int(num_bigint::BigInt),
    /// IEEE 754 floating point scalar value (spec §2.2).
    Float(f64),
    /// UTF-8 string scalar value (spec §2.2).
    Str(String),
    /// ISO 8601 calendar date (`YYYY-MM-DD`, spec §2.2).
    Date(String),
    /// ISO 8601 clock time (`hh:mm:ss`, spec §2.2).
    Time(String),
    /// ISO 8601 date-time (`YYYY-MM-DDThh:mm:ss`, spec §2.2).
    Datetime(String),
}

impl fmt::Display for Scalar {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            Scalar::Null => write!(f, "null"),
            Scalar::Bool(b) => write!(f, "{b}"),
            Scalar::Int(i) => write!(f, "{i}"),
            Scalar::Float(x) => write!(f, "{x}"),
            Scalar::Str(s) => write!(f, "{s:?}"),
            Scalar::Date(s) | Scalar::Time(s) | Scalar::Datetime(s) => write!(f, "{s}"),
        }
    }
}

/// A plain input value (analogous to a parsed JSON/YAML/TOML value), the
/// thing [`Doc::of`]/[`Doc::add`]/[`Doc::set`] turn into canonical nodes.
///
/// `Object` uses [`IndexMap`] (per issue #1 §2) so key order — which the
/// Document model treats as data, not incidental — survives construction.
#[derive(Debug, Clone, PartialEq)]
pub enum Value {
    /// Null value.
    Null,
    /// Boolean value.
    Bool(bool),
    /// Arbitrary-precision integer value.
    Int(num_bigint::BigInt),
    /// Floating point value.
    Float(f64),
    /// String value.
    Str(String),
    /// See [`Scalar::Date`]/[`Scalar::Time`]/[`Scalar::Datetime`] (issue
    /// #105) -- always already shape-validated and canonical, same
    /// invariant.
    Date(String),
    /// ISO time value, matching [`Scalar::Time`].
    Time(String),
    /// ISO datetime value, matching [`Scalar::Datetime`].
    Datetime(String),
    /// Heterogeneous array value.
    Array(Vec<Value>),
    /// Key-value object mapping.
    Object(IndexMap<String, Value>),
}

impl Value {
    /// Borrow the underlying map if this is an `Object`, else `None`.
    /// Used by tests to inspect `to_grouped()`'s output without a
    /// match arm that (for any one call site) is only ever exercised on
    /// one side -- see the test suite for both an `Object` and a
    /// non-`Object` call site.
    #[cfg(test)]
    fn as_object(&self) -> Option<&IndexMap<String, Value>> {
        match self {
            Value::Object(m) => Some(m),
            _ => None,
        }
    }
}

impl From<Scalar> for Value {
    fn from(s: Scalar) -> Self {
        match s {
            Scalar::Null => Value::Null,
            Scalar::Bool(b) => Value::Bool(b),
            Scalar::Int(i) => Value::Int(i),
            Scalar::Float(x) => Value::Float(x),
            Scalar::Str(s) => Value::Str(s),
            Scalar::Date(s) => Value::Date(s),
            Scalar::Time(s) => Value::Time(s),
            Scalar::Datetime(s) => Value::Datetime(s),
        }
    }
}

#[derive(Debug, Clone)]
enum NodeData {
    Leaf(Scalar),
    Internal(Vec<(String, NodeId)>),
}

#[derive(Debug, Clone)]
struct Entry {
    data: NodeData,
    /// This node's own depth relative to the document root (root = 0).
    /// Recorded at construction time so a later mutation rooted at this
    /// node (add/set) can seed the depth guard from *here*, not from 0 --
    /// this is the exact bug class from omnist-ts#37 (a depth check reset
    /// to 0 on every mutation instead of accounting for how deep the
    /// mutation's attachment point already is) and omnist-ts#70 (a second
    /// writer that had the same reset bug because the guard lived in one
    /// place, not one shared helper called from every entry point).
    depth: usize,
}

/// The shared depth guard. Every construction/mutation path that can grow
/// the tree calls this before creating a node -- see the module-level test
/// `every_tree_mutating_entry_point_enforces_the_depth_guard` for the audit
/// that walks every public entry point and confirms each one does.
pub(crate) fn check_write_depth(depth: usize, path: &str) -> Result<(), DocumentError> {
    if depth > MAX_DEPTH {
        return Err(DocumentError::new(
            path,
            format!("nesting exceeds the maximum depth ({MAX_DEPTH})"),
        ));
    }
    Ok(())
}

fn join(path: &str, key: &str) -> String {
    let is_identifier = !key.is_empty()
        && key
            .chars()
            .next()
            .is_some_and(|c| c.is_alphabetic() || c == '_')
        && key.chars().all(|c| c.is_alphanumeric() || c == '_');
    if is_identifier {
        format!("{path}.{key}")
    } else {
        format!("{path}[\"{key}\"]")
    }
}

/// One (path, depth, value) triple to be turned into a child node -- mirrors
/// Python's `_children` generator, including its extra depth level for
/// items of an array value (an array value sits one level deeper than a
/// plain scalar/object value under the same key).
struct ChildSpec<'a> {
    path: String,
    depth: usize,
    value: &'a Value,
}

fn child_specs<'a>(
    v: &'a Value,
    path: &str,
    depth: usize,
) -> Result<Vec<ChildSpec<'a>>, DocumentError> {
    match v {
        Value::Array(items) => {
            let mut out = Vec::with_capacity(items.len());
            for (i, item) in items.iter().enumerate() {
                let ip = format!("{path}[{i}]");
                if matches!(item, Value::Array(_)) {
                    return Err(DocumentError::new(
                        ip,
                        "an array of arrays has no labeled-edge form",
                    ));
                }
                out.push(ChildSpec {
                    path: ip,
                    depth: depth + 1,
                    value: item,
                });
            }
            Ok(out)
        }
        other => Ok(vec![ChildSpec {
            path: path.to_string(),
            depth,
            value: other,
        }]),
    }
}

/// Turn a plain [`Value`] into a canonical node inside `arena`, returning
/// its [`NodeId`]. Mirrors Python's `build_node`.
fn build_node(
    arena: &mut Vec<Entry>,
    value: &Value,
    path: &str,
    depth: usize,
) -> Result<NodeId, DocumentError> {
    check_write_depth(depth, path)?;
    match value {
        Value::Object(map) => {
            let mut edges = Vec::new();
            for (k, v) in map {
                let kp = join(path, k);
                for spec in child_specs(v, &kp, depth + 1)? {
                    let cid = build_node(arena, spec.value, &spec.path, spec.depth)?;
                    edges.push((k.clone(), cid));
                }
            }
            push(arena, NodeData::Internal(edges), depth, path)
        }
        Value::Array(_) => Err(DocumentError::new(
            path,
            "a bare array has no labeled-edge form (arrays appear only as a repeated field)",
        )),
        // Scalars are matched directly as top-level arms of this match
        // (rather than through a `scalar => { match scalar { ... } }`
        // catch-all) so every arm is a real, exhaustive possibility --
        // no `Value::Array(_) | Value::Object(_) => unreachable!()` arm
        // to justify, since those two variants are already handled above.
        Value::Null => push(arena, NodeData::Leaf(Scalar::Null), depth, path),
        Value::Bool(b) => push(arena, NodeData::Leaf(Scalar::Bool(*b)), depth, path),
        Value::Int(i) => push(arena, NodeData::Leaf(Scalar::Int(i.clone())), depth, path),
        Value::Float(x) => push(arena, NodeData::Leaf(Scalar::Float(*x)), depth, path),
        Value::Date(s) => push(arena, NodeData::Leaf(Scalar::Date(s.clone())), depth, path),
        Value::Time(s) => push(arena, NodeData::Leaf(Scalar::Time(s.clone())), depth, path),
        Value::Datetime(s) => push(
            arena,
            NodeData::Leaf(Scalar::Datetime(s.clone())),
            depth,
            path,
        ),
        Value::Str(s) => push(arena, NodeData::Leaf(Scalar::Str(s.clone())), depth, path),
    }
}

/// The shared node-count guard, checked once here since every construction
/// path (`build_node`, `push_raw`) funnels through this single function.
fn push(
    arena: &mut Vec<Entry>,
    data: NodeData,
    depth: usize,
    path: &str,
) -> Result<NodeId, DocumentError> {
    if arena.len() >= MAX_NODES {
        return Err(DocumentError::new(
            path,
            format!("document exceeds the maximum node count ({MAX_NODES})"),
        ));
    }
    let id = NodeId(arena.len());
    arena.push(Entry { data, depth });
    Ok(id)
}

/// A guarded handle on a Document tree: an arena of nodes plus the root.
#[derive(Debug, Clone)]
pub struct Doc {
    arena: Vec<Entry>,
    root: NodeId,
}

impl Doc {
    /// Build a `Doc` from a plain [`Value`].
    pub fn of(value: &Value) -> Result<Doc, DocumentError> {
        let mut arena = Vec::new();
        let root = build_node(&mut arena, value, "$", 0)?;
        Ok(Doc { arena, root })
    }

    /// A cursor to the document root, at path `"$"`.
    pub fn root(&self) -> Cursor<'_> {
        Cursor {
            doc: self,
            id: self.root,
            path: "$".to_string(),
        }
    }

    fn entry(&self, id: NodeId) -> &Entry {
        &self.arena[id.0]
    }

    /// Append an edge `(label, value)` under the node at `at`/`path`. A
    /// repeated label is how an array grows. Returns the new edge's
    /// `NodeId`.
    pub fn add(
        &mut self,
        at: NodeId,
        path: &str,
        label: &str,
        value: &Value,
    ) -> Result<NodeId, DocumentError> {
        self.require_internal(at, path, "add")?;
        let attach_depth = self.entry(at).depth;
        let child_path = join(path, label);
        let cid = build_node(&mut self.arena, value, &child_path, attach_depth + 1)?;
        let edges = self.internal_edges_mut(at, path, "add")?;
        edges.push((label.to_string(), cid));
        Ok(cid)
    }

    /// Replace all edges under `label` with a single new edge, positioned
    /// at the first old occurrence (`set` = `remove` + `add`).
    pub fn set(
        &mut self,
        at: NodeId,
        path: &str,
        label: &str,
        value: &Value,
    ) -> Result<NodeId, DocumentError> {
        self.require_internal(at, path, "set")?;
        let attach_depth = self.entry(at).depth;
        let child_path = join(path, label);
        let cid = build_node(&mut self.arena, value, &child_path, attach_depth + 1)?;
        let edges = self.internal_edges_mut(at, path, "set")?;
        let mut first: Option<usize> = None;
        let mut kept: Vec<(String, NodeId)> = Vec::with_capacity(edges.len());
        for (lbl, child) in edges.drain(..) {
            if lbl == label {
                if first.is_none() {
                    first = Some(kept.len());
                    kept.push((label.to_string(), cid));
                }
                // later duplicates are dropped
            } else {
                kept.push((lbl, child));
            }
        }
        if first.is_none() {
            kept.push((label.to_string(), cid));
        }
        *edges = kept;
        Ok(cid)
    }

    /// Remove every edge under `label`.
    pub fn remove(&mut self, at: NodeId, path: &str, label: &str) -> Result<(), DocumentError> {
        self.require_internal(at, path, "remove")?;
        let edges = self.internal_edges_mut(at, path, "remove")?;
        edges.retain(|(lbl, _)| lbl != label);
        Ok(())
    }

    fn require_internal(&self, id: NodeId, path: &str, op: &str) -> Result<(), DocumentError> {
        match self.entry(id).data {
            NodeData::Internal(_) => Ok(()),
            NodeData::Leaf(_) => Err(DocumentError::new(path, format!("cannot {op} on a leaf"))),
        }
    }

    /// The mutable edge list at `at`, or an error if it's a leaf.
    ///
    /// `add`/`set`/`remove` all call `require_internal` first (preserving
    /// Python's check-leaf-before-build-value error ordering), so in
    /// practice this function's `Leaf` arm never fires through the public
    /// API -- it exists so the actual mutation site is a real two-armed
    /// match (both arms reachable and independently tested, see
    /// `internal_edges_mut_rejects_a_leaf_directly` below) instead of an
    /// `unreachable!()`/if-let-without-else that would leave a
    /// structurally-dead branch for `cargo llvm-cov` to flag.
    fn internal_edges_mut(
        &mut self,
        at: NodeId,
        path: &str,
        op: &str,
    ) -> Result<&mut Vec<(String, NodeId)>, DocumentError> {
        match &mut self.arena[at.0].data {
            NodeData::Internal(edges) => Ok(edges),
            NodeData::Leaf(_) => Err(DocumentError::new(path, format!("cannot {op} on a leaf"))),
        }
    }

    /// A JSON-shaped projection of the whole document: same-label edges
    /// grouped into an array; a label seen once stays a single value.
    pub fn to_grouped(&self) -> Value {
        self.grouped_at(self.root)
    }

    // Note: unlike `build_node`/`data_at`, this has no depth parameter --
    // it walks an already-validated tree (every node was depth-checked at
    // construction time), so there's nothing left to guard here.
    fn grouped_at(&self, id: NodeId) -> Value {
        match &self.entry(id).data {
            NodeData::Leaf(s) => Value::from(s.clone()),
            NodeData::Internal(edges) => {
                let mut counts: IndexMap<&str, usize> = IndexMap::new();
                for (label, _) in edges {
                    *counts.entry(label.as_str()).or_insert(0) += 1;
                }
                let mut out: IndexMap<String, Value> = IndexMap::new();
                for (label, child) in edges {
                    let g = self.grouped_at(*child);
                    if counts[label.as_str()] > 1 {
                        match out.get_mut(label.as_str()) {
                            Some(Value::Array(arr)) => arr.push(g),
                            _ => {
                                out.insert(label.clone(), Value::Array(vec![g]));
                            }
                        }
                    } else {
                        out.insert(label.clone(), g);
                    }
                }
                Value::Object(out)
            }
        }
    }

    /// A lossless copy of the whole document back into [`Value`] form.
    pub fn to_data(&self) -> Value {
        self.data_at(self.root)
    }

    fn data_at(&self, id: NodeId) -> Value {
        match &self.entry(id).data {
            NodeData::Leaf(s) => Value::from(s.clone()),
            NodeData::Internal(edges) => {
                let mut map = IndexMap::new();
                // Structural copy only -- this intentionally does NOT
                // re-group repeated labels (see to_grouped for that); a
                // repeated label here just overwrites in the IndexMap,
                // which is why to_data is for equality/structural
                // comparison, not for JSON-shaped export of repeated
                // fields. Kept simple: only used by `eq` in this issue.
                for (label, child) in edges {
                    map.insert(label.clone(), self.data_at(*child));
                }
                Value::Object(map)
            }
        }
    }

    /// Structural equality between two documents (same shape, same edge
    /// order, same labels, same leaf values).
    pub fn eq_doc(&self, other: &Doc) -> bool {
        self.node_eq(self.root, other, other.root)
    }

    fn node_eq(&self, a: NodeId, other: &Doc, b: NodeId) -> bool {
        match (&self.entry(a).data, &other.entry(b).data) {
            (NodeData::Leaf(x), NodeData::Leaf(y)) => x == y,
            (NodeData::Internal(xs), NodeData::Internal(ys)) => {
                xs.len() == ys.len()
                    && xs
                        .iter()
                        .zip(ys.iter())
                        .all(|((la, ca), (lb, cb))| la == lb && self.node_eq(*ca, other, *cb))
            }
            _ => false,
        }
    }
}

/// A read-only cursor into a [`Doc`]'s tree, tracking its own path.
///
/// Path is owned per-cursor (rather than borrowed) because it's built
/// incrementally (`$.a.b[1]`) as cursors descend; it's only needed for
/// error messages and equality with Python's `Doc.path`, not perf-critical
/// traversal.
#[derive(Debug, Clone)]
pub struct Cursor<'a> {
    doc: &'a Doc,
    id: NodeId,
    /// The path of this cursor within the document.
    pub path: String,
}

impl<'a> Cursor<'a> {
    /// The internal [`NodeId`] of the referenced node.
    pub fn id(&self) -> NodeId {
        self.id
    }

    /// Returns `true` iff this node is a leaf holding a scalar.
    pub fn is_leaf(&self) -> bool {
        matches!(self.doc.entry(self.id).data, NodeData::Leaf(_))
    }

    /// Returns the scalar value if this is a leaf node, or `Err` if it is an internal edge node.
    pub fn value(&self) -> Result<&'a Scalar, DocumentError> {
        match &self.doc.entry(self.id).data {
            NodeData::Leaf(s) => Ok(s),
            NodeData::Internal(_) => Err(DocumentError::new(&self.path, "not a leaf; use edges()")),
        }
    }

    /// Returns the outgoing labeled edges if this is an internal node, or `Err` if it is a leaf.
    pub fn edges(&self) -> Result<Vec<(String, Cursor<'a>)>, DocumentError> {
        match &self.doc.entry(self.id).data {
            NodeData::Internal(edges) => {
                let mut counts: IndexMap<&str, usize> = IndexMap::new();
                let mut out = Vec::with_capacity(edges.len());
                for (label, child) in edges {
                    let i = *counts.entry(label.as_str()).or_insert(0);
                    counts.insert(label.as_str(), i + 1);
                    let cp = crate::report::child_path(&self.path, label, i);
                    out.push((
                        label.clone(),
                        Cursor {
                            doc: self.doc,
                            id: *child,
                            path: cp,
                        },
                    ));
                }
                Ok(out)
            }
            NodeData::Leaf(_) => Err(DocumentError::new(&self.path, "a leaf has no edges")),
        }
    }

    /// Like [`Cursor::edges`], but doesn't build a path `String` for every
    /// child up front (issue #44) -- returns each edge's label, its
    /// same-label occurrence index, and its `NodeId`, leaving path
    /// construction to the caller. Paired with [`Cursor::seek`], used by
    /// `schema.rs`'s `conform_record` (the validate hot path), which reuses
    /// one path buffer for the whole tree walk instead of allocating one
    /// `String` per edge regardless of whether that edge ever needs one.
    pub(crate) fn internal_edges(&self) -> Result<&'a [(String, NodeId)], DocumentError> {
        match &self.doc.entry(self.id).data {
            NodeData::Internal(edges) => Ok(edges),
            NodeData::Leaf(_) => Err(DocumentError::new(&self.path, "a leaf has no edges")),
        }
    }

    pub(crate) fn raw_edges(&self) -> Result<Vec<(&'a str, usize, NodeId)>, DocumentError> {
        match &self.doc.entry(self.id).data {
            NodeData::Internal(edges) => {
                let mut counts: IndexMap<&str, usize> = IndexMap::new();
                let mut out = Vec::with_capacity(edges.len());
                for (label, child) in edges {
                    let i = *counts.entry(label.as_str()).or_insert(0);
                    counts.insert(label.as_str(), i + 1);
                    out.push((label.as_str(), i, *child));
                }
                Ok(out)
            }
            NodeData::Leaf(_) => Err(DocumentError::new(&self.path, "a leaf has no edges")),
        }
    }

    /// Build a cursor for `id` without a meaningful `path` -- only valid for
    /// callers (like `schema.rs`'s buffer-threaded `conform`) that never
    /// read the returned cursor's `path` field directly, tracking the real
    /// path in their own reused buffer instead. Paired with [`Cursor::raw_edges`].
    pub(crate) fn seek(&self, id: NodeId) -> Cursor<'a> {
        Cursor {
            doc: self.doc,
            id,
            path: String::new(),
        }
    }

    /// Returns a deduplicated list of child edge labels.
    pub fn labels(&self) -> Vec<String> {
        let mut seen = std::collections::HashSet::new();
        let mut out = Vec::new();
        if let NodeData::Internal(edges) = &self.doc.entry(self.id).data {
            for (label, _) in edges {
                if seen.insert(label.clone()) {
                    out.push(label.clone());
                }
            }
        }
        out
    }

    /// Returns all child cursors along edges with the given `label`.
    pub fn get(&self, label: &str) -> Vec<Cursor<'a>> {
        self.edges()
            .into_iter()
            .flatten()
            .filter(|(lbl, _)| lbl == label)
            .map(|(_, c)| c)
            .collect()
    }

    /// Returns the single child cursor for `label`, or `Err` if there are 0 or >1 matching edges.
    pub fn get_one(&self, label: &str) -> Result<Cursor<'a>, DocumentError> {
        let mut cs = self.get(label);
        if cs.len() != 1 {
            return Err(DocumentError::new(
                &self.path,
                format!("expected exactly one {label:?}, found {}", cs.len()),
            ));
        }
        Ok(cs.remove(0))
    }

    /// Returns the number of edges with the given `label`.
    pub fn count(&self, label: &str) -> usize {
        if let NodeData::Internal(edges) = &self.doc.entry(self.id).data {
            edges.iter().filter(|(lbl, _)| lbl == label).count()
        } else {
            0
        }
    }

    /// A cursor to the single child under `label`.
    pub fn child(&self, label: &str) -> Result<Cursor<'a>, DocumentError> {
        self.get_one(label)
    }

    /// A lossless [`RawNode`] copy of the subtree rooted at this cursor,
    /// preserving edge order and interleaving exactly. Used by
    /// `crate::materialize` to carry an untouched subtree forward (e.g. an
    /// unexpected field it still has to emit for a caller inspecting the
    /// materialized-but-erroring result) without a second, hand-rolled
    /// tree-copy routine.
    pub fn to_raw(&self) -> RawNode {
        self.doc.raw_at(self.id)
    }
}

/// The *raw* canonical Document node: either a leaf scalar, or an ordered
/// list of `(label, child)` edges that may repeat **and interleave** a label
/// arbitrarily (`[("b",1),("c",2),("b",3)]` is representable exactly).
///
/// This is distinct from [`Value`]: `Value::Object`'s `IndexMap` can't hold
/// a repeated key, so its "repeated label" convention (a `Value::Array`
/// under one key, per `child_specs`) only ever expands to a *contiguous*
/// run of same-label edges. OML is the one format that must round-trip
/// arbitrary interleaving losslessly (per its own docs: "no adjustment ever
/// needed"), so its reader/writer (`crate::oml`) builds/walks a `Doc`
/// through this type instead of going through `Value`.
#[derive(Debug, Clone, PartialEq)]
pub enum RawNode {
    /// A leaf node holding a scalar value.
    Leaf(Scalar),
    /// An internal node holding labeled outgoing edges.
    Edges(Vec<(String, RawNode)>),
}

impl Doc {
    /// Build a `Doc` from a [`RawNode`], preserving edge order and
    /// interleaving exactly. Depth-guarded via the same
    /// `check_write_depth` every other construction path uses.
    pub fn from_raw(root: RawNode) -> Result<Doc, DocumentError> {
        let mut arena = Vec::new();
        let root_id = push_raw(&mut arena, root, 0)?;
        Ok(Doc {
            arena,
            root: root_id,
        })
    }

    /// The inverse of [`Doc::from_raw`]: a lossless walk back into
    /// [`RawNode`] form, preserving edge order and interleaving exactly.
    pub fn to_raw(&self) -> RawNode {
        self.raw_at(self.root)
    }

    fn raw_at(&self, id: NodeId) -> RawNode {
        let entry = self.entry(id);
        match &entry.data {
            NodeData::Leaf(s) => RawNode::Leaf(s.clone()),
            NodeData::Internal(edges) => RawNode::Edges(
                edges
                    .iter()
                    .map(|(label, child)| (label.clone(), self.raw_at(*child)))
                    .collect(),
            ),
        }
    }
}

/// Name-keyed dispatch through [`crate::registry`] (issue #31), mirroring
/// Python's `Doc.from_format`/`to_format`/`check_format` in
/// `~/dev/omnist/omnist/document.py`. Kept as its own `impl Doc` block
/// (rather than folded into the constructors/export blocks above) since it
/// is the one place `Doc` depends on the registry module rather than a
/// single format module directly.
impl Doc {
    /// Read `text` as the registered format `name` (an
    /// [`crate::error::OmnistError::Format`] if `name` isn't registered).
    /// Mirrors Python's `Doc.from_format(name, text)`.
    pub fn from_format(name: &str, text: &str) -> Result<Doc, crate::error::OmnistError> {
        let fmt = crate::registry::get_format(name)?;
        (fmt.read)(text)
    }

    /// Write `self` as the registered format `name`. Mirrors Python's
    /// `Doc.to_format(name)`.
    pub fn to_format(&self, name: &str) -> Result<String, crate::error::OmnistError> {
        let fmt = crate::registry::get_format(name)?;
        (fmt.write)(self)
    }

    /// Simulate writing `self` as the registered format `name`, without
    /// producing output. Mirrors Python's `Doc.check_format(name)`: an
    /// [`crate::error::OmnistError::Document`] if `name`'s registered
    /// [`crate::registry::Format`] has no `check` callable (a plugin
    /// registered via [`crate::registry::Format::new`] alone) -- not a
    /// panic.
    pub fn check_format(
        &self,
        name: &str,
    ) -> Result<crate::report::WriteReport, crate::error::OmnistError> {
        let fmt = crate::registry::get_format(name)?;
        match &fmt.check {
            Some(check) => Ok(check(self)),
            None => Err(DocumentError::new(
                "$",
                format!("format {name:?} has no check() -- cannot simulate a write"),
            )
            .into()),
        }
    }
}

fn push_raw(arena: &mut Vec<Entry>, node: RawNode, depth: usize) -> Result<NodeId, DocumentError> {
    // Path information isn't meaningful during a from-source OML parse (no
    // dotted-key path exists yet), so a fixed placeholder is used here --
    // matching the depth guard's own error message, which never mentions
    // path for depth violations anyway (see `check_write_depth`).
    check_write_depth(depth, "$")?;
    match node {
        RawNode::Leaf(s) => push(arena, NodeData::Leaf(s), depth, "$"),
        RawNode::Edges(edges) => {
            let mut out = Vec::with_capacity(edges.len());
            for (label, child) in edges {
                let cid = push_raw(arena, child, depth + 1)?;
                out.push((label, cid));
            }
            push(arena, NodeData::Internal(out), depth, "$")
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    fn obj(pairs: &[(&str, Value)]) -> Value {
        let mut m = IndexMap::new();
        for (k, v) in pairs {
            m.insert((*k).to_string(), v.clone());
        }
        Value::Object(m)
    }

    /// `levels` nested objects (each `{"a": ...}`) wrapping a leaf. Per
    /// `build_node`'s depth arithmetic, the leaf ends up at depth `levels`
    /// (each object level adds exactly 1 -- no array involved).
    fn nest(levels: usize) -> Value {
        let mut v = Value::Int((0).into());
        for _ in 0..levels {
            v = obj(&[("a", v)]);
        }
        v
    }

    // -- basic construction ---------------------------------------------

    #[test]
    fn constructs_a_scalar_leaf() {
        let doc = Doc::of(&Value::Int((42).into())).unwrap();
        let root = doc.root();
        assert!(root.is_leaf());
        assert_eq!(root.value().unwrap(), &Scalar::Int((42).into()));
    }

    #[test]
    fn constructs_an_object_as_ordered_edges() {
        let v = obj(&[("b", Value::Int((1).into())), ("a", Value::Int((2).into()))]);
        let doc = Doc::of(&v).unwrap();
        let root = doc.root();
        assert!(!root.is_leaf());
        let edges = root.edges().unwrap();
        let labels: Vec<&str> = edges.iter().map(|(l, _)| l.as_str()).collect();
        // Insertion order preserved, NOT sorted -- "b" before "a".
        assert_eq!(labels, vec!["b", "a"]);
    }

    #[test]
    fn a_list_value_expands_into_repeated_edges() {
        let v = obj(&[(
            "member",
            Value::Array(vec![
                Value::Int((1).into()),
                Value::Int((2).into()),
                Value::Int((3).into()),
            ]),
        )]);
        let doc = Doc::of(&v).unwrap();
        let root = doc.root();
        assert_eq!(root.count("member"), 3);
        let members = root.get("member");
        let vals: Vec<&Scalar> = members.iter().map(|c| c.value().unwrap()).collect();
        assert_eq!(
            vals,
            vec![
                &Scalar::Int((1).into()),
                &Scalar::Int((2).into()),
                &Scalar::Int((3).into())
            ]
        );
    }

    #[test]
    fn a_bare_top_level_array_is_rejected() {
        let err = Doc::of(&Value::Array(vec![Value::Int((1).into())])).unwrap_err();
        assert!(err.message.contains("bare array"));
        assert_eq!(err.path, "$");
    }

    #[test]
    fn an_array_of_arrays_is_rejected() {
        let v = obj(&[(
            "a",
            Value::Array(vec![Value::Array(vec![Value::Int((1).into())])]),
        )]);
        let err = Doc::of(&v).unwrap_err();
        assert!(err.message.contains("array of arrays"));
        assert_eq!(err.path, "$.a[0]");
    }

    // -- depth guard: max-depth boundary ---------------------------------

    #[test]
    fn depth_guard_accepts_exactly_max_depth() {
        // nest(MAX_DEPTH) puts the leaf at depth == MAX_DEPTH, which is
        // the accept boundary (guard rejects only depth > MAX_DEPTH).
        let v = nest(MAX_DEPTH);
        assert!(Doc::of(&v).is_ok());
    }

    #[test]
    fn depth_guard_rejects_one_past_max_depth() {
        let v = nest(MAX_DEPTH + 1);
        let err = Doc::of(&v).unwrap_err();
        assert!(err.message.contains("maximum depth"));
    }

    // -- node-count guard: max-nodes boundary (omnist-rs#78) -------------
    //
    // A shallow document can still be enormous -- depth alone doesn't bound
    // total memory, e.g. a single label repeated a million times is depth 1.
    // `wide(n)` builds `{"a": [0, 0, ..., 0]}` with `n` array elements, for
    // a total node count of `n + 1` (the root object, plus one leaf per
    // array element -- the array itself desugars into repeated edges, not
    // its own node).

    fn wide(n: usize) -> Value {
        obj(&[("a", Value::Array(vec![Value::Int((0).into()); n]))])
    }

    #[test]
    fn node_guard_accepts_exactly_max_nodes() {
        let v = wide(MAX_NODES - 1);
        assert!(Doc::of(&v).is_ok());
    }

    #[test]
    fn node_guard_rejects_one_past_max_nodes() {
        let v = wide(MAX_NODES);
        let err = Doc::of(&v).unwrap_err();
        assert!(err.message.contains("maximum node count"));
    }

    #[test]
    fn an_array_value_consumes_an_extra_depth_level() {
        // A scalar directly under a key sits one level deeper than the
        // object (depth 1). The same scalar wrapped in a one-item array
        // under that key sits *two* levels deeper (depth 2) -- the array
        // itself costs an extra level, mirroring Python's `_children`
        // (see the module doc comment / build_node's `depth + 1` for the
        // list branch on top of the caller's own `depth + 1`).
        let direct = obj(&[("a", Value::Int((1).into()))]);
        let via_array = obj(&[("a", Value::Array(vec![Value::Int((1).into())]))]);
        let doc_direct = Doc::of(&direct).unwrap();
        let doc_array = Doc::of(&via_array).unwrap();
        let leaf_direct = doc_direct.root().child("a").unwrap();
        let leaf_array = doc_array.root().child("a").unwrap();
        assert_eq!(doc_direct.entry(leaf_direct.id()).depth, 1);
        assert_eq!(doc_array.entry(leaf_array.id()).depth, 2);
    }

    // -- depth guard: every public tree-mutating entry point -------------

    #[test]
    fn every_tree_mutating_entry_point_enforces_the_depth_guard() {
        // Doc::of
        assert!(Doc::of(&nest(MAX_DEPTH + 1)).is_err());

        // Doc::add, attaching at the root (depth 0): the pushed subtree's
        // own internal depth is what must exceed MAX_DEPTH.
        let mut doc = Doc::of(&obj(&[("seed", Value::Int((0).into()))])).unwrap();
        let root_id = doc.root().id();
        let root_path = doc.root().path.clone();
        assert!(
            doc.add(root_id, &root_path, "b", &nest(MAX_DEPTH + 1))
                .is_err()
        );

        // Doc::set: same guard, different mutating call site.
        let mut doc2 = Doc::of(&obj(&[("seed", Value::Int((0).into()))])).unwrap();
        let root_id2 = doc2.root().id();
        let root_path2 = doc2.root().path.clone();
        assert!(
            doc2.set(root_id2, &root_path2, "b", &nest(MAX_DEPTH + 1))
                .is_err()
        );
    }

    // -- depth guard: hand-constructed deep subtree bypassing a
    //    construction-time-only check (omnist-ts#37 / omnist-ts#70) -------

    #[test]
    fn add_at_a_deep_cursor_accounts_for_the_cursors_own_depth() {
        // Build a document 200 objects deep (leaf at depth 200), then walk
        // a cursor down 190 levels to an *internal* node sitting at depth
        // 190. If `add()` (re-)started the depth guard's counter at 0 for
        // the pushed subtree -- the exact omnist-ts#37 bug, where
        // `buildNode` was called with no depth argument on every mutation
        // -- a modest 15-level subtree would wrongly be accepted here
        // (15 < MAX_DEPTH). Threading the cursor's own depth through
        // means 190 + 1 (attach) + 15 = 206 > MAX_DEPTH is correctly
        // rejected instead.
        let mut doc = Doc::of(&nest(MAX_DEPTH)).unwrap();
        let mut cursor = doc.root();
        for _ in 0..190 {
            cursor = cursor.child("a").unwrap();
        }
        assert_eq!(doc.entry(cursor.id()).depth, 190);
        let id = cursor.id();
        let path = cursor.path.clone();

        let too_deep = nest(15);
        assert!(doc.add(id, &path, "b", &too_deep).is_err());

        // Positive control: a shallow enough subtree at the same depth
        // succeeds, proving the rejection above is about depth, not some
        // unrelated failure.
        let shallow = nest(5);
        assert!(doc.set(id, &path, "b", &shallow).is_ok());
    }

    // -- IndexMap ordering preserved on iteration ------------------------

    #[test]
    fn labels_and_get_preserve_first_seen_and_insertion_order() {
        // Repeated labels come from an `Array` value under one key (a dict
        // key can't repeat) -- "z" appears twice because its value is a
        // 2-item array, not because the object has two "z" entries.
        let v = obj(&[
            (
                "z",
                Value::Array(vec![Value::Int((1).into()), Value::Int((3).into())]),
            ),
            ("a", Value::Int((2).into())),
            ("m", Value::Int((4).into())),
        ]);
        let doc = Doc::of(&v).unwrap();
        let root = doc.root();
        assert_eq!(root.labels(), vec!["z", "a", "m"]);
        let z_vals: Vec<&Scalar> = root.get("z").iter().map(|c| c.value().unwrap()).collect();
        assert_eq!(
            z_vals,
            vec![&Scalar::Int((1).into()), &Scalar::Int((3).into())]
        );
    }

    #[test]
    fn labels_and_count_on_a_leaf_are_empty() {
        let doc = Doc::of(&Value::Int((1).into())).unwrap();
        let root = doc.root();
        assert!(root.labels().is_empty());
        assert_eq!(root.count("anything"), 0);
    }

    #[test]
    fn to_grouped_preserves_first_seen_key_order() {
        let v = obj(&[
            (
                "z",
                Value::Array(vec![Value::Int((1).into()), Value::Int((3).into())]),
            ),
            ("a", Value::Int((2).into())),
        ]);
        let doc = Doc::of(&v).unwrap();
        let grouped = doc.to_grouped();
        let expected = obj(&[
            (
                "z",
                Value::Array(vec![Value::Int((1).into()), Value::Int((3).into())]),
            ),
            ("a", Value::Int((2).into())),
        ]);
        assert_eq!(grouped, expected);
        // `assert_eq!` above is order-insensitive (`IndexMap`'s `PartialEq`
        // ignores insertion order), so separately confirm key order here.
        let keys: Vec<&str> = grouped
            .as_object()
            .unwrap()
            .keys()
            .map(|s| s.as_str())
            .collect();
        assert_eq!(keys, vec!["z", "a"]);
    }

    #[test]
    fn value_as_object_is_none_for_a_non_object() {
        assert!(Value::Int((1).into()).as_object().is_none());
    }

    // -- mutation semantics: add / set / remove / count / get -----------

    #[test]
    fn add_appends_and_get_one_requires_exactly_one() {
        let mut doc = Doc::of(&obj(&[])).unwrap();
        let root_id = doc.root().id();
        let root_path = doc.root().path.clone();
        doc.add(root_id, &root_path, "x", &Value::Int((1).into()))
            .unwrap();
        doc.add(root_id, &root_path, "x", &Value::Int((2).into()))
            .unwrap();
        let root = doc.root();
        assert_eq!(root.count("x"), 2);
        assert!(root.get_one("x").is_err());
    }

    #[test]
    fn set_replaces_all_occurrences_at_first_position() {
        let mut doc = Doc::of(&obj(&[
            ("x", Value::Int((1).into())),
            ("y", Value::Int((9).into())),
            ("x", Value::Int((2).into())),
        ]))
        .unwrap();
        let root_id = doc.root().id();
        let root_path = doc.root().path.clone();
        doc.set(root_id, &root_path, "x", &Value::Int((100).into()))
            .unwrap();
        let root = doc.root();
        let labels: Vec<String> = root.edges().unwrap().into_iter().map(|(l, _)| l).collect();
        assert_eq!(labels, vec!["x", "y"]);
        assert_eq!(
            root.get_one("x").unwrap().value().unwrap(),
            &Scalar::Int((100).into())
        );
    }

    #[test]
    fn remove_drops_every_edge_with_that_label() {
        let mut doc = Doc::of(&obj(&[
            ("x", Value::Int((1).into())),
            ("x", Value::Int((2).into())),
        ]))
        .unwrap();
        let root_id = doc.root().id();
        let root_path = doc.root().path.clone();
        doc.remove(root_id, &root_path, "x").unwrap();
        assert_eq!(doc.root().count("x"), 0);
    }

    #[test]
    fn internal_edges_mut_rejects_a_leaf_directly() {
        // White-box test of the private helper: `add`/`set`/`remove` all
        // gate through `require_internal` first, so this helper's `Leaf`
        // arm is unreachable via the public API -- call it directly to
        // prove the arm itself is correct (see its doc comment).
        let mut doc = Doc::of(&Value::Int((1).into())).unwrap();
        let root_id = doc.root().id();
        let err = doc.internal_edges_mut(root_id, "$", "poke").unwrap_err();
        assert_eq!(err.path, "$");
        assert!(err.message.contains("cannot poke on a leaf"));
    }

    #[test]
    fn mutation_on_a_leaf_is_rejected() {
        let mut doc = Doc::of(&Value::Int((1).into())).unwrap();
        let root_id = doc.root().id();
        let root_path = doc.root().path.clone();
        assert!(
            doc.add(root_id, &root_path, "x", &Value::Int((1).into()))
                .is_err()
        );
        assert!(
            doc.set(root_id, &root_path, "x", &Value::Int((1).into()))
                .is_err()
        );
        assert!(doc.remove(root_id, &root_path, "x").is_err());
    }

    #[test]
    fn value_on_an_internal_node_is_rejected() {
        let doc = Doc::of(&obj(&[("x", Value::Int((1).into()))])).unwrap();
        assert!(doc.root().value().is_err());
    }

    #[test]
    fn edges_on_a_leaf_is_rejected() {
        let doc = Doc::of(&Value::Int((1).into())).unwrap();
        assert!(doc.root().edges().is_err());
    }

    #[test]
    fn raw_edges_on_a_leaf_is_rejected() {
        // Mirrors `edges_on_a_leaf_is_rejected` for the lazy-path variant
        // `edges()` piggybacks its own path-numbering on -- see issue #44.
        let doc = Doc::of(&Value::Int((1).into())).unwrap();
        assert!(doc.root().raw_edges().is_err());
    }

    // -- export / equality ------------------------------------------------

    #[test]
    fn to_data_round_trips_structure() {
        let v = obj(&[
            ("a", Value::Int((1).into())),
            ("b", Value::Str("hi".to_string())),
        ]);
        let doc = Doc::of(&v).unwrap();
        assert_eq!(doc.to_data(), v);
    }

    #[test]
    fn to_data_round_trips_every_scalar_variant() {
        // Covers every `Value`/`Scalar` leaf variant through both
        // `build_node` (construction) and `From<Scalar> for Value`
        // (export via to_data), not just Int/Str.
        let v = obj(&[
            ("n", Value::Null),
            ("b", Value::Bool(true)),
            ("i", Value::Int((7).into())),
            ("f", Value::Float(1.5)),
            ("s", Value::Str("hi".to_string())),
        ]);
        let doc = Doc::of(&v).unwrap();
        assert_eq!(doc.to_data(), v);
        assert_eq!(doc.to_grouped(), v);
    }

    #[test]
    fn join_quotes_a_non_identifier_key() {
        // A key that isn't a valid identifier (starts with a digit) takes
        // the `path["key"]` form, not `path.key`.
        let v = obj(&[(
            "1bad",
            Value::Array(vec![Value::Array(vec![Value::Int((1).into())])]),
        )]);
        let err = Doc::of(&v).unwrap_err();
        assert_eq!(err.path, "$[\"1bad\"][0]");
    }

    #[test]
    fn eq_doc_compares_structurally() {
        let a = Doc::of(&obj(&[("a", Value::Int((1).into()))])).unwrap();
        let b = Doc::of(&obj(&[("a", Value::Int((1).into()))])).unwrap();
        let c = Doc::of(&obj(&[("a", Value::Int((2).into()))])).unwrap();
        assert!(a.eq_doc(&b));
        assert!(!a.eq_doc(&c));
    }

    #[test]
    fn eq_doc_is_false_when_shapes_differ() {
        // A leaf is never equal to an internal node, regardless of
        // content -- exercises `node_eq`'s (Leaf, Internal) mismatch arm.
        let leaf = Doc::of(&Value::Int((1).into())).unwrap();
        let internal = Doc::of(&obj(&[("a", Value::Int((1).into()))])).unwrap();
        assert!(!leaf.eq_doc(&internal));
        assert!(!internal.eq_doc(&leaf));
    }

    #[test]
    fn scalar_display_covers_every_variant() {
        assert_eq!(Scalar::Null.to_string(), "null");
        assert_eq!(Scalar::Bool(true).to_string(), "true");
        assert_eq!(Scalar::Int((1).into()).to_string(), "1");
        assert_eq!(Scalar::Float(1.5).to_string(), "1.5");
        assert_eq!(Scalar::Str("x".to_string()).to_string(), "\"x\"");
    }

    // -- RawNode / from_raw / to_raw (interleaved-edge round trip) ---------

    #[test]
    fn from_raw_to_raw_round_trips_interleaved_repeated_labels() {
        // ("b",1),("c",2),("b",3): interleaved, not a contiguous run --
        // exactly the shape `Value`/`IndexMap` cannot represent, which is
        // why the OML codec goes through RawNode instead.
        let raw = RawNode::Edges(vec![
            ("b".to_string(), RawNode::Leaf(Scalar::Int((1).into()))),
            ("c".to_string(), RawNode::Leaf(Scalar::Int((2).into()))),
            ("b".to_string(), RawNode::Leaf(Scalar::Int((3).into()))),
        ]);
        let doc = Doc::from_raw(raw.clone()).unwrap();
        assert_eq!(doc.to_raw(), raw);
        let labels: Vec<String> = doc
            .root()
            .edges()
            .unwrap()
            .into_iter()
            .map(|(l, _)| l)
            .collect();
        assert_eq!(labels, vec!["b", "c", "b"]);
    }

    #[test]
    fn from_raw_leaf_round_trips() {
        let raw = RawNode::Leaf(Scalar::Str("hi".to_string()));
        let doc = Doc::from_raw(raw.clone()).unwrap();
        assert!(doc.root().is_leaf());
        assert_eq!(doc.to_raw(), raw);
    }

    #[test]
    fn from_raw_enforces_the_depth_guard() {
        fn nest_raw(levels: usize) -> RawNode {
            let mut n = RawNode::Leaf(Scalar::Int((0).into()));
            for _ in 0..levels {
                n = RawNode::Edges(vec![("a".to_string(), n)]);
            }
            n
        }
        assert!(Doc::from_raw(nest_raw(MAX_DEPTH)).is_ok());
        let err = Doc::from_raw(nest_raw(MAX_DEPTH + 1)).unwrap_err();
        assert!(err.message.contains("maximum depth"));
    }
}