molframe-core 0.6.1

//! Compact connectivity storage and lazy graph traversal.
//!
//! Bonds live as sorted edge columns. Graph algorithms can request a cached
//! CSR view, built in O(atoms + bonds) time and storage, without imposing an
//! adjacency allocation on structures whose analyses never traverse bonds.

use crate::index::{AtomIndex, BondIndex};
use crate::optional::OptionalSymbol;
use std::ops::Range;
use std::sync::{Arc, OnceLock};

/// The chemical order assigned to a bond.
#[derive(Clone, Copy, Debug, Default, PartialEq, Eq, PartialOrd, Ord, Hash)]
pub enum BondOrder {
    /// One shared electron pair.
    Single,
    /// Two shared electron pairs.
    Double,
    /// Three shared electron pairs.
    Triple,
    /// Four shared electron pairs.
    Quadruple,
    /// Delocalised aromatic connectivity.
    Aromatic,
    /// A linkage between consecutive polymer components.
    Polymeric,
    /// Connectivity is known but its order is not.
    #[default]
    Unknown,
}

/// Where a bond assignment came from.
#[derive(Clone, Copy, Debug, PartialEq, Eq, PartialOrd, Ord, Hash)]
pub enum BondProvenance {
    /// An explicit record in the input structure.
    File,
    /// The chemical component dictionary.
    ChemicalComponentDictionary,
    /// An explicitly requested distance calculation.
    InferredDistance,
    /// An explicit caller edit.
    User,
}

/// One bond before it is packed into columns.
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub struct BondRecord {
    /// First atom endpoint.
    pub atom_a: AtomIndex,
    /// Second atom endpoint.
    pub atom_b: AtomIndex,
    /// Chemical order.
    pub order: BondOrder,
    /// Source of this assignment.
    pub provenance: BondProvenance,
    /// The connection's own classification, as the source recorded it, interned
    /// in the dictionary that owns this record.
    ///
    /// This is the deposited connectivity kind — `covale`, `disulf`, `metalc`,
    /// `modres`, or a source-defined refinement — and it is independent of
    /// [`order`](Self::order) and of [`provenance`](Self::provenance). A metal
    /// coordination bond and a covalent one can share an order and still mean
    /// different chemistry, so a consumer that must not treat coordination as an
    /// ordinary covalent edge reads this field rather than inferring from the
    /// atom names.
    ///
    /// An identifier means something only against the structure whose dictionary
    /// issued it. Copying one into a structure with an independent dictionary is
    /// invalid; the merge and transfer paths remap it, and
    /// [`NONE`](OptionalSymbol::NONE) means the source recorded no classification
    /// at all, which is not the same as any particular class.
    pub kind: OptionalSymbol,
}

impl BondRecord {
    /// Whether the source explicitly classifies this edge as metal coordination.
    /// An absent or unknown class is not evidence of coordination; elements,
    /// bond order and provenance never substitute for the deposited class.
    #[must_use]
    pub fn is_metal_coordination(&self, dictionary: &crate::symbol::Interner) -> bool {
        self.kind
            .get()
            .and_then(|symbol| dictionary.resolve(symbol))
            .is_some_and(|kind| kind.eq_ignore_ascii_case("metalc"))
    }

    /// A record whose source recorded no connection classification.
    ///
    /// Most producers infer connectivity from chemistry or from distances and
    /// have no deposited `conn_type_id` to carry; this states that absence rather
    /// than picking a class.
    #[must_use]
    pub const fn unclassified(
        atom_a: AtomIndex,
        atom_b: AtomIndex,
        order: BondOrder,
        provenance: BondProvenance,
    ) -> Self {
        Self {
            atom_a,
            atom_b,
            order,
            provenance,
            kind: OptionalSymbol::NONE,
        }
    }
}

/// A compact, immutable edge table.
#[derive(Clone, Debug)]
pub struct BondTable {
    atom_a: Arc<Vec<AtomIndex>>,
    atom_b: Arc<Vec<AtomIndex>>,
    order: Arc<Vec<BondOrder>>,
    provenance: Arc<Vec<BondProvenance>>,
    kind: Arc<Vec<OptionalSymbol>>,
    adjacency: Arc<OnceLock<BondAdjacency>>,
    available: bool,
}

impl Default for BondTable {
    fn default() -> Self {
        Self {
            atom_a: Arc::new(Vec::new()),
            atom_b: Arc::new(Vec::new()),
            order: Arc::new(Vec::new()),
            provenance: Arc::new(Vec::new()),
            kind: Arc::new(Vec::new()),
            adjacency: Arc::new(OnceLock::new()),
            available: false,
        }
    }
}

impl BondTable {
    /// Number of unique undirected edges.
    #[must_use]
    pub fn len(&self) -> usize {
        self.atom_a.len()
    }

    /// Whether no connectivity is available.
    #[must_use]
    pub fn is_empty(&self) -> bool {
        self.atom_a.is_empty()
    }

    /// Whether connectivity was resolved, including a known empty graph.
    #[must_use]
    pub const fn is_available(&self) -> bool {
        self.available
    }

    /// Returns one edge by position.
    #[must_use]
    pub fn get(&self, bond: BondIndex) -> Option<BondRecord> {
        let position = bond.as_usize();
        Some(BondRecord {
            atom_a: *self.atom_a.get(position)?,
            atom_b: *self.atom_b.get(position)?,
            order: *self.order.get(position)?,
            provenance: *self.provenance.get(position)?,
            kind: *self.kind.get(position)?,
        })
    }

    /// Walks records in stable endpoint order.
    #[must_use]
    pub fn iter(&self) -> impl ExactSizeIterator<Item = BondRecord> + '_ {
        self.atom_a
            .iter()
            .zip(self.atom_b.iter())
            .zip(self.order.iter())
            .zip(self.provenance.iter())
            .zip(self.kind.iter())
            .map(
                |((((atom_a, atom_b), order), provenance), kind)| BondRecord {
                    atom_a: *atom_a,
                    atom_b: *atom_b,
                    order: *order,
                    provenance: *provenance,
                    kind: *kind,
                },
            )
    }

    /// The interned connection classification of each edge, position for
    /// position with [`iter`](Self::iter).
    ///
    /// The identifiers belong to the dictionary of the structure that owns this
    /// table; resolving one requires that structure.
    #[must_use]
    pub fn kinds(&self) -> &[OptionalSymbol] {
        &self.kind
    }

    /// Returns a cached compact adjacency index for graph traversal.
    #[must_use]
    pub fn adjacency(&self, atom_count: u32) -> &BondAdjacency {
        self.adjacency
            .get_or_init(|| BondAdjacency::build(self, atom_count))
    }
}

/// Deterministic bond-table construction with endpoint deduplication.
///
/// Records accumulate in insertion order and are sorted and deduplicated once
/// at `finish`. A tree keyed on the endpoint pair would allocate a node per
/// bond, which at billions of bonds dominates the build; an amortised push plus
/// a single sort produces the same ordering for a fraction of the work.
#[derive(Debug, Default)]
pub struct BondTableBuilder {
    records: Vec<BondRecord>,
}

impl BondTableBuilder {
    /// Creates an empty builder.
    #[must_use]
    pub const fn new() -> Self {
        Self {
            records: Vec::new(),
        }
    }

    /// Adds an undirected edge. The first assignment wins on duplicates.
    ///
    /// Self-edges are retained so structure validation can report them rather
    /// than silently changing the caller's data.
    pub fn push(&mut self, mut record: BondRecord) {
        if record.atom_b < record.atom_a {
            std::mem::swap(&mut record.atom_a, &mut record.atom_b);
        }
        self.records.push(record);
    }

    /// Packs records into immutable columns.
    #[must_use]
    pub fn finish(self) -> BondTable {
        self.finish_with_availability(true)
    }

    /// Packs records while preserving whether the complete graph is known.
    ///
    /// A merge can retain explicit edges from one input while marking the
    /// combined graph unavailable because another input carried no connectivity.
    #[must_use]
    pub fn finish_with_availability(mut self, available: bool) -> BondTable {
        // The sort is stable and `dedup_by_key` keeps the first of each run, so
        // the earliest record for a pair wins exactly as an insert-if-absent
        // would, and the output stays in ascending endpoint order.
        self.records
            .sort_by_key(|record| (record.atom_a.get(), record.atom_b.get()));
        self.records
            .dedup_by_key(|record| (record.atom_a.get(), record.atom_b.get()));

        let mut atom_a = Vec::with_capacity(self.records.len());
        let mut atom_b = Vec::with_capacity(self.records.len());
        let mut order = Vec::with_capacity(self.records.len());
        let mut provenance = Vec::with_capacity(self.records.len());
        let mut kind = Vec::with_capacity(self.records.len());
        for record in self.records {
            atom_a.push(record.atom_a);
            atom_b.push(record.atom_b);
            order.push(record.order);
            provenance.push(record.provenance);
            kind.push(record.kind);
        }
        BondTable {
            atom_a: Arc::new(atom_a),
            atom_b: Arc::new(atom_b),
            order: Arc::new(order),
            provenance: Arc::new(provenance),
            kind: Arc::new(kind),
            adjacency: Arc::new(OnceLock::new()),
            available,
        }
    }
}

/// A compressed sparse row view of an undirected bond graph.
#[derive(Clone, Debug, Default)]
pub struct BondAdjacency {
    offsets: Vec<u32>,
    neighbours: Vec<AtomIndex>,
}

impl BondAdjacency {
    fn build(table: &BondTable, atom_count: u32) -> Self {
        let mut offsets = vec![0u32; atom_count as usize + 1];
        for record in table.iter() {
            if record.atom_a.get() < atom_count && record.atom_b.get() < atom_count {
                offsets[record.atom_a.as_usize() + 1] += 1;
                offsets[record.atom_b.as_usize() + 1] += 1;
            }
        }
        for position in 1..offsets.len() {
            offsets[position] += offsets[position - 1];
        }
        let neighbour_count = match offsets.last() {
            Some(count) => *count,
            None => 0,
        };
        let mut neighbours = vec![AtomIndex::new(0); neighbour_count as usize];
        // The prefix sums are spent as write cursors and restored afterwards,
        // so the traversal needs one buffer rather than a second copy of the
        // offsets held only to keep the sums while the cursors advance.
        for record in table.iter() {
            if record.atom_a.get() >= atom_count || record.atom_b.get() >= atom_count {
                continue;
            }
            insert(&mut neighbours, &mut offsets, record.atom_a, record.atom_b);
            insert(&mut neighbours, &mut offsets, record.atom_b, record.atom_a);
        }
        // Each cursor advanced past its own start by exactly the degree it
        // filled, so walking backwards restores every prefix sum.
        for position in (1..offsets.len()).rev() {
            offsets[position] = offsets[position - 1];
        }
        offsets[0] = 0;
        for atom in 0..atom_count as usize {
            let range = offsets[atom] as usize..offsets[atom + 1] as usize;
            neighbours[range].sort_unstable();
        }
        Self {
            offsets,
            neighbours,
        }
    }

    /// Directly connected atoms in stable ordinal order.
    #[must_use]
    pub fn neighbours(&self, atom: AtomIndex) -> &[AtomIndex] {
        let Some(range) = self.range(atom) else {
            return &[];
        };
        &self.neighbours[range]
    }

    fn range(&self, atom: AtomIndex) -> Option<Range<usize>> {
        let next = atom.as_usize().checked_add(1)?;
        Some(*self.offsets.get(atom.as_usize())? as usize..*self.offsets.get(next)? as usize)
    }
}

fn insert(neighbours: &mut [AtomIndex], cursor: &mut [u32], atom: AtomIndex, value: AtomIndex) {
    let position = cursor[atom.as_usize()] as usize;
    if let Some(slot) = neighbours.get_mut(position) {
        *slot = value;
        cursor[atom.as_usize()] += 1;
    }
}

#[cfg(test)]
#[path = "model_tests.rs"]
mod tests;