diff --git a/beacon_node/beacon_chain/src/builder.rs b/beacon_node/beacon_chain/src/builder.rs index f905ef0ae..237e61414 100644 --- a/beacon_node/beacon_chain/src/builder.rs +++ b/beacon_node/beacon_chain/src/builder.rs @@ -306,8 +306,8 @@ where })?; let genesis = BeaconSnapshot { - beacon_block_root, beacon_block, + beacon_block_root, beacon_state, }; diff --git a/beacon_node/beacon_chain/src/eth1_chain.rs b/beacon_node/beacon_chain/src/eth1_chain.rs index ed74ff6e4..c269b8c51 100644 --- a/beacon_node/beacon_chain/src/eth1_chain.rs +++ b/beacon_node/beacon_chain/src/eth1_chain.rs @@ -612,11 +612,9 @@ fn collect_valid_votes( .eth1_data_votes .iter() .filter_map(|vote| { - if let Some(block_num) = votes_to_consider.get(vote) { - Some((vote.clone(), *block_num)) - } else { - None - } + votes_to_consider + .get(vote) + .map(|block_num| (vote.clone(), *block_num)) }) .for_each(|(eth1_data, block_number)| { valid_votes diff --git a/beacon_node/eth1/src/http.rs b/beacon_node/eth1/src/http.rs index 547715a06..9ec7576d2 100644 --- a/beacon_node/eth1/src/http.rs +++ b/beacon_node/eth1/src/http.rs @@ -73,7 +73,7 @@ impl FromStr for Eth1Id { type Err = String; fn from_str(s: &str) -> Result { - u64::from_str_radix(s, 10) + s.parse::() .map(Into::into) .map_err(|e| format!("Failed to parse eth1 network id {}", e)) } diff --git a/beacon_node/eth2_libp2p/src/discovery/enr_ext.rs b/beacon_node/eth2_libp2p/src/discovery/enr_ext.rs index 30ace623c..deb554c7f 100644 --- a/beacon_node/eth2_libp2p/src/discovery/enr_ext.rs +++ b/beacon_node/eth2_libp2p/src/discovery/enr_ext.rs @@ -299,7 +299,7 @@ mod tests { let sk_bytes = hex::decode(sk_hex).unwrap(); let secret = discv5::enr::ed25519_dalek::SecretKey::from_bytes(&sk_bytes).unwrap(); let public = discv5::enr::ed25519_dalek::PublicKey::from(&secret); - let keypair = discv5::enr::ed25519_dalek::Keypair { public, secret }; + let keypair = discv5::enr::ed25519_dalek::Keypair { secret, public }; let libp2p_sk = libp2p::identity::ed25519::SecretKey::from_bytes(sk_bytes).unwrap(); let ed25519_kp: libp2p::identity::ed25519::Keypair = libp2p_sk.into(); diff --git a/beacon_node/eth2_libp2p/src/service.rs b/beacon_node/eth2_libp2p/src/service.rs index 079338b54..21c75836e 100644 --- a/beacon_node/eth2_libp2p/src/service.rs +++ b/beacon_node/eth2_libp2p/src/service.rs @@ -233,9 +233,9 @@ impl Service { } let service = Service { - local_peer_id, - bandwidth, swarm, + bandwidth, + local_peer_id, log, }; diff --git a/beacon_node/eth2_libp2p/src/types/topics.rs b/beacon_node/eth2_libp2p/src/types/topics.rs index 18efde345..f8e2b6768 100644 --- a/beacon_node/eth2_libp2p/src/types/topics.rs +++ b/beacon_node/eth2_libp2p/src/types/topics.rs @@ -81,8 +81,8 @@ impl GossipTopic { pub fn new(kind: GossipKind, encoding: GossipEncoding, fork_digest: [u8; 4]) -> Self { GossipTopic { encoding, - kind, fork_digest, + kind, } } @@ -135,8 +135,8 @@ impl GossipTopic { return Ok(GossipTopic { encoding, - kind, fork_digest, + kind, }); } @@ -195,7 +195,10 @@ pub fn subnet_id_from_topic_hash(topic_hash: &TopicHash) -> Option { fn committee_topic_index(topic: &str) -> Option { if topic.starts_with(BEACON_ATTESTATION_PREFIX) { return Some(SubnetId::new( - u64::from_str_radix(topic.trim_start_matches(BEACON_ATTESTATION_PREFIX), 10).ok()?, + topic + .trim_start_matches(BEACON_ATTESTATION_PREFIX) + .parse::() + .ok()?, )); } None diff --git a/beacon_node/http_api/src/lib.rs b/beacon_node/http_api/src/lib.rs index 653820367..325b28988 100644 --- a/beacon_node/http_api/src/lib.rs +++ b/beacon_node/http_api/src/lib.rs @@ -1355,7 +1355,7 @@ pub fn serve( let heads = chain .heads() .into_iter() - .map(|(root, slot)| api_types::ChainHeadData { root, slot }) + .map(|(root, slot)| api_types::ChainHeadData { slot, root }) .collect::>(); Ok(api_types::GenericResponse::from(heads)) }) @@ -1623,10 +1623,10 @@ pub fn serve( }); Ok(api_types::GenericResponse::from(api_types::PeerCount { - disconnecting, - connecting, connected, + connecting, disconnected, + disconnecting, })) }) }); diff --git a/beacon_node/network/src/beacon_processor/worker/rpc_methods.rs b/beacon_node/network/src/beacon_processor/worker/rpc_methods.rs index 71b9b1139..d25590f7c 100644 --- a/beacon_node/network/src/beacon_processor/worker/rpc_methods.rs +++ b/beacon_node/network/src/beacon_processor/worker/rpc_methods.rs @@ -197,10 +197,7 @@ impl Worker { }; // remove all skip slots - let block_roots = block_roots - .into_iter() - .filter_map(|root| root) - .collect::>(); + let block_roots = block_roots.into_iter().flatten().collect::>(); let mut blocks_sent = 0; for root in block_roots { diff --git a/consensus/types/src/slot_epoch_macros.rs b/consensus/types/src/slot_epoch_macros.rs index caf31417d..b8e6202fe 100644 --- a/consensus/types/src/slot_epoch_macros.rs +++ b/consensus/types/src/slot_epoch_macros.rs @@ -572,10 +572,8 @@ macro_rules! math_tests { #[test] fn checked_div() { let assert_checked_div = |a: u64, b: u64, result: Option| { - let division_result_as_u64 = match $type(a).safe_div($type(b)).ok() { - None => None, - Some(val) => Some(val.as_u64()), - }; + let division_result_as_u64 = + $type(a).safe_div($type(b)).ok().map(|val| val.as_u64()); assert_eq!(division_result_as_u64, result); }; diff --git a/slasher/src/slasher.rs b/slasher/src/slasher.rs index fab807fcf..91cf84fc3 100644 --- a/slasher/src/slasher.rs +++ b/slasher/src/slasher.rs @@ -38,10 +38,10 @@ impl Slasher { let block_queue = BlockQueue::default(); Ok(Self { db, - attester_slashings, - proposer_slashings, attestation_queue, block_queue, + attester_slashings, + proposer_slashings, config, log, }) diff --git a/testing/eth1_test_rig/src/ganache.rs b/testing/eth1_test_rig/src/ganache.rs index 7b62db30b..a890f7c71 100644 --- a/testing/eth1_test_rig/src/ganache.rs +++ b/testing/eth1_test_rig/src/ganache.rs @@ -62,8 +62,8 @@ impl GanacheInstance { child.stdout = Some(reader.into_inner()); Ok(Self { - child, port, + child, web3, network_id, chain_id, diff --git a/testing/eth1_test_rig/src/lib.rs b/testing/eth1_test_rig/src/lib.rs index e222de05e..716ccd357 100644 --- a/testing/eth1_test_rig/src/lib.rs +++ b/testing/eth1_test_rig/src/lib.rs @@ -104,7 +104,7 @@ impl DepositContract { })?; Contract::from_json(web3.clone().eth(), address, ABI) .map_err(|e| format!("Failed to init contract: {:?}", e)) - .map(move |contract| Self { contract, web3 }) + .map(move |contract| Self { web3, contract }) } /// The deposit contract's address in `0x00ab...` format. diff --git a/testing/state_transition_vectors/src/exit.rs b/testing/state_transition_vectors/src/exit.rs index 10843f9d2..99b8122ac 100644 --- a/testing/state_transition_vectors/src/exit.rs +++ b/testing/state_transition_vectors/src/exit.rs @@ -83,8 +83,8 @@ impl ExitTest { TestVector { title, - block, pre_state, + block, post_state, error, } diff --git a/validator_client/src/http_api/api_secret.rs b/validator_client/src/http_api/api_secret.rs index 7f2a81d19..d3e5c2d12 100644 --- a/validator_client/src/http_api/api_secret.rs +++ b/validator_client/src/http_api/api_secret.rs @@ -133,7 +133,7 @@ impl ApiSecret { )); } - Ok(Self { sk, pk }) + Ok(Self { pk, sk }) } /// Returns the public key of `self` as a 0x-prefixed hex string.