@@ -10184,19 +10184,17 @@ fn incoming_signers_ignore_block_proposals() {
10184
10184
10185
10185
let mut no_next_signer_messages = || {
10186
10186
let _ = wait_for ( 30 , || {
10187
- for slot_id in next_signer_slot_ids. iter ( ) {
10188
- let latest_msgs = StackerDB :: get_messages :: < SignerMessage > (
10189
- stackerdb
10190
- . get_session_mut ( & MessageSlotID :: BlockResponse )
10191
- . expect ( "Failed to get BlockResponse stackerdb session" ) ,
10192
- & [ * slot_id] ,
10193
- )
10194
- . expect ( "Failed to get message from stackerdb" ) ;
10195
- assert ! (
10196
- latest_msgs. is_empty( ) ,
10197
- "Signer {slot_id} has messages in the stackerdb"
10198
- ) ;
10199
- }
10187
+ let latest_msgs = StackerDB :: get_messages :: < SignerMessage > (
10188
+ stackerdb
10189
+ . get_session_mut ( & MessageSlotID :: BlockResponse )
10190
+ . expect ( "Failed to get BlockResponse stackerdb session" ) ,
10191
+ & next_signer_slot_ids,
10192
+ )
10193
+ . expect ( "Failed to get messages from stackerdb" ) ;
10194
+ assert ! (
10195
+ latest_msgs. is_empty( ) ,
10196
+ "Next signers have messages in their stackerdb"
10197
+ ) ;
10200
10198
Ok ( false )
10201
10199
} ) ;
10202
10200
} ;
@@ -10218,19 +10216,12 @@ fn incoming_signers_ignore_block_proposals() {
10218
10216
10219
10217
info ! ( "------------------------- Test Attempt to Mine Invalid Block {signer_signature_hash_1} -------------------------" ) ;
10220
10218
10221
- // First propose a block to the signers that does not have the correct consensus hash or BitVec. This should be rejected BEFORE
10222
- // the block is submitted to the node for validation.
10223
10219
let short_timeout = Duration :: from_secs ( 30 ) ;
10224
10220
let all_signers: Vec < _ > = signer_test
10225
10221
. signer_stacks_private_keys
10226
10222
. iter ( )
10227
10223
. map ( StacksPublicKey :: from_private)
10228
10224
. collect ( ) ;
10229
- signer_test. propose_block ( block. clone ( ) , short_timeout) ;
10230
- signer_test
10231
- . wait_for_block_rejections ( 30 , & all_signers)
10232
- . expect ( "Timed out waiting for block rejections" ) ;
10233
- no_next_signer_messages ( ) ;
10234
10225
test_observer:: clear ( ) ;
10235
10226
10236
10227
// Propose a block to the signers that passes initial checks but will be rejected by the stacks node
@@ -10388,18 +10379,16 @@ fn outgoing_signers_ignore_block_proposals() {
10388
10379
10389
10380
let mut old_signers_ignore_block_proposals = |hash| {
10390
10381
let _ = wait_for ( 10 , || {
10391
- for slot_id in old_signer_slot_ids. iter ( ) {
10392
- let latest_msgs = StackerDB :: get_messages :: < SignerMessage > (
10393
- stackerdb
10394
- . get_session_mut ( & MessageSlotID :: BlockResponse )
10395
- . expect ( "Failed to get BlockResponse stackerdb session" ) ,
10396
- & [ * slot_id] ,
10397
- )
10398
- . expect ( "Failed to get message from stackerdb" ) ;
10399
- for msg in latest_msgs. iter ( ) {
10400
- if let SignerMessage :: BlockResponse ( response) = msg {
10401
- assert_ne ! ( response. get_signer_signature_hash( ) , hash) ;
10402
- }
10382
+ let latest_msgs = StackerDB :: get_messages :: < SignerMessage > (
10383
+ stackerdb
10384
+ . get_session_mut ( & MessageSlotID :: BlockResponse )
10385
+ . expect ( "Failed to get BlockResponse stackerdb session" ) ,
10386
+ & old_signer_slot_ids,
10387
+ )
10388
+ . expect ( "Failed to get messages from stackerdb" ) ;
10389
+ for msg in latest_msgs. iter ( ) {
10390
+ if let SignerMessage :: BlockResponse ( response) = msg {
10391
+ assert_ne ! ( response. get_signer_signature_hash( ) , hash) ;
10403
10392
}
10404
10393
}
10405
10394
Ok ( false )
@@ -10422,19 +10411,12 @@ fn outgoing_signers_ignore_block_proposals() {
10422
10411
10423
10412
info ! ( "------------------------- Test Attempt to Mine Invalid Block {signer_signature_hash_1} -------------------------" ) ;
10424
10413
10425
- // First propose a block to the signers that does not have the correct consensus hash or BitVec. This should be rejected BEFORE
10426
- // the block is submitted to the node for validation.
10427
10414
let short_timeout = Duration :: from_secs ( 30 ) ;
10428
10415
let all_signers: Vec < _ > = signer_test
10429
10416
. signer_stacks_private_keys
10430
10417
. iter ( )
10431
10418
. map ( StacksPublicKey :: from_private)
10432
10419
. collect ( ) ;
10433
- signer_test. propose_block ( block. clone ( ) , short_timeout) ;
10434
- signer_test
10435
- . wait_for_block_rejections ( 30 , & all_signers)
10436
- . expect ( "Timed out waiting for block rejections" ) ;
10437
- old_signers_ignore_block_proposals ( signer_signature_hash_1) ;
10438
10420
test_observer:: clear ( ) ;
10439
10421
10440
10422
// Propose a block to the signers that passes initial checks but will be rejected by the stacks node
0 commit comments