Git-Mirrors/xmr-btc-swap
1
0
Fork 0
mirror of https://github.com/comit-network/xmr-btc-swap.git synced 2025-02-21 23:29:50 -05:00
Code Issues Packages Projects Releases Wiki Activity

mplex

Browse Source
This commit is contained in:
Daniel Karzel 2021-06-11 16:00:17 +10:00
parent 9dc6228a2c
commit f81a4cf629
No known key found for this signature in database
GPG Key ID: 30C3FC2E438ADB6E
3 changed files with 17 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libp2p-tor/Cargo.toml
View File

@ -19,7 +19,7 @@ torut = { version = "0.1", default-features = false, features = [ "v3", "control
tracing = "0.1" tracing = "0.1"
[dev-dependencies] [dev-dependencies]
libp2p = { version = "0.37", default-features = false, features = [ "yamux", "noise", "ping" ] } libp2p = { version = "0.37", default-features = false, features = [ "yamux", "noise", "ping", "mplex" ] }
rand = "0.8" rand = "0.8"
tempfile = "3" tempfile = "3"
testcontainers = "0.12" testcontainers = "0.12"

13
libp2p-tor/examples/dialer.rs
View File

@ -1,10 +1,11 @@
use libp2p::core::muxing::StreamMuxerBox; use libp2p::core::muxing::StreamMuxerBox;
use libp2p::core::upgrade::Version; use libp2p::core::upgrade::{Version, SelectUpgrade};
use libp2p::ping::{Ping, PingEvent, PingSuccess}; use libp2p::ping::{Ping, PingEvent, PingSuccess};
use libp2p::swarm::{SwarmBuilder, SwarmEvent}; use libp2p::swarm::{SwarmBuilder, SwarmEvent};
use libp2p::{identity, noise, yamux, Multiaddr, Swarm, Transport}; use libp2p::{identity, noise, yamux, Multiaddr, Swarm, Transport};
use libp2p_tor::dial_only; use libp2p_tor::dial_only;
use std::time::Duration; use std::time::Duration;
use libp2p::mplex::MplexConfig;
#[tokio::main] #[tokio::main]
async fn main() { async fn main() {
@ -55,6 +56,9 @@ async fn main() {
/// Builds a new swarm that is capable of dialling onion address. /// Builds a new swarm that is capable of dialling onion address.
fn new_swarm() -> Swarm<Ping> { fn new_swarm() -> Swarm<Ping> {
let identity = identity::Keypair::generate_ed25519(); let identity = identity::Keypair::generate_ed25519();
let peer_id = identity.public().into_peer_id();
println!("peer id upon swarm setup: {}", peer_id);
SwarmBuilder::new( SwarmBuilder::new(
dial_only::TorConfig::new(9050) dial_only::TorConfig::new(9050)
@ -67,12 +71,15 @@ fn new_swarm() -> Swarm<Ping> {
) )
.into_authenticated(), .into_authenticated(),
) )
.multiplex(yamux::YamuxConfig::default()) .multiplex(SelectUpgrade::new(
yamux::YamuxConfig::default(),
MplexConfig::new(),
))
.timeout(Duration::from_secs(20)) .timeout(Duration::from_secs(20))
.map(|(peer, muxer), _| (peer, StreamMuxerBox::new(muxer))) .map(|(peer, muxer), _| (peer, StreamMuxerBox::new(muxer)))
.boxed(), .boxed(),
Ping::default(), Ping::default(),
identity.public().into_peer_id(), peer_id,
) )
.executor(Box::new(|f| { .executor(Box::new(|f| {
tokio::spawn(f); tokio::spawn(f);

8
libp2p-tor/examples/listener.rs
View File

@ -1,5 +1,5 @@
use libp2p::core::muxing::StreamMuxerBox; use libp2p::core::muxing::StreamMuxerBox;
use libp2p::core::upgrade::Version; use libp2p::core::upgrade::{Version, SelectUpgrade};
use libp2p::ping::{Ping, PingEvent, PingSuccess}; use libp2p::ping::{Ping, PingEvent, PingSuccess};
use libp2p::swarm::{SwarmBuilder, SwarmEvent}; use libp2p::swarm::{SwarmBuilder, SwarmEvent};
use libp2p::{identity, noise, yamux, Swarm, Transport, Multiaddr}; use libp2p::{identity, noise, yamux, Swarm, Transport, Multiaddr};
@ -11,6 +11,7 @@ use std::time::Duration;
use torut::control::AuthenticatedConn; use torut::control::AuthenticatedConn;
use torut::onion::TorSecretKeyV3; use torut::onion::TorSecretKeyV3;
use std::str::FromStr; use std::str::FromStr;
use libp2p::mplex::MplexConfig;
#[tokio::main] #[tokio::main]
async fn main() { async fn main() {
@ -83,7 +84,10 @@ async fn new_swarm(key: TorSecretKeyV3) -> Swarm<Ping> {
) )
.into_authenticated(), .into_authenticated(),
) )
.multiplex(yamux::YamuxConfig::default()) .multiplex(SelectUpgrade::new(
yamux::YamuxConfig::default(),
MplexConfig::new(),
))
.timeout(Duration::from_secs(20)) .timeout(Duration::from_secs(20))
.map(|(peer, muxer), _| (peer, StreamMuxerBox::new(muxer))) .map(|(peer, muxer), _| (peer, StreamMuxerBox::new(muxer)))
.boxed(), .boxed(),