shacl 0.3.21

A SHACL validator for RDF data, implemented in Rust.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106

use crate::ast::ASTComponent;
use crate::rdf::parsers::non_shape::message;
use prefixmap::PrefixMap;
use rudof_iri::IriS;
use rudof_rdf::rdf_core::parser::rdf_node_parser::constructors::{
    SingleBoolPropertyParser, SingleStringPropertyParser, ValuesPropertyParser,
};
use rudof_rdf::rdf_core::parser::rdf_node_parser::{ParserExt, RDFNodeParse};
use rudof_rdf::rdf_core::vocabs::{OwlVocab, ShaclVocab};
use rudof_rdf::rdf_core::{FocusRDF, RDFError};
use std::collections::HashSet;
use std::marker::PhantomData;

struct BasicSparqlConstraintParser<RDF>(PhantomData<RDF>);

impl<RDF: FocusRDF> RDFNodeParse<RDF> for BasicSparqlConstraintParser<RDF> {
    type Output = Vec<ASTComponent>;

    fn parse_focused(&self, rdf: &mut RDF) -> Result<Self::Output, RDFError> {
        let fshape = rdf.get_focus().ok_or(RDFError::NoFocusNodeError)?.clone();

        let constraint_nodes = ValuesPropertyParser::new(ShaclVocab::sh_sparql()).parse_focused(rdf)?;

        let mut result = Vec::new();

        for node in constraint_nodes {
            rdf.set_focus(&node);

            let select = SingleStringPropertyParser::new(ShaclVocab::sh_select()).parse_focused(rdf)?;

            let message = message().optional().parse_focused(rdf)?;

            let deactivated = SingleBoolPropertyParser::new(ShaclVocab::sh_deactivated())
                .optional()
                .parse_focused(rdf)?;

            let mut pm = PrefixMap::new();
            let prefix_nodes = ValuesPropertyParser::new(ShaclVocab::sh_prefixes())
                .parse_focused(rdf)
                .unwrap_or_default();

            for pn in prefix_nodes {
                // Changes focus node, should be restored afterwards
                collect_prefixes(rdf, &pn, &mut pm, &mut HashSet::new());
            }
            rdf.set_focus(&node);

            let prefixes_opt = if pm.is_empty() { None } else { Some(pm) };

            result.push(ASTComponent::BasicSparql {
                prefixes: prefixes_opt,
                deactivated,
                select,
                message,
            })
        }

        rdf.set_focus(&fshape);
        Ok(result)
    }
}

/// Recursively collects `(prefix, namespace)` pairs from a SHACL prefix ontology node.
///
/// Follows `sh:declare` to pick up `sh:prefix` / `sh:namespace` pairs, and
/// `owl:imports` to include prefixes declared in imported ontologies.
fn collect_prefixes<RDF: FocusRDF>(
    rdf: &mut RDF,
    node: &RDF::Term,
    out: &mut PrefixMap,
    visited: &mut HashSet<String>,
) {
    let node_str = node.to_string();
    if !visited.insert(node_str) {
        return;
    }

    rdf.set_focus(node);

    // sh:declare: bnodes with sh:prefix and sh:namespace
    if let Ok(decl_nodes) = ValuesPropertyParser::new(ShaclVocab::sh_declare()).parse_focused(rdf) {
        for decl in decl_nodes {
            rdf.set_focus(&decl);
            let prefix = SingleStringPropertyParser::new(ShaclVocab::sh_prefix()).parse_focused(rdf);
            let ns = SingleStringPropertyParser::new(ShaclVocab::sh_namespace()).parse_focused(rdf);
            if let (Ok(p), Ok(n)) = (prefix, ns)
                && let Ok(iri) = IriS::new(&n)
            {
                out.add_prefix(&p, iri);
            }
        }
        rdf.set_focus(node);
    }

    // owl:imports
    if let Ok(import_nodes) = ValuesPropertyParser::new(OwlVocab::owl_imports()).parse_focused(rdf) {
        for imp in import_nodes {
            collect_prefixes(rdf, &imp, out, visited);
        }
        rdf.set_focus(node);
    }
}

pub(crate) fn basic_sparql<RDF: FocusRDF>() -> impl RDFNodeParse<RDF, Output = Vec<ASTComponent>> {
    BasicSparqlConstraintParser(PhantomData)
}