hyperi-rustlib 2.5.4

Opinionated Rust framework for high-throughput data pipelines at PB scale. Auto-wiring config, logging, metrics, tracing, health, and graceful shutdown — built from many years of production infrastructure experience.
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

// Project:   hyperi-rustlib
// File:      tests/integration/env_parity.rs
// Purpose:   Environment detection parity tests
// Language:  Rust
//
// License:   FSL-1.1-ALv2
// Copyright: (c) 2026 HYPERI PTY LIMITED

#![allow(unsafe_code)]

//! Environment detection parity tests.
//!
//! These tests verify that environment detection behaves identically
//! to hyperi-golib's env package.

use hyperi_rustlib::env::{Environment, get_app_env};

/// Test that Environment::detect() returns valid enum.
#[test]
fn test_detect_returns_valid_environment() {
    let env = Environment::detect();
    assert!(matches!(
        env,
        Environment::Kubernetes
            | Environment::Docker
            | Environment::Container
            | Environment::BareMetal
    ));
}

/// Test is_container() matches Go behaviour.
#[test]
fn test_is_container_parity() {
    // K8s, Docker, Container should return true
    assert!(Environment::Kubernetes.is_container());
    assert!(Environment::Docker.is_container());
    assert!(Environment::Container.is_container());

    // BareMetal should return false
    assert!(!Environment::BareMetal.is_container());
}

/// Test get_app_env() priority: APP_ENV > ENVIRONMENT > ENV > "development".
#[test]
fn test_get_app_env_priority() {
    // SAFETY: single-threaded test, no concurrent env access
    unsafe {
        // Clear all
        std::env::remove_var("APP_ENV");
        std::env::remove_var("ENVIRONMENT");
        std::env::remove_var("ENV");

        // Default should be "development"
        assert_eq!(get_app_env(), "development");

        // ENV should override default
        std::env::set_var("ENV", "staging");
        assert_eq!(get_app_env(), "staging");

        // ENVIRONMENT should override ENV
        std::env::set_var("ENVIRONMENT", "production");
        assert_eq!(get_app_env(), "production");

        // APP_ENV should override all
        std::env::set_var("APP_ENV", "testing");
        assert_eq!(get_app_env(), "testing");

        // Cleanup
        std::env::remove_var("APP_ENV");
        std::env::remove_var("ENVIRONMENT");
        std::env::remove_var("ENV");
    }
}

/// Test Display implementation matches Go string output.
#[test]
fn test_environment_display_parity() {
    assert_eq!(Environment::Kubernetes.to_string(), "kubernetes");
    assert_eq!(Environment::Docker.to_string(), "docker");
    assert_eq!(Environment::Container.to_string(), "container");
    assert_eq!(Environment::BareMetal.to_string(), "bare_metal");
}