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
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
107
108
109

#[test]
fn test_lookup_in_pipe() {
    // Full pipe: lookup then transform result
    // Simpler test: just lookup and verify
    let pipe = V2Pipe {
        start: V2Start::Literal(json!(null)),
        steps: vec![V2Step::Op(V2OpStep {
            op: "lookup_first".to_string(),
            args: vec![
                V2Expr::Pipe(V2Pipe {
                    start: V2Start::Ref(V2Ref::Context("departments".to_string())),
                    steps: vec![],
                }),
                V2Expr::Pipe(V2Pipe {
                    start: V2Start::Literal(json!("id")),
                    steps: vec![],
                }),
                V2Expr::Pipe(V2Pipe {
                    start: V2Start::Ref(V2Ref::Input("dept_id".to_string())),
                    steps: vec![],
                }),
                V2Expr::Pipe(V2Pipe {
                    start: V2Start::Literal(json!("budget")),
                    steps: vec![],
                }),
            ],
        })],
    };
    let record = json!({"dept_id": 2}); // Sales dept
    let context = json!({"departments": make_departments()});
    let out = json!({});
    let ctx = V2EvalContext::new();
    let result = eval_v2_pipe(&pipe, &record, Some(&context), &out, "test", &ctx);
    // Sales budget is 50000
    assert!(matches!(result, Ok(EvalValue::Value(v)) if v == json!(50000)));
}

#[test]
fn test_lookup_then_multiply() {
    // Two-step pipe: lookup, then multiply
    let pipe = V2Pipe {
        start: V2Start::Ref(V2Ref::Context("departments".to_string())),
        steps: vec![],
    };
    let record = json!({"dept_id": 2});
    let context = json!({"departments": make_departments()});
    let out = json!({});
    let ctx = V2EvalContext::new();

    // First verify context is accessible
    let result = eval_v2_pipe(&pipe, &record, Some(&context), &out, "test", &ctx);
    assert!(result.is_ok());

    // Now test just the lookup op step directly
    let op = V2OpStep {
        op: "lookup_first".to_string(),
        args: vec![
            V2Expr::Pipe(V2Pipe {
                start: V2Start::Ref(V2Ref::Context("departments".to_string())),
                steps: vec![],
            }),
            V2Expr::Pipe(V2Pipe {
                start: V2Start::Literal(json!("id")),
                steps: vec![],
            }),
            V2Expr::Pipe(V2Pipe {
                start: V2Start::Literal(json!(2)),
                steps: vec![],
            }),
            V2Expr::Pipe(V2Pipe {
                start: V2Start::Literal(json!("budget")),
                steps: vec![],
            }),
        ],
    };
    let result = eval_v2_op_step(
        &op,
        EvalValue::Value(json!(null)),
        &record,
        Some(&context),
        &out,
        "test",
        &ctx,
    );
    assert!(matches!(result, Ok(EvalValue::Value(ref v)) if *v == json!(50000)));

    // Now multiply it
    let multiply_op = V2OpStep {
        op: "multiply".to_string(),
        args: vec![V2Expr::Pipe(V2Pipe {
            start: V2Start::Literal(json!(1.1)),
            steps: vec![],
        })],
    };
    let budget = result.unwrap();
    let result2 = eval_v2_op_step(&multiply_op, budget, &record, None, &out, "test", &ctx);
    // multiply returns f64, check approximately 55000
    match result2 {
        Ok(EvalValue::Value(v)) => {
            let num = v.as_f64().expect("should be number");
            assert!(
                (num - 55000.0).abs() < 0.001,
                "expected 55000.0, got {}",
                num
            );
        }
        other => panic!("expected Ok(EvalValue::Value), got {:?}", other),
    }
}