jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

docs: add example docs (#14164)

Browse Source
This commit is contained in:
Matthias Seitz
2025-02-03 15:37:42 +01:00
committed by GitHub
parent 6f9aa3804b
commit 7243aaf555
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
examples/network-proxy/src/main.rs
View File

@ -13,8 +13,11 @@
use futures::StreamExt; use futures::StreamExt;
use reth_chainspec::DEV; use reth_chainspec::DEV;
use reth_network::{ use reth_network::{
config::rng_secret_key, eth_requests::IncomingEthRequest, p2p::HeadersClient, config::rng_secret_key,
transactions::NetworkTransactionEvent, types::NewPooledTransactionHashes68, eth_requests::IncomingEthRequest,
p2p::HeadersClient,
transactions::NetworkTransactionEvent,
types::{BlockHashOrNumber, NewPooledTransactionHashes68},
BlockDownloaderProvider, FetchClient, NetworkConfig, NetworkEventListenerProvider, BlockDownloaderProvider, FetchClient, NetworkConfig, NetworkEventListenerProvider,
NetworkHandle, NetworkInfo, NetworkManager, Peers, NetworkHandle, NetworkInfo, NetworkManager, Peers,
}; };
@ -62,7 +65,7 @@ async fn main() -> eyre::Result<()> {
}); });
loop { loop {
// receive incoming eth requests and transaction messages // receive incoming eth requests and transaction messages from the second peer
tokio::select! { tokio::select! {
eth_request = requests_rx.recv() => { eth_request = requests_rx.recv() => {
let Some(eth_request) = eth_request else {break}; let Some(eth_request) = eth_request else {break};
@ -93,7 +96,8 @@ async fn main() -> eyre::Result<()> {
Ok(()) Ok(())
} }
/// Launches another network/peer, connects to the first peer and sends a header request. /// Launches another network/peer, connects to the first peer and sends requests/messages to the
/// first peer.
async fn run_peer(handle: NetworkHandle) -> eyre::Result<()> { async fn run_peer(handle: NetworkHandle) -> eyre::Result<()> {
// create another peer // create another peer
let config = NetworkConfig::builder(rng_secret_key()) let config = NetworkConfig::builder(rng_secret_key())
@ -106,12 +110,13 @@ async fn run_peer(handle: NetworkHandle) -> eyre::Result<()> {
tokio::task::spawn(network); tokio::task::spawn(network);
// add the other peer as trusted // add the other peer as trusted
// this will establish a connection to the first peer
peer.add_trusted_peer(*handle.peer_id(), handle.local_addr()); peer.add_trusted_peer(*handle.peer_id(), handle.local_addr());
// obtain the client that can emit requests // obtain the client that can emit requests
let client: FetchClient = peer.fetch_client().await?; let client: FetchClient = peer.fetch_client().await?;
let header = client.get_header(0.into()).await.unwrap(); let header = client.get_header(BlockHashOrNumber::Number(0)).await.unwrap();
println!("Got header: {:?}", header); println!("Got header: {:?}", header);
// send a (bogus) hashes message // send a (bogus) hashes message