holochain 0.7.0-dev.22

Holochain, a framework for distributed applications
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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86

use crate::prelude::fake_dna_hash;
use crate::sweettest::*;
use hdk::prelude::CloneCellId;
use hdk::prelude::DnaModifiersOpt;
use holochain_types::app::{CreateCloneCellPayload, EnableCloneCellPayload};
use holochain_types::network::Kitsune2NetworkMetricsRequest;
use holochain_types::prelude::InstalledAppId;
use holochain_wasm_test_utils::TestWasm;

#[tokio::test(flavor = "multi_thread")]
async fn network_metrics() {
    holochain_trace::test_run();

    let (dna, _, _) = SweetDnaFile::unique_from_test_wasms(vec![TestWasm::Create]).await;
    let number_of_peers = 3;
    let mut conductors = SweetConductorBatch::standard(number_of_peers).await;
    let app_id: InstalledAppId = "app".into();
    conductors
        .setup_app(&app_id, std::slice::from_ref(&dna))
        .await
        .unwrap();

    conductors.exchange_peer_info().await;

    let network_metrics = conductors[0]
        .dump_network_metrics_for_app(
            &app_id,
            Kitsune2NetworkMetricsRequest {
                dna_hash: Some(dna.dna_hash().clone()),
                include_dht_summary: false,
            },
        )
        .await
        .unwrap();

    assert!(network_metrics.contains_key(dna.dna_hash()));

    let network_metrics = &network_metrics[dna.dna_hash()];
    assert_eq!(network_metrics.gossip_state_summary.peer_meta.len(), 2);

    let fake_dna = fake_dna_hash(1);
    let response = conductors[0]
        .dump_network_metrics_for_app(
            &app_id,
            Kitsune2NetworkMetricsRequest {
                dna_hash: Some(fake_dna),
                include_dht_summary: false,
            },
        )
        .await;
    assert!(response.is_err());

    // Create a disabled clone cell for app1
    let clone_cell = conductors[0]
        .create_clone_cell(
            &app_id,
            CreateCloneCellPayload {
                role_name: dna.dna_hash().to_string(),
                modifiers: DnaModifiersOpt::none().with_network_seed("test_seed".to_string()),
                membrane_proof: None,
                name: Some("disabled_clone".into()),
            },
        )
        .await
        .unwrap();

    let clone_cell_id = CloneCellId::CloneId(clone_cell.clone_id);
    let response = conductors[0]
        .clone()
        .enable_clone_cell(&app_id, &EnableCloneCellPayload { clone_cell_id })
        .await;
    assert!(response.is_ok());

    let response = conductors[0]
        .dump_network_metrics_for_app(
            &app_id,
            Kitsune2NetworkMetricsRequest {
                dna_hash: Some(clone_cell.cell_id.dna_hash().clone()),
                include_dht_summary: false,
            },
        )
        .await;
    assert!(response
        .unwrap()
        .contains_key(clone_cell.cell_id.dna_hash()));
}