rulemorph 0.3.3

YAML-based declarative data transformation engine for CSV/JSON to JSON
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

use serde_json::Value as JsonValue;

use crate::error::{TransformError, TransformErrorKind};
use crate::model::RuleFile;
use crate::serde_guard::parse_json_value_strict;

use super::{NormalizationOptions, enforce_json_limits, select_records_from_owned_document};

pub fn normalize_json_records(
    rule: &RuleFile,
    input: &str,
    options: &NormalizationOptions,
) -> Result<Vec<JsonValue>, TransformError> {
    let value = parse_json_value_strict(input).map_err(|err| {
        TransformError::new(
            TransformErrorKind::InvalidInput,
            format!("failed to parse JSON input: {}", err),
        )
    })?;
    enforce_json_limits(&value, options)?;

    let records = select_records_from_owned_document(
        value,
        rule.input
            .json
            .as_ref()
            .and_then(|json| json.records_path.as_deref()),
        "input.json.records_path",
        options,
    )?;
    Ok(records)
}