pfp 0.5.0

Prefect CLI - a fast Rust CLI for managing Prefect deployments and flow runs
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

use assert_cmd::cargo::cargo_bin_cmd;
use predicates::prelude::*;

/// Verify that running pfp with no arguments shows help/usage info.
#[test]
fn no_args_shows_usage() {
    cargo_bin_cmd!("pfp")
        .assert()
        .failure()
        .stderr(predicate::str::contains("Usage"));
}

/// Verify that --version prints the version.
#[test]
fn version_flag() {
    cargo_bin_cmd!("pfp")
        .arg("--version")
        .assert()
        .success()
        .stdout(predicate::str::contains(env!("CARGO_PKG_VERSION")));
}

/// Verify that --help lists all subcommands.
#[test]
fn help_lists_subcommands() {
    cargo_bin_cmd!("pfp")
        .arg("--help")
        .assert()
        .success()
        .stdout(predicate::str::contains("ls"))
        .stdout(predicate::str::contains("run"))
        .stdout(predicate::str::contains("runs"))
        .stdout(predicate::str::contains("logs"))
        .stdout(predicate::str::contains("pause"))
        .stdout(predicate::str::contains("resume"))
        .stdout(predicate::str::contains("cancel"));
}

/// Malformed JSON piped via `--params-file -` is rejected with exit code 2,
/// before any config or network work. Guards that the stdin branch is wired
/// and read, and that the payload error surfaces ahead of config loading.
#[test]
fn run_params_file_stdin_malformed_json_rejected() {
    cargo_bin_cmd!("pfp")
        .args(["run", "some-deploy", "--params-file", "-"])
        .write_stdin("not json")
        .assert()
        .failure()
        .code(2)
        .stderr(predicate::str::contains("Invalid JSON in params payload"));
}

/// Valid JSON piped via `--params-file -` is read exactly once: it parses
/// successfully and execution proceeds past parsing to the (unreachable) API,
/// rather than failing with an empty-stdin JSON/EOF error. Regression guard
/// for the stdin double-read bug. PREFECT_API_URL points at a closed port so
/// the run fails fast on connection refused instead of hitting a real server.
#[test]
fn run_params_file_stdin_valid_json_read_once() {
    cargo_bin_cmd!("pfp")
        .args(["run", "some-deploy", "--params-file", "-"])
        .env("PREFECT_API_URL", "http://127.0.0.1:1")
        .env_remove("PREFECT_API_AUTH_STRING")
        .write_stdin(r#"{"config": {"action": "plan"}}"#)
        .assert()
        .failure()
        .stderr(predicate::str::contains("Invalid JSON").not())
        .stderr(predicate::str::contains("EOF").not());
}