mubit-sdk 0.7.0

Umbrella Rust SDK for Mubit core/control planes
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

#[path = "support/utils.rs"]
mod _utils;

use _utils::{boxed_error, cleanup_run, create_client, new_run_id, print_summary, require};
use mubit_sdk::TransportMode;
use serde_json::{json, Value};
use std::error::Error;
use std::time::Instant;

#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<(), Box<dyn Error>> {
    let name = "control_state_structured_variables";
    let started = Instant::now();
    let client = create_client().await?;
    let run_id = new_run_id("control_state_structured_variables");
    client.set_run_id(Some(run_id.clone()));
    client.set_transport(TransportMode::Http);

    let mut passed = true;
    let mut detail = "validated control structured variable state-management".to_string();
    let mut metrics = json!({});

    let scenario = async {
        let variable_name = "planner_state";
        let value_json = json!({ "phase": "draft", "confidence": 0.91_f32 }).to_string();

        let set = client
            .set_variable(json!({
                "run_id": run_id,
                "name": variable_name,
                "value_json": value_json,
                "source": "explicit",
            }))
            .await?;
        require(
            set.get("success").and_then(Value::as_bool).unwrap_or(false),
            format!("set_variable failed: {set}"),
        )?;

        let get = client
            .get_variable(json!({ "run_id": run_id, "name": variable_name }))
            .await?;
        let list = client
            .list_variables(json!({ "run_id": run_id }))
            .await?;
        let delete = client
            .delete_variable(json!({ "run_id": run_id, "name": variable_name }))
            .await?;

        require(get.is_object(), format!("get_variable failed: {get}"))?;
        require(list.is_object(), format!("list_variables failed: {list}"))?;
        require(
            delete
                .get("success")
                .and_then(Value::as_bool)
                .unwrap_or(false),
            format!("delete_variable failed: {delete}"),
        )?;

        let variables = list
            .get("variables")
            .and_then(Value::as_array)
            .ok_or_else(|| boxed_error(format!("list_variables payload invalid: {list}")))?;
        require(
            variables
                .iter()
                .any(|entry| entry.get("name").and_then(Value::as_str) == Some(variable_name)),
            format!("variable not present in list_variables: {list}"),
        )?;

        metrics = json!({
            "run_id": run_id,
            "variable_name": variable_name,
            "variable_count": variables.len(),
        });
        Ok::<(), Box<dyn Error>>(())
    }
    .await;

    if let Err(err) = scenario {
        passed = false;
        detail = err.to_string();
    }

    let cleanup_ok = cleanup_run(&client, &run_id).await;
    if !cleanup_ok {
        passed = false;
        detail = format!("{detail} | cleanup failures");
    }

    print_summary(
        name,
        passed,
        &detail,
        &metrics,
        started.elapsed().as_secs_f64(),
        cleanup_ok,
    );

    if passed {
        Ok(())
    } else {
        Err(boxed_error(detail))
    }
}