debugbundle 1.0.0-alpha.1

mod helpers;
use debugbundle::{Config, ConfigError, Level};
use std::{sync::Arc, time::Duration};
fn config(service: &str) -> Config {
    Config {
        service: service.into(),
        ..helpers::configured(Arc::new(helpers::Recorder::default()))
    }
}

#[test]
fn configuration_rejects_invalid_limits_and_preserves_zero_sampling() {
    let mut config = config("checkout");
    assert!(config.validate().is_ok());
    config.sample_rate = 0.0;
    assert!(config.validate().is_ok());
    config.sample_rate = f64::NAN;
    assert_eq!(config.validate(), Err(ConfigError::InvalidLimit));
    config.sample_rate = 1.0;
    config.request_timeout = Duration::ZERO;
    assert!(config.validate().is_err());
    config.request_timeout = Duration::from_secs(5);
    config.max_buffered_events = 1001;
    assert!(config.validate().is_err());
}
#[test]
fn missing_credentials_are_not_healthy_connected_configuration() {
    let config = Config::default();
    assert_eq!(config.validate(), Err(ConfigError::MissingToken));
    assert_eq!(config.log_level, Level::Warning);
    assert!(Config {
        enabled: false,
        ..config
    }
    .validate()
    .is_ok());
}

#[test]
fn reader_pin_accepts_unique_features_in_any_order_and_integer_json_numbers() {
    let config = Config {
        evidence_capabilities: Some(
            serde_json::json!({"version":1.0,"features":["recovery_v1","exception_evidence_v1"]}),
        ),
        ..config("service")
    };
    assert!(config.validate().is_ok());
    assert_eq!(
        debugbundle::Client::new(config).status().state,
        debugbundle::ConnectionStatus::Healthy
    );
}

#[test]
fn discovery_identity_and_endpoint_values_cannot_carry_credentials() {
    for identity in [
        "dbundle_proj_SYNTHETIC_SECRET",
        "password=SYNTHETIC_SECRET",
        "service\nAuthorization: secret",
    ] {
        assert!(config(identity).validate().is_err());
        assert!(Config {
            environment: identity.into(),
            ..config("service")
        }
        .validate()
        .is_err());
    }
    for endpoint in [
        "https://api.example.test/v1/events?token=SYNTHETIC_SECRET",
        "https://api.example.test/dbundle_proj_SYNTHETIC_SECRET",
        "https://api.example.test/v1/events?%74oken=SYNTHETIC_SECRET",
    ] {
        assert!(Config {
            endpoint: endpoint.into(),
            ..config("service")
        }
        .validate()
        .is_err());
    }
    assert!(Config {
        endpoint: "https://api.example.test/v1/events?mode=a%20b&channel=stable".into(),
        ..config("service")
    }
    .validate()
    .is_ok());
}

#[cfg(not(feature = "http"))]
#[test]
fn core_only_requires_an_explicit_custom_transport() {
    assert_eq!(
        Config::new("synthetic", "service").validate(),
        Err(ConfigError::MissingTransport)
    );
    assert!(config("service").validate().is_ok());
}