tupa-cli 0.8.2

Command-line interface for TupaLang
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
110
111
112
113
114
115
116
117
118
119
120
121

use assert_cmd::Command;
use std::time::Instant;

fn repo_root() -> std::path::PathBuf {
    std::path::PathBuf::from(env!("CARGO_MANIFEST_DIR")).join("../..")
}

fn run_e2e_enabled() -> bool {
    std::env::var("TUPA_RUN_E2E").as_deref() == Ok("1")
}

#[test]
fn run_fraud_detection_plan_only_and_run() {
    if !run_e2e_enabled() {
        eprintln!("skipping run_fraud_detection_plan_only_and_run (set TUPA_RUN_E2E=1)");
        return;
    }

    let root = repo_root();
    let mut gen = Command::new(env!("CARGO_BIN_EXE_tupa"));
    gen.current_dir(&root)
        .args([
            "codegen",
            "--plan-only",
            "examples/pipeline/fraud_complete.tp",
        ])
        .assert()
        .success();

    let mut run = Command::new(env!("CARGO_BIN_EXE_tupa"));
    run.current_dir(&root)
        .args([
            "run",
            "--plan",
            "fraud_complete.plan.json",
            "--pipeline",
            "FraudDetection",
            "--input",
            "examples/pipeline/tx.json",
        ])
        .assert()
        .success()
        .stdout(predicates::str::contains("\"status\": \"pass\""));
}

#[test]
fn run_credit_decision_report_contains_approved() {
    if !run_e2e_enabled() {
        eprintln!("skipping run_credit_decision_report_contains_approved (set TUPA_RUN_E2E=1)");
        return;
    }

    let root = repo_root();
    let tmp_path = root.join("tmp_input_i64.json");
    std::fs::write(&tmp_path, "100").unwrap();

    let mut run = Command::new(env!("CARGO_BIN_EXE_tupa"));
    run.current_dir(&root)
        .args([
            "run",
            "--pipeline",
            "CreditDecision",
            "--input",
            tmp_path.to_str().unwrap(),
            "examples/pipeline/credit_decision.tp",
        ])
        .assert()
        .success()
        .stdout(predicates::str::contains("\"status\": \"pass\""));

    let _ = std::fs::remove_file(&tmp_path);
}

#[test]
fn perf_codegen_fraud_medium_under_target() {
    let root = repo_root();
    let start = Instant::now();
    let mut gen = Command::new(env!("CARGO_BIN_EXE_tupa"));
    gen.current_dir(&root)
        .args(["codegen", "examples/pipeline/fraud_complete.tp"])
        .assert()
        .success();

    let elapsed = start.elapsed();
    println!(
        "perf: codegen fraud_complete took {} ms",
        elapsed.as_millis()
    );
    assert!(
        elapsed.as_millis() <= 500,
        "codegen took {} ms (> 500ms threshold)",
        elapsed.as_millis()
    );
}

#[test]
#[ignore]
fn perf_run_fraud_medium_under_target() {
    let root = repo_root();
    let start = Instant::now();
    let mut run = Command::new(env!("CARGO_BIN_EXE_tupa"));
    run.current_dir(&root)
        .args([
            "run",
            "--pipeline",
            "FraudDetection",
            "--input",
            "examples/pipeline/tx.json",
            "examples/pipeline/fraud_complete.tp",
        ])
        .assert()
        .success();

    let elapsed = start.elapsed();
    println!("perf: run fraud_complete took {} ms", elapsed.as_millis());
    assert!(
        elapsed.as_millis() <= 500,
        "run took {} ms (> 500ms threshold)",
        elapsed.as_millis()
    );
}