phlow-runtime 0.4.2

Phlow is a fast, modular runtime for building backends with YAML flows, Rust modules, and native OpenTelemetry observability.
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

use phlow_engine::Context;
use phlow_runtime::PhlowRuntime;
use phlow_sdk::prelude::Value;

#[test]
fn preprocess_string_inserts_modules() {
    let runtime = PhlowRuntime::new();
    let script = r#"
steps:
  - return: "ok"
"#;

    let value = runtime.preprocess_string(script).unwrap();
    assert!(value.get("steps").is_some());
    let modules = value.get("modules").expect("modules key should exist");
    assert!(modules.is_array());
}

#[tokio::test]
async fn run_preprocessed_pipeline_returns_value() {
    let runtime = PhlowRuntime::new();
    let script = r#"
steps:
  - return: "ok"
"#;

    let pipeline = runtime.preprocess_string(script).unwrap();
    let result = PhlowRuntime::run_preprocessed(pipeline, Context::new())
        .await
        .unwrap();

    assert_eq!(result, Value::from("ok"));
}