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
timwu20 wants to merge 15 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
15 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
ae6bc2f
patch webrtc-rs to always send keepalives
haikoschol Dec 12, 2025
70fd122
bump litep2p
haikoschol Dec 16, 2025
43e5ff2
cover all values except 1GiB in run script
haikoschol Dec 16, 2025
d1f650e
fix table rendering
haikoschol Dec 16, 2025
1a8a991
update bandwidth table in README
haikoschol Dec 16, 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,624 changes: 1,133 additions & 491 deletions Cargo.lock
View file
Open in desktop

Large diffs are not rendered by default.

3 changes: 3 additions & 0 deletions Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,3 +6,6 @@ members = [
]

resolver = "2"

[patch.crates-io]
webrtc = { git = "https://github.com/haikoschol/webrtc.git", branch = "always-send-ice-keepalives" }
88 changes: 44 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,47 @@ 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 (TCP) | Libp2p->Libp2p (TCP) | Libp2p->Libp2p (WebRTC) | Libp2p->Litep2p (TCP) | Libp2p->Litep2p (WebRTC) | Litep2p->Libp2p (TCP) |
|------------|--------|------------------------|----------------------|-------------------------|-----------------------|--------------------------|-----------------------|
| Uploaded | 1.0KiB | 3.98 Gbit/s | 2.35 Gbit/s | 563.06 Mbit/s | 3.39 Gbit/s | 452.90 Mbit/s | 3.81 Gbit/s |
| Uploaded | 2.0KiB | 5.91 Gbit/s | 3.70 Gbit/s | 1.24 Gbit/s | 4.88 Gbit/s | 539.56 Mbit/s | 6.54 Gbit/s |
| Uploaded | 4.0KiB | 4.73 Gbit/s | 2.81 Gbit/s | 1.95 Gbit/s | 6.05 Gbit/s | 641.58 Mbit/s | 4.73 Gbit/s |
| Uploaded | 8.0KiB | 10.10 Gbit/s | 3.65 Gbit/s | 2.27 Gbit/s | 3.71 Gbit/s | 354.69 Mbit/s | 9.70 Gbit/s |
| Uploaded | 16KiB | 1001.33 Mbit/s | 409.11 Mbit/s | 1.62 Gbit/s | 425.71 Mbit/s | 784.52 Mbit/s | 647.39 Mbit/s |
| Uploaded | 32KiB | 734.21 Mbit/s | 323.24 Mbit/s | 1.92 Gbit/s | 329.58 Mbit/s | 696.38 Mbit/s | 521.65 Mbit/s |
| Uploaded | 64KiB | 426.85 Mbit/s | 417.23 Mbit/s | 1.89 Gbit/s | 404.08 Mbit/s | 804.18 Mbit/s | 465.50 Mbit/s |
| Uploaded | 128KiB | 385.00 Mbit/s | 388.95 Mbit/s | 2.06 Gbit/s | 360.21 Mbit/s | 673.44 Mbit/s | 408.18 Mbit/s |
| Uploaded | 256KiB | 379.18 Mbit/s | 392.68 Mbit/s | 83.72 Mbit/s | 505.00 Mbit/s | 49.55 Mbit/s | 395.67 Mbit/s |
| Uploaded | 512KiB | 476.20 Mbit/s | 411.87 Mbit/s | 43.52 Mbit/s | 531.37 Mbit/s | 41.83 Mbit/s | 419.62 Mbit/s |
| Uploaded | 1.0MiB | 465.22 Mbit/s | 426.62 Mbit/s | 40.60 Mbit/s | 410.64 Mbit/s | 36.77 Mbit/s | 470.99 Mbit/s |
| Uploaded | 2.0MiB | 518.01 Mbit/s | 501.62 Mbit/s | 35.07 Mbit/s | 472.82 Mbit/s | 33.27 Mbit/s | 503.70 Mbit/s |
| Uploaded | 4.0MiB | 680.79 Mbit/s | 587.54 Mbit/s | 33.75 Mbit/s | 587.76 Mbit/s | 33.46 Mbit/s | 673.93 Mbit/s |
| Uploaded | 8.0MiB | 802.99 Mbit/s | 650.43 Mbit/s | 32.92 Mbit/s | 650.16 Mbit/s | 33.60 Mbit/s | 768.98 Mbit/s |
| Uploaded | 16MiB | 854.45 Mbit/s | 703.67 Mbit/s | 32.99 Mbit/s | 685.35 Mbit/s | 33.76 Mbit/s | 787.97 Mbit/s |
| Uploaded | 32MiB | 921.60 Mbit/s | 708.99 Mbit/s | 32.72 Mbit/s | 728.34 Mbit/s | 33.68 Mbit/s | 818.49 Mbit/s |
| Uploaded | 64MiB | 957.68 Mbit/s | 710.41 Mbit/s | 32.42 Mbit/s | 730.43 Mbit/s | 33.61 Mbit/s | 836.55 Mbit/s |
| Uploaded | 128MiB | 961.15 Mbit/s | 717.94 Mbit/s | 32.29 Mbit/s | 749.60 Mbit/s | 33.55 Mbit/s | 852.71 Mbit/s |
| Uploaded | 256MiB | 882.12 Mbit/s | 719.77 Mbit/s | 32.23 Mbit/s | 761.55 Mbit/s | 33.48 Mbit/s | 858.93 Mbit/s |
| Uploaded | 512MiB | 920.68 Mbit/s | 716.89 Mbit/s | 32.17 Mbit/s | 763.27 Mbit/s | 33.46 Mbit/s | 860.74 Mbit/s |
| Uploaded | 1.0GiB | 985.91 Mbit/s | 712.41 Mbit/s | 32.37 Mbit/s | 766.33 Mbit/s | n/a | 868.62 Mbit/s |
| Downloaded | 1.0KiB | 30.64 Mbit/s | 36.34 Mbit/s | 4.15 Mbit/s | 29.32 Mbit/s | 3.03 Mbit/s | 27.98 Mbit/s |
| Downloaded | 2.0KiB | 49.42 Mbit/s | 44.87 Mbit/s | 7.21 Mbit/s | 56.93 Mbit/s | 3.08 Mbit/s | 45.70 Mbit/s |
| Downloaded | 4.0KiB | 73.04 Mbit/s | 81.47 Mbit/s | 9.29 Mbit/s | 86.36 Mbit/s | 3.93 Mbit/s | 88.12 Mbit/s |
| Downloaded | 8.0KiB | 112.38 Mbit/s | 119.77 Mbit/s | 9.18 Mbit/s | 120.23 Mbit/s | 3.81 Mbit/s | 118.11 Mbit/s |
| Downloaded | 16KiB | 281.27 Mbit/s | 175.84 Mbit/s | 9.30 Mbit/s | 204.14 Mbit/s | 5.53 Mbit/s | 161.08 Mbit/s |
| Downloaded | 32KiB | 267.69 Mbit/s | 341.53 Mbit/s | 10.42 Mbit/s | 342.02 Mbit/s | 7.12 Mbit/s | 201.18 Mbit/s |
| Downloaded | 64KiB | 271.50 Mbit/s | 331.55 Mbit/s | 12.16 Mbit/s | 425.94 Mbit/s | 8.29 Mbit/s | 278.07 Mbit/s |
| Downloaded | 128KiB | 310.64 Mbit/s | 355.65 Mbit/s | 14.05 Mbit/s | 363.56 Mbit/s | 11.03 Mbit/s | 336.00 Mbit/s |
| Downloaded | 256KiB | 375.84 Mbit/s | 394.35 Mbit/s | 18.58 Mbit/s | 443.98 Mbit/s | 18.84 Mbit/s | 378.60 Mbit/s |
| Downloaded | 512KiB | 512.30 Mbit/s | 463.59 Mbit/s | 24.55 Mbit/s | 495.57 Mbit/s | 23.94 Mbit/s | 436.09 Mbit/s |
| Downloaded | 1.0MiB | 540.09 Mbit/s | 598.67 Mbit/s | 26.51 Mbit/s | 569.77 Mbit/s | 29.25 Mbit/s | 513.71 Mbit/s |
| Downloaded | 2.0MiB | 879.67 Mbit/s | 645.99 Mbit/s | 29.98 Mbit/s | 836.44 Mbit/s | 34.31 Mbit/s | 642.60 Mbit/s |
| Downloaded | 4.0MiB | 982.02 Mbit/s | 713.97 Mbit/s | 31.21 Mbit/s | 845.34 Mbit/s | 35.21 Mbit/s | 769.42 Mbit/s |
| Downloaded | 8.0MiB | 978.81 Mbit/s | 748.43 Mbit/s | 32.15 Mbit/s | 879.50 Mbit/s | 36.03 Mbit/s | 744.14 Mbit/s |
| Downloaded | 16MiB | 867.09 Mbit/s | 711.13 Mbit/s | 32.45 Mbit/s | 831.28 Mbit/s | 36.29 Mbit/s | 740.03 Mbit/s |
| Downloaded | 32MiB | 964.77 Mbit/s | 719.94 Mbit/s | 32.44 Mbit/s | 849.40 Mbit/s | 36.24 Mbit/s | 726.23 Mbit/s |
| Downloaded | 64MiB | 970.98 Mbit/s | 716.00 Mbit/s | 32.49 Mbit/s | 841.98 Mbit/s | 36.24 Mbit/s | 748.07 Mbit/s |
| Downloaded | 128MiB | 933.48 Mbit/s | 705.87 Mbit/s | 32.45 Mbit/s | 844.31 Mbit/s | 36.62 Mbit/s | 754.59 Mbit/s |
| Downloaded | 256MiB | 920.71 Mbit/s | 707.10 Mbit/s | 32.38 Mbit/s | 850.48 Mbit/s | 36.60 Mbit/s | 750.82 Mbit/s |
| Downloaded | 512MiB | 951.07 Mbit/s | 712.52 Mbit/s | 32.45 Mbit/s | 852.45 Mbit/s | 36.40 Mbit/s | 744.70 Mbit/s |
| Downloaded | 1.0GiB | 964.81 Mbit/s | 700.56 Mbit/s | 32.64 Mbit/s | 849.49 Mbit/s | n/a | 757.75 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
Loading