atman-runtime 1.8.0

atman flow execution runtime: evaluator, tool dispatch, provider dispatch, executor, memory stores
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

use atman_dsl::parse::parse_file;
use atman_runtime::{Executor, Value, tools};

#[tokio::test]
async fn destructure_binds_each_field_into_scope() {
    let src = r#"flow t() -> string {
    { status, body } = { status: "ok", body: "hello" }
    return body
}
"#;
    let ex = Executor::new();
    tools::register_tier_zero(&ex.tools);
    let file = parse_file(src).unwrap();
    let val = ex.run(&file, "t", vec![]).await.expect("flow ok");
    match val {
        Value::Str(s) => assert_eq!(s, "hello"),
        other => panic!("expected str, got {other:?}"),
    }
}

#[tokio::test]
async fn destructure_supports_rename_into_new_name() {
    let src = r#"flow t() -> string {
    { error: err } = { error: "oops" }
    return err
}
"#;
    let ex = Executor::new();
    tools::register_tier_zero(&ex.tools);
    let file = parse_file(src).unwrap();
    let val = ex.run(&file, "t", vec![]).await.expect("flow ok");
    match val {
        Value::Str(s) => assert_eq!(s, "oops"),
        other => panic!("expected str, got {other:?}"),
    }
}

#[tokio::test]
async fn destructure_nested_pattern_binds_inner_leaf() {
    let src = r#"flow t() -> string {
    { outer: { inner_a, inner_b }, top } = { outer: { inner_a: "hi", inner_b: "there" }, top: "root" }
    return inner_a
}
"#;
    let ex = Executor::new();
    tools::register_tier_zero(&ex.tools);
    let file = parse_file(src).unwrap();
    let val = ex.run(&file, "t", vec![]).await.expect("flow ok");
    match val {
        Value::Str(s) => assert_eq!(s, "hi"),
        other => panic!("expected str, got {other:?}"),
    }
}

#[tokio::test]
async fn destructure_nested_pattern_missing_inner_field_errors() {
    let src = r#"flow t() -> string {
    { outer: { missing } } = { outer: { present: "yes" } }
    return missing
}
"#;
    let ex = Executor::new();
    tools::register_tier_zero(&ex.tools);
    let file = parse_file(src).unwrap();
    let err = ex.run(&file, "t", vec![]).await.expect_err("should error");
    let msg = format!("{err}");
    assert!(
        msg.contains("missing") || msg.contains("field"),
        "want inner-missing error, got: {msg}"
    );
}

#[tokio::test]
async fn destructure_nested_pattern_non_struct_inner_errors() {
    let src = r#"flow t() -> string {
    { outer: { a } } = { outer: "not a struct" }
    return a
}
"#;
    let ex = Executor::new();
    tools::register_tier_zero(&ex.tools);
    let file = parse_file(src).unwrap();
    let err = ex.run(&file, "t", vec![]).await.expect_err("should error");
    let msg = format!("{err}");
    assert!(
        msg.contains("struct"),
        "want struct-mismatch error, got: {msg}"
    );
}

#[tokio::test]
async fn destructure_missing_field_reports_missing_arg() {
    let src = r#"flow t() -> string {
    { nope } = { present: "yes" }
    return nope
}
"#;
    let ex = Executor::new();
    tools::register_tier_zero(&ex.tools);
    let file = parse_file(src).unwrap();
    let err = ex.run(&file, "t", vec![]).await.expect_err("should error");
    let msg = format!("{err}");
    assert!(
        msg.contains("nope") || msg.contains("field"),
        "want missing-field error, got: {msg}"
    );
}