From: Chris Waterson Date: Mon, 16 Oct 2023 22:54:29 +0000 (-0700) Subject: Terser asserts X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=commitdiff_plain;h=5d0d5c6c175b5f538cb0f030ffa94719264e6d3f;p=rust-lightning Terser asserts Get rid of temporaries; replace multiline checks. --- diff --git a/lightning/src/ln/async_signer_tests.rs b/lightning/src/ln/async_signer_tests.rs index a0045b771..9e3fe2b8b 100644 --- a/lightning/src/ln/async_signer_tests.rs +++ b/lightning/src/ln/async_signer_tests.rs @@ -41,11 +41,7 @@ fn test_async_commitment_signature_for_funding_created() { nodes[0].node.funding_transaction_generated(&temporary_channel_id, &nodes[1].node.get_our_node_id(), tx.clone()).unwrap(); check_added_monitors(&nodes[0], 0); - { - let events = nodes[0].node.get_and_clear_pending_msg_events(); - let n = events.len(); - assert_eq!(n, 0, "expected no events generated from nodes[0], found {}", n); - } + assert!(nodes[0].node.get_and_clear_pending_msg_events().is_empty()); // Now re-enable the signer and simulate a retry. The temporary_channel_id won't work anymore so // we have to dig out the real channel ID. @@ -100,11 +96,7 @@ fn test_async_commitment_signature_for_funding_signed() { nodes[1].node.handle_funding_created(&nodes[0].node.get_our_node_id(), &funding_created_msg); check_added_monitors(&nodes[1], 1); - { - let events = nodes[1].node.get_and_clear_pending_msg_events(); - let n = events.len(); - assert_eq!(n, 0, "expected no events generated from nodes[1], found {}", n); - } + assert!(nodes[1].node.get_and_clear_pending_msg_events().is_empty()); // Now re-enable the signer and simulate a retry. The temporary_channel_id won't work anymore so // we have to dig out the real channel ID. @@ -137,8 +129,7 @@ fn test_async_commitment_signature_for_commitment_signed() { let per_peer_state = nodes[0].node.per_peer_state.read().unwrap(); let chan_lock = per_peer_state.get(&nodes[1].node.get_our_node_id()).unwrap().lock().unwrap(); let chan_ids = chan_lock.channel_by_id.keys().collect::>(); - let n = chan_ids.len(); - assert_eq!(n, 1, "expected one channel, not {}", n); + assert_eq!(chan_ids.len(), 1, "expected one channel, not {}", chan_ids.len()); *chan_ids[0] }; @@ -174,8 +165,7 @@ fn test_async_commitment_signature_for_commitment_signed() { dst.node.signer_unblocked(Some((src.node.get_our_node_id(), chan_id))); let events = dst.node.get_and_clear_pending_msg_events(); - let n = events.len(); - assert_eq!(n, 1, "expected one message, got {}", n); + assert_eq!(events.len(), 1, "expected one message, got {}", events.len()); if let MessageSendEvent::UpdateHTLCs { ref node_id, .. } = events[0] { assert_eq!(node_id, &src.node.get_our_node_id()); } else { @@ -231,11 +221,7 @@ fn test_async_commitment_signature_for_funding_signed_0conf() { nodes[1].node.handle_funding_created(&nodes[0].node.get_our_node_id(), &funding_created_msg); check_added_monitors(&nodes[1], 1); - { - let events = nodes[1].node.get_and_clear_pending_msg_events(); - let n = events.len(); - assert_eq!(n, 0, "expected no events generated from nodes[1], found {}", n); - } + assert!(nodes[1].node.get_and_clear_pending_msg_events().is_empty()); // Now re-enable the signer and simulate a retry. The temporary_channel_id won't work anymore so // we have to dig out the real channel ID. @@ -298,8 +284,7 @@ fn test_async_commitment_signature_for_peer_disconnect() { let per_peer_state = nodes[0].node.per_peer_state.read().unwrap(); let chan_lock = per_peer_state.get(&nodes[1].node.get_our_node_id()).unwrap().lock().unwrap(); let chan_ids = chan_lock.channel_by_id.keys().collect::>(); - let n = chan_ids.len(); - assert_eq!(n, 1, "expected one channel, not {}", n); + assert_eq!(chan_ids.len(), 1, "expected one channel, not {}", chan_ids.len()); *chan_ids[0] }; @@ -344,8 +329,7 @@ fn test_async_commitment_signature_for_peer_disconnect() { { let events = dst.node.get_and_clear_pending_msg_events(); - let n = events.len(); - assert_eq!(n, 1, "expected one message, got {}", n); + assert_eq!(events.len(), 1, "expected one message, got {}", events.len()); if let MessageSendEvent::UpdateHTLCs { ref node_id, .. } = events[0] { assert_eq!(node_id, &src.node.get_our_node_id()); } else {