bee-network 0.2.2

Networking functionality and types for nodes and clients participating in the IOTA protocol built on top of `libp2p`.
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

// Copyright 2020-2021 IOTA Stiftung
// SPDX-License-Identifier: Apache-2.0

#![cfg(feature = "full")]

use super::common::{await_events::*, keys_and_ids::*, network_config::*, shutdown::*};

use crate::{standalone::init, Command, PeerRelation};

use tokio_stream::StreamExt;

#[tokio::test]
#[serial_test::serial]
async fn send_recv() {
    let config1 = get_in_memory_network_config(1337);
    let keys1 = gen_random_keys();

    let config2 = get_in_memory_network_config(4242);
    let keys2 = gen_random_keys();

    let network_id = gen_constant_net_id();

    let (tx1, mut rx1) = init(config1, keys1, network_id, shutdown(10))
        .await
        .expect("init failed");
    let (_tx2, mut rx2) = init(config2, keys2, network_id, shutdown(10))
        .await
        .expect("init failed");

    let _peer_id1 = get_local_id(&mut rx1).await;
    let _address1 = get_bind_address(&mut rx1).await;

    let peer_id2 = get_local_id(&mut rx2).await;
    let address2 = get_bind_address(&mut rx2).await;

    tx1.send(Command::AddPeer {
        alias: Some("2".into()),
        multiaddr: address2,
        relation: PeerRelation::Known,
        peer_id: peer_id2,
    })
    .expect("send command");

    let (_, gossip_out1) = get_gossip_channels(&mut rx1).await;
    let (mut gossip_in2, _) = get_gossip_channels(&mut rx2).await;

    gossip_out1.send(b"hello".to_vec()).unwrap();
    assert_eq!(gossip_in2.next().await.unwrap(), b"hello");
}