rudof_lib 0.2.20-rc.1

use crate::{
    Result, Rudof,
    errors::{DataError, ShExError},
    types::Data,
};
use shex_ast::{ir::schema_ir::SchemaIR as ShExSchemaIR, shapemap::NodeSelector, shapemap::QueryShapeMap};
use shex_validation::Validator as ShExValidator;

pub fn validate_shex(rudof: &mut Rudof) -> Result<()> {
    let (data, shex_schema, shapemap, shex_validator) = prepare_loaded_data_schema_and_shapemap(rudof)?;
    let rdf_data = data.unwrap_rdf_mut();

    let needs_store = shapemap.iter().any(|asc| {
        matches!(
            asc.node_selector,
            NodeSelector::Sparql { .. } | NodeSelector::TriplePattern { .. }
        )
    });

    if needs_store {
        rdf_data
            .check_store()
            .map_err(|e| ShExError::FailedInitializingQueryStore { error: e.to_string() })?;
    }

    let result = shex_validator
        .validate_shapemap(shapemap, rdf_data, shex_schema, &Some(rdf_data.graph_prefixmap()))
        .map_err(|e| ShExError::FailedShExValidation { error: e.to_string() })?;

    // Read back the map state that was mutated by MapActionExtension closures during validation.
    // The SchemaIR's registry holds an Arc<Mutex<MapState>> that is shared with every compiled
    // closure, so locking it here gives the fully-populated state.
    if let Some(schema_ir) = &rudof.shex_schema_ir
        && let Some(arc) = schema_ir.get_map_state_arc()
    {
        let state = arc.lock().unwrap().clone();
        rudof.map_state = Some(state);
    }

    rudof.shex_validation_results = Some(result);

    Ok(())
}

fn prepare_loaded_data_schema_and_shapemap(
    rudof: &mut Rudof,
) -> Result<(&mut Data, &ShExSchemaIR, &QueryShapeMap, &ShExValidator)> {
    let data = rudof.data.as_mut().ok_or(Box::new(DataError::NoDataLoaded))?;

    if !data.is_rdf() {
        Err(Box::new(DataError::NoRdfDataLoaded))?
    }

    let shex_schema_ir = rudof.shex_schema_ir.as_ref().ok_or(ShExError::NoShExSchemaLoaded)?;
    let shex_validator = rudof.shex_validator.as_ref().ok_or(ShExError::NoShExSchemaLoaded)?;

    let shapemap = rudof.shapemap.as_ref().ok_or(ShExError::NoShapemapLoaded)?;

    Ok((data, shex_schema_ir, shapemap, shex_validator))
}