statsig-rust 0.19.2

mod utils;

use crate::utils::mock_event_logging_adapter::MockEventLoggingAdapter;
use crate::utils::mock_specs_adapter::MockSpecsAdapter;
use assert_json_diff::assert_json_eq;
use serde_json::json;
use statsig_rust::{Statsig, StatsigOptions, StatsigUser};
use std::sync::Arc;

async fn setup(
    options_overrides: Option<StatsigOptions>,
) -> (Statsig, Arc<MockEventLoggingAdapter>) {
    let logging_adapter = Arc::new(MockEventLoggingAdapter::new());

    let options = StatsigOptions {
        specs_adapter: Some(Arc::new(MockSpecsAdapter::with_data(
            "tests/data/dcs_missing_gates.json",
        ))),
        event_logging_adapter: Some(logging_adapter.clone()),
        ..options_overrides.unwrap_or_default()
    };

    let statsig = Statsig::new("secret-key", Some(Arc::new(options)));
    statsig.initialize().await.unwrap();
    (statsig, logging_adapter)
}

#[tokio::test]
async fn test_fail_gate_passes_when_target_gate_does_not_exist() {
    let (statsig, logging_adapter) = setup(None).await;

    let user = StatsigUser::with_user_id("a_user".to_string());
    let fail_gate = statsig.check_gate(&user, "test_fail_gate_not_found");

    assert!(fail_gate);

    statsig.shutdown().await.unwrap();

    assert_json_eq!(
        json!(&logging_adapter.force_get_first_event()["secondaryExposures"]),
        json!([])
    );
}

#[tokio::test]
async fn test_fail_gate_passes_when_target_gate_name_is_empty() {
    let (statsig, logging_adapter) = setup(None).await;

    let user = StatsigUser::with_user_id("a_user".to_string());
    let fail_gate = statsig.check_gate(&user, "test_fail_gate_not_set");

    assert!(fail_gate);

    statsig.shutdown().await.unwrap();

    assert_json_eq!(
        json!(&logging_adapter.force_get_first_event()["secondaryExposures"]),
        json!([])
    );
}

#[tokio::test]
async fn test_pass_gate_passes_when_target_gate_does_not_exist() {
    let (statsig, logging_adapter) = setup(None).await;

    let user = StatsigUser::with_user_id("a_user".to_string());
    let pass_gate = statsig.check_gate(&user, "test_pass_gate_not_found");

    assert!(!pass_gate);

    statsig.shutdown().await.unwrap();

    assert_json_eq!(
        json!(&logging_adapter.force_get_first_event()["secondaryExposures"]),
        json!([])
    );
}

#[tokio::test]
async fn test_pass_gate_passes_when_target_gate_name_is_empty() {
    let (statsig, logging_adapter) = setup(None).await;

    let user = StatsigUser::with_user_id("a_user".to_string());
    let pass_gate = statsig.check_gate(&user, "test_pass_gate_not_set");

    assert!(!pass_gate);

    statsig.shutdown().await.unwrap();

    assert_json_eq!(
        json!(&logging_adapter.force_get_first_event()["secondaryExposures"]),
        json!([])
    );
}