use std::collections::HashMap;
use chematic_core::{Atom, AtomIdx, BondOrder, Element, Molecule, MoleculeBuilder};
use crate::cml::parse_xml_attrs;
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum CdxmlError {
UnknownAtomicNumber(u32),
UnknownAtomRef(String),
MissingBondEndpoint,
InvalidCoords(String),
TooManyAtoms(usize),
}
impl std::fmt::Display for CdxmlError {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
match self {
CdxmlError::UnknownAtomicNumber(n) => write!(f, "unknown atomic number: {n}"),
CdxmlError::UnknownAtomRef(s) => write!(f, "unknown atom ref: {s}"),
CdxmlError::MissingBondEndpoint => write!(f, "bond missing B or E attribute"),
CdxmlError::InvalidCoords(s) => write!(f, "invalid p coords: {s}"),
CdxmlError::TooManyAtoms(n) => write!(f, "CDXML document exceeds atom limit ({n})"),
}
}
}
impl std::error::Error for CdxmlError {}
pub fn parse_cdxml(input: &str) -> Result<(Molecule, Vec<(f64, f64)>), CdxmlError> {
let mut all = parse_cdxml_all(input)?;
if all.is_empty() {
return Ok((MoleculeBuilder::new().build(), vec![]));
}
Ok(all.remove(0))
}
#[derive(Default)]
struct FragAccum {
atom_ids: Vec<String>,
atom_elems: Vec<Element>,
atom_charges: Vec<i8>,
atom_isotopes: Vec<Option<u16>>,
atom_h: Vec<Option<u8>>,
atom_xs: Vec<f64>,
atom_ys: Vec<f64>,
bond_bs: Vec<String>,
bond_es: Vec<String>,
bond_ords: Vec<BondOrder>,
}
impl FragAccum {
fn is_empty(&self) -> bool {
self.atom_ids.is_empty() && self.bond_bs.is_empty()
}
fn flush(
&mut self,
results: &mut Vec<(Molecule, Vec<(f64, f64)>)>,
) -> Result<(), CdxmlError> {
if self.is_empty() {
return Ok(());
}
let mut id_to_pos: HashMap<&str, usize> = HashMap::new();
for (i, id) in self.atom_ids.iter().enumerate() {
id_to_pos.insert(id.as_str(), i);
}
let mut builder = MoleculeBuilder::new();
let mut idx_map: HashMap<usize, AtomIdx> = HashMap::new();
let mut coords: Vec<(f64, f64)> = Vec::new();
for i in 0..self.atom_ids.len() {
let mut a = Atom::new(self.atom_elems[i]);
a.charge = self.atom_charges[i];
a.isotope = self.atom_isotopes[i];
a.hydrogen_count = self.atom_h[i];
let new_idx = builder.add_atom(a);
idx_map.insert(i, new_idx);
coords.push((self.atom_xs[i], self.atom_ys[i]));
}
for k in 0..self.bond_bs.len() {
let pos_b = *id_to_pos
.get(self.bond_bs[k].as_str())
.ok_or_else(|| CdxmlError::UnknownAtomRef(self.bond_bs[k].clone()))?;
let pos_e = *id_to_pos
.get(self.bond_es[k].as_str())
.ok_or_else(|| CdxmlError::UnknownAtomRef(self.bond_es[k].clone()))?;
let a1 = idx_map[&pos_b];
let a2 = idx_map[&pos_e];
builder.add_bond(a1, a2, self.bond_ords[k]).map_err(|_| {
CdxmlError::UnknownAtomRef(format!("{} {}", self.bond_bs[k], self.bond_es[k]))
})?;
}
results.push((builder.build(), coords));
*self = FragAccum::default();
Ok(())
}
}
pub const CDXML_MAX_ATOMS: usize = 10_000;
#[allow(clippy::type_complexity)]
pub fn parse_cdxml_all(input: &str) -> Result<Vec<(Molecule, Vec<(f64, f64)>)>, CdxmlError> {
let mut acc = FragAccum::default();
let mut results: Vec<(Molecule, Vec<(f64, f64)>)> = Vec::new();
for raw_line in input.lines() {
let line = raw_line.trim();
if line.is_empty() {
continue;
}
if line.starts_with("<fragment") {
acc = FragAccum::default();
continue;
}
if line.starts_with("</fragment>") {
acc.flush(&mut results)?;
continue;
}
if is_n_tag(line) {
let attrs = parse_xml_attrs(line);
let id = match attrs.get("id") {
Some(s) => s.clone(),
None => continue,
};
let element_num: u32 = attrs
.get("Element")
.and_then(|s| s.trim().parse().ok())
.unwrap_or(6);
if element_num > 255 {
return Err(CdxmlError::UnknownAtomicNumber(element_num));
}
let element = Element::from_atomic_number(element_num as u8)
.ok_or(CdxmlError::UnknownAtomicNumber(element_num))?;
let charge = attrs
.get("Charge")
.and_then(|s| s.trim().parse().ok())
.unwrap_or(0);
let isotope = attrs
.get("Isotope")
.and_then(|s| s.trim().parse::<u16>().ok())
.filter(|&v| v > 0);
let hcount = attrs
.get("NumHydrogens")
.and_then(|s| s.trim().parse().ok());
let (x, y) = if let Some(p) = attrs.get("p") {
let parts: Vec<&str> = p.split_whitespace().collect();
if parts.len() < 2 {
return Err(CdxmlError::InvalidCoords(p.clone()));
}
(
parts[0].parse().unwrap_or(0.0),
parts[1].parse().unwrap_or(0.0),
)
} else {
(0.0, 0.0)
};
if acc.atom_ids.len() >= CDXML_MAX_ATOMS {
return Err(CdxmlError::TooManyAtoms(CDXML_MAX_ATOMS));
}
acc.atom_ids.push(id);
acc.atom_elems.push(element);
acc.atom_charges.push(charge);
acc.atom_isotopes.push(isotope);
acc.atom_h.push(hcount);
acc.atom_xs.push(x);
acc.atom_ys.push(y);
continue;
}
if is_b_tag(line) {
let attrs = parse_xml_attrs(line);
let b = attrs
.get("B")
.cloned()
.ok_or(CdxmlError::MissingBondEndpoint)?;
let e = attrs
.get("E")
.cloned()
.ok_or(CdxmlError::MissingBondEndpoint)?;
let base: BondOrder = match attrs.get("Order").map(String::as_str) {
Some("2") => BondOrder::Double,
Some("3") => BondOrder::Triple,
_ => BondOrder::Single,
};
let order = if base == BondOrder::Single {
match attrs.get("Display").map(String::as_str) {
Some("WedgeBegin") | Some("WedgedHashBegin") => BondOrder::Up,
Some("Hash") | Some("Dash") | Some("WedgeEnd") | Some("WedgedHashEnd") => {
BondOrder::Down
}
_ => BondOrder::Single,
}
} else {
base
};
acc.bond_bs.push(b);
acc.bond_es.push(e);
acc.bond_ords.push(order);
}
}
acc.flush(&mut results)?;
Ok(results)
}
fn is_n_tag(line: &str) -> bool {
(line.starts_with("<n ") || line.starts_with("<n\t") || line == "<n>")
&& !line.starts_with("<node") }
fn is_b_tag(line: &str) -> bool {
line.starts_with("<b ")
|| line.starts_with("<b\t")
|| line == "<b>"
|| line.starts_with("<b/>")
|| line.starts_with("<b>")
}
#[cfg(test)]
mod tests {
use super::*;
const ETHANOL_CDXML: &str = r#"<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE CDXML SYSTEM "http://www.cambridgesoft.com/xml/cdxml.dtd">
<CDXML>
<fragment>
<n id="1" p="10.0 20.0" Element="6" NumHydrogens="3"/>
<n id="2" p="25.0 20.0" Element="6" NumHydrogens="2"/>
<n id="3" p="40.0 20.0" Element="8" NumHydrogens="1"/>
<b B="1" E="2" Order="1"/>
<b B="2" E="3" Order="1"/>
</fragment>
</CDXML>"#;
#[test]
fn parse_cdxml_ethanol_atom_count() {
let (mol, coords) = parse_cdxml(ETHANOL_CDXML).unwrap();
assert_eq!(mol.atom_count(), 3, "ethanol: 3 heavy atoms");
assert_eq!(mol.bond_count(), 2, "ethanol: 2 bonds");
assert_eq!(coords.len(), 3, "one coord per atom");
}
#[test]
fn parse_cdxml_ethanol_elements() {
let (mol, _) = parse_cdxml(ETHANOL_CDXML).unwrap();
let elems: Vec<&str> = mol.atoms().map(|(_, a)| a.element.symbol()).collect();
assert!(elems.contains(&"C"), "should contain C");
assert!(elems.contains(&"O"), "should contain O");
}
#[test]
fn parse_cdxml_ethanol_coords() {
let (_, coords) = parse_cdxml(ETHANOL_CDXML).unwrap();
assert!(
(coords[0].0 - 10.0).abs() < 0.01,
"first atom x=10.0: {:?}",
coords[0]
);
assert!(
(coords[0].1 - 20.0).abs() < 0.01,
"first atom y=20.0: {:?}",
coords[0]
);
}
#[test]
fn parse_cdxml_carbon_element_6() {
let cdxml = r#"<CDXML><fragment>
<n id="1" Element="6" p="0 0"/>
</fragment></CDXML>"#;
let (mol, _) = parse_cdxml(cdxml).unwrap();
assert_eq!(mol.atom_count(), 1);
let atom = mol.atom(chematic_core::AtomIdx(0));
assert_eq!(atom.element.symbol(), "C", "Element=6 → Carbon");
}
#[test]
fn parse_cdxml_double_bond() {
let cdxml = r#"<CDXML><fragment>
<n id="1" Element="6" p="0 0"/>
<n id="2" Element="8" p="10 0"/>
<b B="1" E="2" Order="2"/>
</fragment></CDXML>"#;
let (mol, _) = parse_cdxml(cdxml).unwrap();
let bond = mol.bond(chematic_core::BondIdx(0));
assert_eq!(bond.order, BondOrder::Double, "Order=2 → Double");
}
#[test]
fn parse_cdxml_charge() {
let cdxml = r#"<CDXML><fragment>
<n id="1" Element="7" Charge="1" p="0 0"/>
</fragment></CDXML>"#;
let (mol, _) = parse_cdxml(cdxml).unwrap();
let atom = mol.atom(chematic_core::AtomIdx(0));
assert_eq!(atom.charge, 1, "Charge=1 → N+");
}
#[test]
fn parse_cdxml_unknown_atomic_number_returns_err() {
let cdxml = r#"<CDXML><fragment>
<n id="1" Element="999" p="0 0"/>
</fragment></CDXML>"#;
let result = parse_cdxml(cdxml);
assert!(
matches!(result, Err(CdxmlError::UnknownAtomicNumber(_))),
"unknown atomic number should return Err"
);
}
#[test]
fn parse_cdxml_element_above_255_is_rejected() {
let cdxml = r#"<CDXML><fragment>
<n id="1" Element="300" p="0 0"/>
</fragment></CDXML>"#;
let result = parse_cdxml(cdxml);
assert!(
matches!(result, Err(CdxmlError::UnknownAtomicNumber(300))),
"Element=300 must return UnknownAtomicNumber(300)"
);
}
const TWO_FRAGMENT_CDXML: &str = r#"<?xml version="1.0" encoding="UTF-8"?>
<CDXML>
<fragment>
<n id="1" p="10.0 20.0" Element="6"/>
<n id="2" p="25.0 20.0" Element="8"/>
<b B="1" E="2" Order="1"/>
</fragment>
<fragment>
<n id="3" p="60.0 20.0" Element="7"/>
<n id="4" p="75.0 20.0" Element="6"/>
<n id="5" p="90.0 20.0" Element="6"/>
<b B="3" E="4" Order="1"/>
<b B="4" E="5" Order="1"/>
</fragment>
</CDXML>"#;
#[test]
fn parse_cdxml_all_two_fragments_count() {
let mols = parse_cdxml_all(TWO_FRAGMENT_CDXML).unwrap();
assert_eq!(mols.len(), 2, "two <fragment> elements → two molecules");
}
#[test]
fn parse_cdxml_all_first_fragment_co() {
let mols = parse_cdxml_all(TWO_FRAGMENT_CDXML).unwrap();
let (mol, _) = &mols[0];
assert_eq!(mol.atom_count(), 2, "first fragment: C + O");
assert_eq!(mol.bond_count(), 1);
}
#[test]
fn parse_cdxml_all_second_fragment_ncc() {
let mols = parse_cdxml_all(TWO_FRAGMENT_CDXML).unwrap();
let (mol, _) = &mols[1];
assert_eq!(mol.atom_count(), 3, "second fragment: N + C + C");
assert_eq!(mol.bond_count(), 2);
}
#[test]
fn parse_cdxml_all_coords_independent() {
let mols = parse_cdxml_all(TWO_FRAGMENT_CDXML).unwrap();
let (_, coords0) = &mols[0];
let (_, coords1) = &mols[1];
assert!((coords0[0].0 - 10.0).abs() < 0.01);
assert!((coords1[0].0 - 60.0).abs() < 0.01);
}
#[test]
fn parse_cdxml_empty_doc_returns_empty_vec() {
let cdxml = r#"<?xml version="1.0"?><CDXML></CDXML>"#;
let mols = parse_cdxml_all(cdxml).unwrap();
assert!(mols.is_empty(), "empty CDXML → empty Vec");
}
}