blueprint-networking 0.2.0-alpha.2

Networking utilities for Tangle Blueprints
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

use std::{num::NonZero, time::Duration};

use libp2p::{
    PeerId, StreamProtocol,
    kad::{self, store::MemoryStore},
};

pub mod behaviour;
pub mod config;
pub mod peers;
pub mod utils;

pub use peers::{PeerEvent, PeerInfo, PeerManager};

#[must_use]
#[allow(clippy::missing_panics_doc)]
pub fn new_kademlia(peer_id: PeerId, protocol: StreamProtocol) -> kad::Behaviour<MemoryStore> {
    let store = kad::store::MemoryStore::new(peer_id);
    let mut config = kad::Config::new(protocol);

    // Optimize Kademlia configuration
    config
        .set_query_timeout(Duration::from_secs(60))
        .set_replication_factor(NonZero::new(3).unwrap())
        .set_publication_interval(Some(Duration::from_secs(120)))
        .set_provider_record_ttl(Some(Duration::from_secs(24 * 60 * 60)))
        .set_record_ttl(Some(Duration::from_secs(24 * 60 * 60)))
        .set_parallelism(NonZero::new(5).unwrap());

    let mut kademlia = kad::Behaviour::with_config(peer_id, store, config);
    kademlia.set_mode(Some(kad::Mode::Server));
    kademlia
}