rskit-dataset 0.2.0-alpha.3

Dataset collection framework: source, transform, target, collector
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

//! Schema-backed validation for structured records.

use rskit_errors::AppResult;

use crate::schema::DatasetSchema;
use crate::validate::Validator;

use super::model::DatasetRecord;

/// Rejects records that fail a compiled [`DatasetSchema`].
pub struct SchemaValidator {
    schema: DatasetSchema,
}

impl SchemaValidator {
    /// Create a validator from a compiled schema.
    #[must_use]
    pub fn new(schema: DatasetSchema) -> Self {
        Self { schema }
    }

    /// Compile a JSON Schema and wrap it as a record validator.
    pub fn compile(schema: &serde_json::Value) -> AppResult<Self> {
        Ok(Self::new(DatasetSchema::compile(schema)?))
    }
}

impl Validator<DatasetRecord> for SchemaValidator {
    fn validate(&self, item: &DatasetRecord) -> AppResult<()> {
        self.schema.validate(&item.to_json())
    }
}

#[cfg(test)]
mod tests {
    use rskit_errors::ErrorCode;
    use serde_json::json;

    use super::*;

    #[test]
    fn schema_validator_accepts_valid_and_rejects_invalid_records() {
        let validator = SchemaValidator::compile(&json!({
            "type": "object",
            "required": ["id"],
            "properties": { "id": {"type": "string"} }
        }))
        .unwrap();

        validator
            .validate(&DatasetRecord::from_fields([("id", json!("a"))]))
            .unwrap();

        let error = validator
            .validate(&DatasetRecord::from_fields([("id", json!(1))]))
            .unwrap_err();
        assert_eq!(error.code(), ErrorCode::InvalidInput);
    }
}