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

feat: propagate helper (#11654)

Browse Source 
Co-authored-by: Oliver <onbjerg@users.noreply.github.com>
This commit is contained in:
Matthias Seitz
2024-10-11 08:28:07 +02:00
committed by GitHub
parent cb123084bf
commit ad485277de
1 changed files with 21 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
crates/net/network/src/transactions/mod.rs
View File

@ -153,6 +153,14 @@ impl TransactionsHandle {
self.send(TransactionsCommand::PropagateTransactionsTo(transactions, peer))
}
/// Manually propagate the given transactions to all peers.
///
/// It's up to the [`TransactionsManager`] whether the transactions are sent as hashes or in
/// full.
pub fn propagate_transactions(&self, transactions: Vec<TxHash>) {
self.send(TransactionsCommand::PropagateTransactions(transactions))
}
/// Request the transaction hashes known by specific peers.
pub async fn get_transaction_hashes(
&self,
@ -398,8 +406,14 @@ where
trace!(target: "net::tx", num_hashes=?hashes.len(), "Start propagating transactions");
// This fetches all transaction from the pool, including the 4844 blob transactions but
// __without__ their sidecar, because 4844 transactions are only ever announced as hashes.
self.propagate_all(hashes);
}
/// Propagates the given transactions to the peers
///
/// This fetches all transaction from the pool, including the 4844 blob transactions but
/// __without__ their sidecar, because 4844 transactions are only ever announced as hashes.
fn propagate_all(&mut self, hashes: Vec<TxHash>) {
let propagated = self.propagate_transactions(
self.pool.get_all(hashes).into_iter().map(PropagateTransaction::new).collect(),
);
@ -872,11 +886,12 @@ where
let peers = self.peers.keys().copied().collect::<HashSet<_>>();
tx.send(peers).ok();
}
TransactionsCommand::PropagateTransactionsTo(txs, _peer) => {
if let Some(propagated) = self.propagate_full_transactions_to_peer(txs, _peer) {
TransactionsCommand::PropagateTransactionsTo(txs, peer) => {
if let Some(propagated) = self.propagate_full_transactions_to_peer(txs, peer) {
self.pool.on_propagated(propagated);
}
}
TransactionsCommand::PropagateTransactions(txs) => self.propagate_all(txs),
TransactionsCommand::GetTransactionHashes { peers, tx } => {
let mut res = HashMap::with_capacity(peers.len());
for peer_id in peers {
@ -1653,6 +1668,8 @@ enum TransactionsCommand {
GetActivePeers(oneshot::Sender<HashSet<PeerId>>),
/// Propagate a collection of full transactions to a specific peer.
PropagateTransactionsTo(Vec<TxHash>, PeerId),
/// Propagate a collection of full transactions to all peers.
PropagateTransactions(Vec<TxHash>),
/// Request transaction hashes known by specific peers from the [`TransactionsManager`].
GetTransactionHashes {
peers: Vec<PeerId>,