Skip to content

Commit d7840f2

Browse files
authored
fix(taiko-client-rs): add DNS support to libp2p transport configuration (#21355)
1 parent 748467c commit d7840f2

File tree

2 files changed

+7
-5
lines changed

2 files changed

+7
-5
lines changed

packages/taiko-client-rs/crates/whitelist-preconfirmation-driver/Cargo.toml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,10 +27,10 @@ hashlink = "0.10"
2727
http = "1"
2828
http-body = "1"
2929
http-body-util = { workspace = true }
30-
lru = "0.12"
3130
jsonwebtoken = "9"
3231
kona-gossip = { git = "https://github.com/op-rs/kona", package = "kona-gossip", tag = "kona-client/v1.2.4", default-features = false }
33-
libp2p = { version = "0.56.0", features = ["tcp", "gossipsub", "ping", "identify", "noise", "yamux", "macros", "tokio"] }
32+
libp2p = { version = "0.56.0", features = ["tcp", "dns", "gossipsub", "ping", "identify", "noise", "yamux", "macros", "tokio"] }
33+
lru = "0.12"
3434
metrics = { workspace = true }
3535
preconfirmation-net = { path = "../../../preconfirmation-p2p/crates/net" }
3636
protocol = { path = "../protocol" }

packages/taiko-client-rs/crates/whitelist-preconfirmation-driver/src/network.rs

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@ use std::{collections::HashSet, sync::Arc, time::Instant};
44
use alloy_primitives::B256;
55
use futures::StreamExt;
66
use libp2p::{
7-
Multiaddr, PeerId, Swarm, Transport, core::upgrade, gossipsub, identify, identity, noise, ping,
8-
swarm::NetworkBehaviour, tcp, yamux,
7+
Multiaddr, PeerId, Swarm, Transport, core::upgrade, dns, gossipsub, identify, identity, noise,
8+
ping, swarm::NetworkBehaviour, tcp, yamux,
99
};
1010
use preconfirmation_net::{P2pConfig, spawn_discovery};
1111
use sha2::{Digest, Sha256};
@@ -224,7 +224,9 @@ impl WhitelistNetwork {
224224
};
225225

226226
let noise_config = noise::Config::new(&local_key).map_err(to_p2p_err)?;
227-
let transport = tcp::tokio::Transport::new(tcp::Config::default().nodelay(true))
227+
let base_tcp = tcp::tokio::Transport::new(tcp::Config::default().nodelay(true));
228+
let tcp_with_dns = dns::tokio::Transport::system(base_tcp).map_err(to_p2p_err)?;
229+
let transport = tcp_with_dns
228230
.upgrade(upgrade::Version::V1Lazy)
229231
.authenticate(noise_config)
230232
.multiplex(yamux::Config::default())

0 commit comments

Comments
 (0)