rudof_lib 0.2.18

RDF data shapes implementation in Rust
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

use crate::{
    Rudof, RudofConfig,
    api::data::implementations::load_data,
    api::pgschema::implementations::load_pgschema::load_pgschema,
    api::pgschema::implementations::load_typemap::load_typemap,
    api::pgschema::implementations::serialize_pgschema_validation_results::serialize_pgschema_validation_results,
    api::pgschema::implementations::validate_pgschema::validate_pgschema,
    formats::{DataFormat, InputSpec, ResultPgSchemaValidationFormat},
};

/// Helper: serialize validation results to string
fn serialize_validation_to_string(
    rudof: &Rudof,
    format: Option<ResultPgSchemaValidationFormat>,
    show_colors: Option<bool>,
) -> String {
    let mut buffer = Vec::new();

    serialize_pgschema_validation_results(rudof, format.as_ref(), show_colors, &mut buffer).unwrap();

    String::from_utf8(buffer).unwrap()
}

#[test]
fn test_validate_and_serialize_pgschema() {
    let mut rudof = Rudof::new(RudofConfig::default());

    // Load PG data
    let pg_data = InputSpec::str(
        r#"
(n1 {"Student"}["name": "Alice", "age": 23])
(n2_wrong {"Student"}["name": "Bob", "age": 12])
(n3_wrong {"Student"}["name": "Carol", "age": "unknown"])
        "#,
    );

    load_data(
        &mut rudof,
        Some(&[pg_data]),
        Some(&DataFormat::Pg),
        None,
        None,
        None,
        None,
        None,
    )
    .unwrap();

    // Load PG schema
    let pg_schema = InputSpec::str(
        r#"
CREATE NODE TYPE ( AdultStudentType: Student {
    name: STRING ,
    age: INTEGER CHECK > 18
})
        "#,
    );

    load_pgschema(&mut rudof, &pg_schema, None).unwrap();

    // Load typemap
    let typemap = InputSpec::str(
        r#"
n1: AdultStudentType,
n2_wrong: AdultStudentType,
n3_wrong: AdultStudentType
        "#,
    );

    load_typemap(&mut rudof, &typemap).unwrap();

    // Validate
    validate_pgschema(&mut rudof).unwrap();

    // Serialize results in different formats
    let compact = serialize_validation_to_string(&rudof, Some(ResultPgSchemaValidationFormat::Compact), None);
    println!("\n===== Compact Format =====\n{}\n", compact);

    let json = serialize_validation_to_string(&rudof, Some(ResultPgSchemaValidationFormat::Json), None);
    println!("===== JSON Format =====\n{}\n", json);

    let csv = serialize_validation_to_string(&rudof, Some(ResultPgSchemaValidationFormat::Csv), Some(true));
    println!("===== CSV Format =====\n{}\n", csv);

    // Assertions - should find validation errors
    // n1 should pass (age 23 > 18)
    // n2_wrong should fail (age 12 <= 18)
    // n3_wrong should fail (age is "unknown", not INTEGER)
    assert!(
        compact.contains("n2_wrong")
            || compact.contains("n3_wrong")
            || compact.contains("error")
            || compact.contains("fail")
    );
    assert!(json.contains("n2_wrong") || json.contains("n3_wrong"));
    assert!(csv.contains("n2_wrong") || csv.contains("n3_wrong"));
    println!("===== test_validate_and_serialize_pgschema =====\nValidation completed successfully");
}