eggress-testkit 1.0.4

Test utilities for eggress 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

//! Scenario-driven oracle harness for comparing eggress with pproxy.
//!
//! This module provides a structured framework for running equivalent
//! scenarios against both pproxy and eggress, normalizing outputs, and
//! generating JSON comparison reports.
//!
//! # Gating
//!
//! Oracle differential tests are gated on `EGRESS_PPROXY_CERTIFY=1`
//! and require Python 3 with pproxy==2.7.9 installed. Structural tests
//! that need no pproxy run without any gate variable.

pub mod observations;
pub mod probes;
pub mod profile;
pub mod report;
pub mod scenario;
pub mod schema;
pub mod supervisor;

use std::time::Duration;

/// Environment variable that gates oracle differential tests.
pub const ORACLE_GATE_VAR: &str = "EGRESS_PPROXY_CERTIFY";

/// Check if the oracle test gate is enabled.
pub fn oracle_gate_enabled() -> bool {
    std::env::var(ORACLE_GATE_VAR)
        .map(|v| v == "1")
        .unwrap_or(false)
}

/// Require the oracle gate to be enabled. Panics with a clear message if not.
pub fn require_oracle_gate() {
    if !oracle_gate_enabled() {
        panic!(
            "oracle tests require {}=1 and pproxy=={}",
            ORACLE_GATE_VAR,
            crate::differential::PINNED_PPROXY_VERSION
        );
    }
    if !pproxy_available() {
        panic!(
            "pproxy not available; install with: pip install pproxy=={}",
            crate::differential::PINNED_PPROXY_VERSION
        );
    }
}

fn pproxy_available() -> bool {
    let python = crate::differential::find_python_binary();
    std::process::Command::new(&python)
        .args(["-c", "import pproxy"])
        .stdout(std::process::Stdio::null())
        .stderr(std::process::Stdio::null())
        .status()
        .map(|s| s.success())
        .unwrap_or(false)
}

/// Default timeout for oracle scenario execution.
pub const DEFAULT_SCENARIO_TIMEOUT: Duration = Duration::from_secs(15);

/// Default timeout for process startup.
pub const DEFAULT_STARTUP_TIMEOUT: Duration = Duration::from_secs(5);

/// Default timeout for I/O operations.
pub const DEFAULT_IO_TIMEOUT: Duration = Duration::from_secs(3);