eggress-cli 1.0.7

CLI binary for the eggress multi-protocol proxy
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

#[test]
fn test_cli_help() {
    assert_cmd::Command::cargo_bin("eggress")
        .unwrap()
        .arg("--help")
        .assert()
        .success()
        .stdout(predicates::str::contains("eggress"))
        .stdout(predicates::str::contains("--listen"))
        .stdout(predicates::str::contains("--remote"));
}

/// `--config` is a single global option: it is accepted before and after
/// the subcommand with identical effect.
#[test]
fn global_config_placement_before_and_after_subcommand() {
    let dir = tempfile::tempdir().unwrap();
    let config_path = dir.path().join("eggress.toml");
    std::fs::write(
        &config_path,
        r#"
version = 1
[[listeners]]
name = "http-in"
bind = "127.0.0.1:0"
protocols = ["http"]
"#,
    )
    .unwrap();

    for args in [
        vec![
            "--config",
            config_path.to_str().unwrap(),
            "route",
            "example.com:443",
        ],
        vec![
            "route",
            "example.com:443",
            "--config",
            config_path.to_str().unwrap(),
        ],
        vec![
            "route",
            "example.com:443",
            "-c",
            config_path.to_str().unwrap(),
        ],
    ] {
        assert_cmd::Command::cargo_bin("eggress")
            .unwrap()
            .args(&args)
            .assert()
            .success()
            .stdout(predicates::str::contains("Target: example.com:443"));
    }
}

/// Closed value domains fail at parse time instead of silently falling back.
#[test]
fn invalid_closed_domain_values_are_parse_errors() {
    // --log-format
    assert_cmd::Command::cargo_bin("eggress")
        .unwrap()
        .args(["--log-format", "jsno", "version"])
        .assert()
        .code(2);
    // upstream test --mode
    assert_cmd::Command::cargo_bin("eggress")
        .unwrap()
        .args(["upstream", "test", "--mode", "socks"])
        .assert()
        .code(2);
    // route --protocol
    assert_cmd::Command::cargo_bin("eggress")
        .unwrap()
        .args(["route", "example.com:443", "--protocol", "quic"])
        .assert()
        .code(2);
}

/// A listener that cannot bind fails closed with the bind exit code.
#[test]
fn occupied_listener_port_exits_bind_failure() {
    let occupied = std::net::TcpListener::bind("127.0.0.1:0").unwrap();
    let port = occupied.local_addr().unwrap().port();
    assert_cmd::Command::cargo_bin("eggress")
        .unwrap()
        .args(["-l", &format!("http://127.0.0.1:{port}")])
        .timeout(std::time::Duration::from_secs(20))
        .assert()
        .code(4)
        .stderr(predicates::str::contains("failed to bind"));
}