Skip to content

feat: support WebRTC transport for libp2p client and server #2

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 10 commits into
base: master
Choose a base branch
from
Open

feat: support WebRTC transport for libp2p client and server #2

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
88d91d3
add match on ClientOpts.transport_layer for libp2p client
timwu20 Aug 14, 2025
73f83a0
wip WebRTC transport support
timwu20 Aug 22, 2025
3f313c1
add flushes to behaviour
timwu20 Sep 8, 2025
2eac3b5
code cleanup
timwu20 Sep 8, 2025
247bc7f
cargo fmt
timwu20 Sep 9, 2025
2481b2e
bump litep2p and libp2p commits to latest
timwu20 Oct 27, 2025
0e81241
switch to ChainSafe libp2p/litep2p forks
haikoschol Nov 17, 2025
4c3134a
set the litep2p keep alive timeout to 5min
haikoschol Nov 17, 2025
2f87ae8
add webrtc libp2p & litep2p tests to run script
haikoschol Nov 18, 2025
d47573b
update README with new bandwidth report table
haikoschol Nov 18, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1,649 changes: 1,153 additions & 496 deletions Cargo.lock
View file
Open in desktop

Large diffs are not rendered by default.

89 changes: 45 additions & 44 deletions README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -114,47 +114,48 @@ cd litep2p

### Bandwidth

| Operation | Bytes | Litep2p->Litep2p | Libp2p->Libp2p | Libp2p->Litep2p | Litep2p->Libp2p |
|------------|------------|------------------|----------------|-----------------|-----------------|
| Uploaded | 1,0KiB | 3.77 Gbit/s | 4.35 Gbit/s | 4.56 Gbit/s | 3.61 Gbit/s |
| Uploaded | 2,0KiB | 3.11 Gbit/s | 2.67 Gbit/s | 2.75 Gbit/s | 2.48 Gbit/s |
| Uploaded | 4,0KiB | 4.23 Gbit/s | 4.88 Gbit/s | 7.02 Gbit/s | 5.14 Gbit/s |
| Uploaded | 8,0KiB | 4.45 Gbit/s | 6.13 Gbit/s | 6.03 Gbit/s | 5.58 Gbit/s |
| Uploaded | 16KiB | 502.09 Mbit/s | 515.68 Mbit/s | 510.01 Mbit/s | 443.20 Mbit/s |
| Uploaded | 32KiB | 645.81 Mbit/s | 661.01 Mbit/s | 549.09 Mbit/s | 634.26 Mbit/s |
| Uploaded | 64KiB | 573.64 Mbit/s | 559.63 Mbit/s | 570.35 Mbit/s | 382.15 Mbit/s |
| Uploaded | 128KiB | 544.27 Mbit/s | 485.29 Mbit/s | 284.80 Mbit/s | 588.11 Mbit/s |
| Uploaded | 256KiB | 548.08 Mbit/s | 495.29 Mbit/s | 168.58 Mbit/s | 547.41 Mbit/s |
| Uploaded | 512KiB | 559.30 Mbit/s | 495.63 Mbit/s | 516.49 Mbit/s | 558.62 Mbit/s |
| Uploaded | 1,0MiB | 549.48 Mbit/s | 502.00 Mbit/s | 509.12 Mbit/s | 574.06 Mbit/s |
| Uploaded | 2,0MiB | 544.65 Mbit/s | 458.79 Mbit/s | 512.94 Mbit/s | 552.43 Mbit/s |
| Uploaded | 4,0MiB | 585.49 Mbit/s | 489.34 Mbit/s | 508.92 Mbit/s | 556.91 Mbit/s |
| Uploaded | 8,0MiB | 590.55 Mbit/s | 477.83 Mbit/s | 511.24 Mbit/s | 537.80 Mbit/s |
| Uploaded | 16MiB | 588.77 Mbit/s | 486.59 Mbit/s | 508.14 Mbit/s | 534.24 Mbit/s |
| Uploaded | 32MiB | 608.04 Mbit/s | 454.59 Mbit/s | 512.72 Mbit/s | 543.04 Mbit/s |
| Uploaded | 64MiB | 596.67 Mbit/s | 476.27 Mbit/s | 512.60 Mbit/s | 539.67 Mbit/s |
| Uploaded | 128MiB | 597.67 Mbit/s | 475.44 Mbit/s | 500.52 Mbit/s | 566.77 Mbit/s |
| Uploaded | 256MiB | 568.63 Mbit/s | 488.77 Mbit/s | 503.91 Mbit/s | 523.64 Mbit/s |
| Uploaded | 512MiB | 608.78 Mbit/s | 485.44 Mbit/s | 518.24 Mbit/s | 585.06 Mbit/s |
| Uploaded | 1,0GiB | 593.76 Mbit/s | 480.22 Mbit/s | 509.59 Mbit/s | 533.81 Mbit/s |
| Downloaded | 1,0KiB | 37.52 Mbit/s | 32.47 Mbit/s | 27.34 Mbit/s | 32.32 Mbit/s |
| Downloaded | 2,0KiB | 59.92 Mbit/s | 70.58 Mbit/s | 67.25 Mbit/s | 56.54 Mbit/s |
| Downloaded | 4,0KiB | 104.13 Mbit/s | 107.57 Mbit/s | 62.26 Mbit/s | 103.77 Mbit/s |
| Downloaded | 8,0KiB | 144.40 Mbit/s | 164.40 Mbit/s | 144.31 Mbit/s | 175.94 Mbit/s |
| Downloaded | 16KiB | 226.44 Mbit/s | 244.50 Mbit/s | 234.40 Mbit/s | 192.15 Mbit/s |
| Downloaded | 32KiB | 433.87 Mbit/s | 246.87 Mbit/s | 302.03 Mbit/s | 398.61 Mbit/s |
| Downloaded | 64KiB | 398.39 Mbit/s | 391.43 Mbit/s | 319.19 Mbit/s | 348.72 Mbit/s |
| Downloaded | 128KiB | 399.92 Mbit/s | 438.45 Mbit/s | 345.96 Mbit/s | 428.56 Mbit/s |
| Downloaded | 256KiB | 553.59 Mbit/s | 417.66 Mbit/s | 355.77 Mbit/s | 475.05 Mbit/s |
| Downloaded | 512KiB | 564.92 Mbit/s | 430.31 Mbit/s | 534.81 Mbit/s | 397.76 Mbit/s |
| Downloaded | 1,0MiB | 576.16 Mbit/s | 421.55 Mbit/s | 549.70 Mbit/s | 414.19 Mbit/s |
| Downloaded | 2,0MiB | 591.18 Mbit/s | 485.44 Mbit/s | 569.70 Mbit/s | 459.81 Mbit/s |
| Downloaded | 4,0MiB | 585.57 Mbit/s | 428.47 Mbit/s | 490.32 Mbit/s | 502.02 Mbit/s |
| Downloaded | 8,0MiB | 609.17 Mbit/s | 490.68 Mbit/s | 522.76 Mbit/s | 496.34 Mbit/s |
| Downloaded | 16MiB | 601.63 Mbit/s | 480.64 Mbit/s | 543.31 Mbit/s | 500.06 Mbit/s |
| Downloaded | 32MiB | 615.73 Mbit/s | 486.40 Mbit/s | 533.18 Mbit/s | 499.05 Mbit/s |
| Downloaded | 64MiB | 609.44 Mbit/s | 485.17 Mbit/s | 557.61 Mbit/s | 505.44 Mbit/s |
| Downloaded | 128MiB | 603.49 Mbit/s | 483.54 Mbit/s | 541.33 Mbit/s | 495.37 Mbit/s |
| Downloaded | 256MiB | 600.82 Mbit/s | 488.18 Mbit/s | 564.84 Mbit/s | 497.95 Mbit/s |
| Downloaded | 512MiB | 506.49 Mbit/s | 483.55 Mbit/s | 519.57 Mbit/s | 498.65 Mbit/s |
| Downloaded | 1,0GiB | 601.71 Mbit/s | 485.35 Mbit/s | 543.15 Mbit/s | 500.86 Mbit/s |
| Operation | Bytes | Litep2p->Litep2p | Libp2p->Libp2p | Libp2p->Libp2p | Libp2p->Litep2p | Libp2p->Litep2p | Litep2p->Libp2p |
| | | (TCP) | (TCP) | (WebRTC) | (TCP) | (WebRTC) | (TCP) |
|------------|------------|------------------|----------------|----------------|-----------------|-----------------|-----------------|
| Uploaded | 1.0KiB | 3.46 Gbit/s | 3.16 Gbit/s | 1.17 Gbit/s | 4.36 Gbit/s | 225.36 Mbit/s | 3.74 Gbit/s |
| Uploaded | 2.0KiB | 9.39 Gbit/s | 5.23 Gbit/s | 796.18 Mbit/s | 1.85 Gbit/s | 429.06 Mbit/s | 2.54 Gbit/s |
| Uploaded | 4.0KiB | 2.15 Gbit/s | 6.37 Gbit/s | 1.23 Gbit/s | 8.05 Gbit/s | 370.01 Mbit/s | 3.45 Gbit/s |
| Uploaded | 8.0KiB | 7.11 Gbit/s | 5.09 Gbit/s | 1.46 Gbit/s | 5.66 Gbit/s | 515.82 Mbit/s | 5.79 Gbit/s |
| Uploaded | 16KiB | 838.46 Mbit/s | 373.74 Mbit/s | 1.68 Gbit/s | 391.24 Mbit/s | 532.77 Mbit/s | 800.64 Mbit/s |
| Uploaded | 32KiB | 555.92 Mbit/s | 348.37 Mbit/s | 1.69 Gbit/s | 299.48 Mbit/s | 1.20 Gbit/s | 453.10 Mbit/s |
| Uploaded | 64KiB | 436.65 Mbit/s | 353.20 Mbit/s | 1.74 Gbit/s | 538.50 Mbit/s | 1.73 Gbit/s | 432.45 Mbit/s |
| Uploaded | 128KiB | 357.14 Mbit/s | 388.14 Mbit/s | 3.45 Gbit/s | 341.68 Mbit/s | 681.16 Mbit/s | 414.52 Mbit/s |
| Uploaded | 256KiB | 482.24 Mbit/s | 323.69 Mbit/s | 51.57 Mbit/s | 321.55 Mbit/s | 60.10 Mbit/s | 349.15 Mbit/s |
| Uploaded | 512KiB | 420.43 Mbit/s | 349.45 Mbit/s | 47.77 Mbit/s | 393.10 Mbit/s | 46.43 Mbit/s | 362.95 Mbit/s |
| Uploaded | 1.0MiB | 452.06 Mbit/s | 382.80 Mbit/s | 34.42 Mbit/s | 405.66 Mbit/s | 35.68 Mbit/s | 396.46 Mbit/s |
| Uploaded | 2.0MiB | 476.54 Mbit/s | 468.72 Mbit/s | 33.50 Mbit/s | 454.18 Mbit/s | 33.54 Mbit/s | 484.36 Mbit/s |
| Uploaded | 4.0MiB | 602.35 Mbit/s | 542.05 Mbit/s | 32.51 Mbit/s | 529.74 Mbit/s | 31.15 Mbit/s | 595.09 Mbit/s |
| Uploaded | 8.0MiB | 731.84 Mbit/s | 597.95 Mbit/s | 32.05 Mbit/s | 587.44 Mbit/s | 31.37 Mbit/s | 723.80 Mbit/s |
| Uploaded | 16MiB | 745.03 Mbit/s | 616.75 Mbit/s | 31.83 Mbit/s | 617.36 Mbit/s | 30.80 Mbit/s | 756.98 Mbit/s |
| Uploaded | 32MiB | 753.37 Mbit/s | 631.18 Mbit/s | 31.65 Mbit/s | 644.45 Mbit/s | n/a | 778.50 Mbit/s |
| Uploaded | 64MiB | 806.63 Mbit/s | 635.26 Mbit/s | 31.68 Mbit/s | 632.70 Mbit/s | n/a | 784.85 Mbit/s |
| Uploaded | 128MiB | 879.59 Mbit/s | 635.71 Mbit/s | 31.03 Mbit/s | 637.97 Mbit/s | n/a | 764.72 Mbit/s |
| Uploaded | 256MiB | 867.99 Mbit/s | 643.30 Mbit/s | 31.42 Mbit/s | 698.84 Mbit/s | n/a | 803.06 Mbit/s |
| Uploaded | 512MiB | 871.38 Mbit/s | 652.90 Mbit/s | 31.16 Mbit/s | 620.08 Mbit/s | n/a | 808.02 Mbit/s |
| Uploaded | 1.0GiB | 882.42 Mbit/s | 643.92 Mbit/s | 31.39 Mbit/s | 630.04 Mbit/s | n/a | 813.40 Mbit/s |
| Downloaded | 1.0KiB | 32.95 Mbit/s | 22.49 Mbit/s | 3.77 Mbit/s | 28.53 Mbit/s | 2.36 Mbit/s | 23.87 Mbit/s |
| Downloaded | 2.0KiB | 63.92 Mbit/s | 50.13 Mbit/s | 4.88 Mbit/s | 52.36 Mbit/s | 3.45 Mbit/s | 45.08 Mbit/s |
| Downloaded | 4.0KiB | 81.83 Mbit/s | 77.48 Mbit/s | 6.82 Mbit/s | 130.75 Mbit/s | 3.54 Mbit/s | 63.33 Mbit/s |
| Downloaded | 8.0KiB | 141.94 Mbit/s | 102.54 Mbit/s | 7.62 Mbit/s | 114.75 Mbit/s | 3.58 Mbit/s | 100.94 Mbit/s |
| Downloaded | 16KiB | 195.20 Mbit/s | 169.77 Mbit/s | 9.33 Mbit/s | 190.36 Mbit/s | 5.22 Mbit/s | 141.49 Mbit/s |
| Downloaded | 32KiB | 197.94 Mbit/s | 288.42 Mbit/s | 10.47 Mbit/s | 252.40 Mbit/s | 6.81 Mbit/s | 196.53 Mbit/s |
| Downloaded | 64KiB | 225.54 Mbit/s | 286.09 Mbit/s | 11.81 Mbit/s | 296.95 Mbit/s | 10.00 Mbit/s | 275.46 Mbit/s |
| Downloaded | 128KiB | 297.69 Mbit/s | 325.77 Mbit/s | 13.88 Mbit/s | 327.18 Mbit/s | 11.41 Mbit/s | 278.86 Mbit/s |
| Downloaded | 256KiB | 413.71 Mbit/s | 357.56 Mbit/s | 19.97 Mbit/s | 351.91 Mbit/s | 18.07 Mbit/s | 351.01 Mbit/s |
| Downloaded | 512KiB | 408.00 Mbit/s | 405.74 Mbit/s | 22.14 Mbit/s | 399.83 Mbit/s | 22.16 Mbit/s | 400.23 Mbit/s |
| Downloaded | 1.0MiB | 505.80 Mbit/s | 513.97 Mbit/s | 28.11 Mbit/s | 581.64 Mbit/s | n/a | 504.74 Mbit/s |
| Downloaded | 2.0MiB | 777.57 Mbit/s | 638.82 Mbit/s | 29.31 Mbit/s | 775.99 Mbit/s | n/a | 666.08 Mbit/s |
| Downloaded | 4.0MiB | 844.21 Mbit/s | 651.80 Mbit/s | 29.96 Mbit/s | 774.64 Mbit/s | n/a | 715.37 Mbit/s |
| Downloaded | 8.0MiB | 792.89 Mbit/s | 641.97 Mbit/s | 31.05 Mbit/s | 784.99 Mbit/s | n/a | 683.01 Mbit/s |
| Downloaded | 16MiB | 803.64 Mbit/s | 626.76 Mbit/s | 31.46 Mbit/s | 745.87 Mbit/s | n/a | 688.40 Mbit/s |
| Downloaded | 32MiB | 779.37 Mbit/s | 633.95 Mbit/s | 31.48 Mbit/s | 760.55 Mbit/s | n/a | 691.93 Mbit/s |
| Downloaded | 64MiB | 804.71 Mbit/s | 635.22 Mbit/s | 31.53 Mbit/s | 752.78 Mbit/s | n/a | 690.73 Mbit/s |
| Downloaded | 128MiB | 862.24 Mbit/s | 637.05 Mbit/s | 31.18 Mbit/s | 782.09 Mbit/s | n/a | 621.61 Mbit/s |
| Downloaded | 256MiB | 858.61 Mbit/s | 636.08 Mbit/s | 31.53 Mbit/s | 788.31 Mbit/s | n/a | 694.58 Mbit/s |
| Downloaded | 512MiB | 861.56 Mbit/s | 637.50 Mbit/s | 31.19 Mbit/s | 738.45 Mbit/s | n/a | 692.77 Mbit/s |
| Downloaded | 1.0GiB | 872.73 Mbit/s | 619.31 Mbit/s | 31.04 Mbit/s | 744.37 Mbit/s | n/a | 687.94 Mbit/s |
19 changes: 9 additions & 10 deletions libp2p/Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,24 +4,23 @@ version = "0.1.0"
edition = "2024"

[dependencies]
async-trait = "0.1"
clap = { version = "4.5.31", features = ["derive", "cargo"] }
tokio = { version = "1.28", features = ["macros", "time", "rt-multi-thread"] }
tracing-subscriber = { version = "0.3", features = ["env-filter"] }
tracing = "0.1.34"
futures = "0.3.28"

thiserror = "1.0"
futures-bounded = "0.2.4"
thiserror = "2.0.16"

libp2p = { git = "https://github.com/ChainSafe/rust-libp2p", rev = "6accaf64eec35cffc2807af6b3b1eba10303058d", features = ["dns", "identify", "kad", "macros", "mdns", "noise", "ping", "tcp", "tokio", "yamux", "websocket", "request-response"] }
libp2p-core = { git = "https://github.com/ChainSafe/rust-libp2p", rev = "6accaf64eec35cffc2807af6b3b1eba10303058d" }
libp2p-swarm = { git = "https://github.com/ChainSafe/rust-libp2p", rev = "6accaf64eec35cffc2807af6b3b1eba10303058d" }
libp2p-identity = { version = "0.2.12", features = ["ed25519", "peerid", "rand"] }
libp2p-noise = { git = "https://github.com/ChainSafe/rust-libp2p", rev = "6accaf64eec35cffc2807af6b3b1eba10303058d" }
libp2p-webrtc = { git = "https://github.com/ChainSafe/rust-libp2p", rev = "6accaf64eec35cffc2807af6b3b1eba10303058d", features = ["tokio"] }
libp2p-yamux = { git = "https://github.com/ChainSafe/rust-libp2p", rev = "6accaf64eec35cffc2807af6b3b1eba10303058d" }

libp2p = { version = "0.54.1", features = ["dns", "identify", "kad", "macros", "mdns", "noise", "ping", "tcp", "tokio", "yamux", "websocket", "request-response"] }
libp2p-core = { version = "0.42" }
libp2p-swarm = { version = "0.45.1" }
libp2p-identity = { version = "0.2.9", features = ["ed25519", "peerid", "rand"] }
libp2p-tls = "0.5.0"
libp2p-noise = "0.45.0"
libp2p-yamux = "0.46.0"
void = "1"

utils = { path = "../utils" }
rand = "0.8"
11 changes: 9 additions & 2 deletions libp2p/src/client/handler.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
use core::panic;
use std::{
collections::VecDeque,
task::{Context, Poll},
Expand Down Expand Up @@ -95,7 +96,10 @@ impl ConnectionHandler for Handler {
#[allow(unreachable_patterns)]
ConnectionEvent::FullyNegotiatedInbound(FullyNegotiatedInbound {
protocol, ..
}) => void::unreachable(protocol),
}) => panic!(
"Unexpected FullyNegotiatedInbound event in server handler: {:?}",
protocol
),
ConnectionEvent::FullyNegotiatedOutbound(FullyNegotiatedOutbound {
protocol,
info: (),
Expand Down Expand Up @@ -135,7 +139,10 @@ impl ConnectionHandler for Handler {
// TODO: remove when Rust 1.82 is MSRV
#[allow(unreachable_patterns)]
ConnectionEvent::ListenUpgradeError(ListenUpgradeError { info: (), error }) => {
void::unreachable(error)
panic!(
"ListenUpgradeError should not occur in this context: {:?}",
error
);
}
_ => {}
}
Expand Down
143 changes: 103 additions & 40 deletions libp2p/src/main.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,10 @@
use clap::Parser as ClapParser;
use futures::StreamExt;
use libp2p::core::{Transport, muxing::StreamMuxerBox};
use libp2p::multiaddr::{Multiaddr, Protocol};
use libp2p_swarm::SwarmEvent;
use rand::thread_rng;
use std::net::Ipv4Addr;

use utils::Command;

Expand Down Expand Up @@ -29,20 +33,53 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
let local_key = libp2p::identity::ed25519::Keypair::from(secret_key);
let local_key: libp2p::identity::Keypair = local_key.into();

let tcp_config = libp2p::tcp::Config::new().nodelay(true);
let mut swarm = libp2p::SwarmBuilder::with_existing_identity(local_key)
.with_tokio()
.with_tcp(
tcp_config,
libp2p_noise::Config::new,
libp2p_yamux::Config::default,
)?
.with_dns()?
.with_behaviour(|_key| crate::server::behaviour::Behaviour::new())?
.with_swarm_config(|cfg| {
cfg.with_idle_connection_timeout(std::time::Duration::from_secs(60))
})
.build();
let mut swarm = match server_opts.transport_layer {
utils::TransportLayer::Tcp => {
let tcp_config = libp2p::tcp::Config::new().nodelay(true);
libp2p::SwarmBuilder::with_existing_identity(local_key)
.with_tokio()
.with_tcp(
tcp_config,
libp2p_noise::Config::new,
libp2p_yamux::Config::default,
)?
.with_dns()?
.with_behaviour(|_key| crate::server::behaviour::Behaviour::new())?
.with_swarm_config(|cfg| {
cfg.with_idle_connection_timeout(std::time::Duration::from_secs(60))
})
.build()
}
utils::TransportLayer::WebSocket => {
unimplemented!("WebSocket transport layer not implemented yet");
}
utils::TransportLayer::WebRTC => {
let address_webrtc = Multiaddr::from(Ipv4Addr::UNSPECIFIED)
.with(Protocol::Udp(0))
.with(Protocol::WebRTCDirect);

tracing::info!(
"Using WebRTC transport layer with address: {}",
address_webrtc
);

libp2p::SwarmBuilder::with_existing_identity(local_key)
.with_tokio()
.with_other_transport(|key| {
Ok(libp2p_webrtc::tokio::Transport::new(
key.clone(),
libp2p_webrtc::tokio::Certificate::generate(&mut thread_rng())?,
)
.map(|(peer_id, conn), _| (peer_id, StreamMuxerBox::new(conn))))
})?
.with_dns()?
.with_behaviour(|_key| crate::server::behaviour::Behaviour::new())?
.with_swarm_config(|cfg| {
cfg.with_idle_connection_timeout(std::time::Duration::from_secs(60))
})
.build()
}
};

swarm.listen_on(server_opts.listen_address.parse()?)?;

Expand All @@ -54,40 +91,66 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
Command::Client(client_opts) => {
let local_key = libp2p::identity::Keypair::generate_ed25519();

let tcp_config = libp2p::tcp::Config::new().nodelay(true);
let mut swarm = libp2p::SwarmBuilder::with_existing_identity(local_key)
.with_tokio()
.with_tcp(
tcp_config,
libp2p_noise::Config::new,
libp2p_yamux::Config::default,
)?
.with_dns()?
.with_behaviour(|_key| crate::client::behaviour::Behaviour::new())?
.with_swarm_config(|cfg| {
cfg.with_idle_connection_timeout(std::time::Duration::from_secs(60))
})
.build();
let mut swarm = match client_opts.transport_layer {
utils::TransportLayer::Tcp => {
let tcp_config = libp2p::tcp::Config::new().nodelay(true);
libp2p::SwarmBuilder::with_existing_identity(local_key)
.with_tokio()
.with_tcp(
tcp_config,
libp2p_noise::Config::new,
libp2p_yamux::Config::default,
)?
.with_dns()?
.with_behaviour(|_key| crate::client::behaviour::Behaviour::new())?
.with_swarm_config(|cfg| {
cfg.with_idle_connection_timeout(std::time::Duration::from_secs(60))
})
.build()
}
utils::TransportLayer::WebSocket => {
unimplemented!("WebSocket transport layer not implemented yet");
}
utils::TransportLayer::WebRTC => {
let mut swarm = libp2p::SwarmBuilder::with_existing_identity(local_key)
.with_tokio()
.with_other_transport(|key| {
Ok(libp2p_webrtc::tokio::Transport::new(
key.clone(),
libp2p_webrtc::tokio::Certificate::generate(&mut thread_rng())?,
)
.map(|(peer_id, conn), _| (peer_id, StreamMuxerBox::new(conn))))
})?
.with_dns()?
.with_behaviour(|_key| crate::client::behaviour::Behaviour::new())?
.with_swarm_config(|cfg| {
cfg.with_idle_connection_timeout(std::time::Duration::from_secs(60))
})
.build();

let addr: libp2p::Multiaddr = client_opts.server_address.parse()?;
swarm.dial(addr)?;
let listen_addr = Multiaddr::from(Ipv4Addr::UNSPECIFIED)
.with(Protocol::Udp(0))
.with(Protocol::WebRTCDirect);
swarm.listen_on(listen_addr)?;

let server_peer_id = match swarm.next().await.unwrap() {
SwarmEvent::ConnectionEstablished { peer_id, .. } => peer_id,
e => panic!("{e:?}"),
swarm
}
};

swarm.behaviour_mut().perf(
server_peer_id,
client_opts.upload_bytes as u64,
client_opts.download_bytes as u64,
)?;
let addr: libp2p::Multiaddr = client_opts.server_address.parse()?;
swarm.dial(addr)?;

loop {
let event = swarm.next().await;
tracing::info!("Even: {:?}", event);

tracing::info!("Event: {:?}", event);
match event {
Some(SwarmEvent::ConnectionEstablished { peer_id, .. }) => {
swarm.behaviour_mut().perf(
peer_id,
client_opts.upload_bytes as u64,
client_opts.download_bytes as u64,
)?;
}
Some(SwarmEvent::Behaviour(..)) => {
return Ok(());
}
Expand Down
Loading