Function test_ssv_network_fetch

tests/tests/pbs_mux.rs:28–60

Tests that a successful SSV network fetch is handled and parsed properly

()

#[tokio::test]
/// Tests that a successful SSV network fetch is handled and parsed properly
async fn test_ssv_network_fetch() -> Result<()> {
    // Start the mock server
    let port = 30100;
    let _server_handle = create_mock_ssv_server(port, None).await?;
    let url =
        Url::parse(&format!("http://localhost:{port}/api/v4/test_chain/validators/in_operator/1"))
            .unwrap();
    let response =
        fetch_ssv_pubkeys_from_url(url, Duration::from_secs(HTTP_TIMEOUT_SECONDS_DEFAULT)).await?;

    // Make sure the response is correct
    // NOTE: requires that ssv_data.json dpesn't change
    assert_eq!(response.validators.len(), 3);
    let expected_pubkeys = [
        bls_pubkey_from_hex_unchecked(
            "967ba17a3e7f82a25aa5350ec34d6923e28ad8237b5a41efe2c5e325240d74d87a015bf04634f21900963539c8229b2a",
        ),
        bls_pubkey_from_hex_unchecked(
            "ac769e8cec802e8ffee34de3253be8f438a0c17ee84bdff0b6730280d24b5ecb77ebc9c985281b41ee3bda8663b6658c",
        ),
        bls_pubkey_from_hex_unchecked(
            "8c866a5a05f3d45c49b457e29365259021a509c5daa82e124f9701a960ee87b8902e87175315ab638a3d8b1115b23639",
        ),
    ];
    for (i, validator) in response.validators.iter().enumerate() {
        assert_eq!(validator.pubkey, expected_pubkeys[i]);
    }

    // Clean up the server handle
    _server_handle.abort();

    Ok(())
}

#[tokio::test]
/// Tests that the SSV network fetch is handled properly when the response's