tatami 0.1.5

A library for creating satellites and interacting with Tatami protocols.
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

use libp2p::{identity::Keypair, swarm::SwarmBuilder, PeerId};

pub mod behaviour;
pub mod event;
mod transport;

use self::behaviour::SwarmBehaviour;
use crate::errors::TatamiError;

pub struct Swarm(pub libp2p::Swarm<SwarmBehaviour>);

impl Swarm {
	pub async fn create(keypair: Keypair, bootstrap: bool) -> Result<Self, TatamiError> {
		// Get the PeerId from the public key
		let local_peer_id = PeerId::from(keypair.public());

		// Transport and behaviour configs are in different functions
		let transport = Self::transport(&keypair)?;
		let behaviour = SwarmBehaviour::new(keypair, bootstrap).await?;

		// Libp2p Swarm
		let swarm = SwarmBuilder::new(transport, behaviour, local_peer_id)
			.executor(Box::new(|fut| {
				tokio::spawn(fut);
			}))
			.build();

		let swarm = Self(swarm);

		Ok(swarm)
	}
}