mosaik 0.3.19

A Rust runtime for building self-organizing, leaderless distributed systems.
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

use {
	super::*,
	crate::utils::{discover_all, timeout_s},
	futures::future::join_all,
	mosaik::*,
};

#[tokio::test]
async fn members_can_see_each_other() -> anyhow::Result<()> {
	// bond formation timeout in seconds
	const T: u64 = 5;

	let network_id = NetworkId::random();

	let n0 = Network::new(network_id).await?;
	let n1 = Network::new(network_id).await?;
	let n2 = Network::new(network_id).await?;
	let n3 = Network::new(network_id).await?;

	discover_all([&n0, &n1, &n2, &n3]).await?;

	let key1 = GroupKey::from_secret("group1secret");
	let key2 = GroupKey::from_secret("group2secret");
	let key3 = GroupKey::random();

	tracing::debug!("group1 key: {key1}");
	tracing::debug!("group2 key: {key2}");
	tracing::debug!("group3 key: {key3}");

	// group1: n0 and n1
	let g1_0 = n0.groups().with_key(key1).join();
	let g1_1 = n1.groups().with_key(key1).join();

	// group2: n0, n2 and n3
	let g2_0 = n0.groups().with_key(key2).join();
	let g2_2 = n2.groups().with_key(key2).join();
	let g2_3 = n3.groups().with_key(key2).join();

	// group3: n1 and n2
	let g3_1 = n1.groups().with_key(key3).join();
	let g3_2 = n2.groups().with_key(key3).join();

	tracing::debug!("group1 id: {}", Short(g1_0.id()));
	tracing::debug!("group2 id: {}", Short(g2_0.id()));
	tracing::debug!("group3 id: {}", Short(g3_1.id()));

	join_all([
		timeout_s(T, ensure_bonds_formed(&g1_0, &n0, &[&n1], "g1_0")),
		timeout_s(T, ensure_bonds_formed(&g1_1, &n1, &[&n0], "g1_1")),
		timeout_s(T, ensure_bonds_formed(&g2_0, &n0, &[&n2, &n3], "g2_0")),
		timeout_s(T, ensure_bonds_formed(&g2_2, &n2, &[&n0, &n3], "g2_2")),
		timeout_s(T, ensure_bonds_formed(&g2_3, &n3, &[&n0, &n2], "g2_3")),
		timeout_s(T, ensure_bonds_formed(&g3_1, &n1, &[&n2], "g3_1")),
		timeout_s(T, ensure_bonds_formed(&g3_2, &n2, &[&n1], "g3_2")),
	])
	.await
	.into_iter()
	.collect::<Result<Vec<_>, _>>()
	.expect("not all groups formed successfully");

	Ok(())
}