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
pub use overlay_id::{IdFull, IdShort};
mod overlay_id;
#[cfg(feature = "overlay")]
mod broadcast_receiver;
#[cfg(feature = "overlay")]
mod node;
#[cfg(feature = "overlay")]
mod overlay_shard;
#[cfg(feature = "overlay")]
mod node_impl {
use std::sync::Arc;
use anyhow::Result;
use frunk_core::hlist::{HCons, HList, IntoTuple2, Selector};
use frunk_core::indices::{Here, There};
pub use super::node::Node;
pub use super::overlay_shard::{
BroadcastTarget, IncomingBroadcastInfo, OutgoingBroadcastInfo, ReceivedPeersMap, Shard,
ShardMetrics, ShardOptions,
};
use crate::adnl;
use crate::rldp;
use crate::utils::{DeferredInitialization, NetworkBuilder};
pub(crate) type Deferred = Result<Arc<Node>>;
impl DeferredInitialization for Deferred {
type Initialized = Arc<Node>;
fn initialize(self) -> Result<Self::Initialized> {
self
}
}
impl<L, I> NetworkBuilder<L, I>
where
L: HList + Selector<rldp::Deferred, Here> + Selector<Arc<adnl::Node>, I>,
HCons<Deferred, L>: IntoTuple2,
{
#[allow(clippy::type_complexity)]
pub fn with_overlay(
mut self,
zero_state_file_hash: [u8; 32],
key_tag: usize,
) -> NetworkBuilder<HCons<Deferred, L>, There<I>> {
let adnl: &Arc<adnl::Node> = self.0.get();
let overlay = Node::new(adnl.clone(), zero_state_file_hash, key_tag);
if let Ok(overlay) = &overlay {
let rldp: &mut rldp::Deferred = self.0.get_mut();
rldp.1.push(overlay.query_subscriber());
}
NetworkBuilder(self.0.prepend(overlay), Default::default())
}
}
pub const MAX_OVERLAY_PEERS: usize = 65536;
}
#[cfg(feature = "overlay")]
pub use node_impl::*;