@@ -4585,9 +4585,9 @@ fn test_ignore_too_many_messages_in_ihave() {
4585
4585
let ( peer, receiver) = add_peer ( & mut gs, & topics, false , false ) ;
4586
4586
receivers. insert ( peer, receiver) ;
4587
4587
4588
- //peer has 20 messages
4588
+ //peer has 30 messages
4589
4589
let mut seq = 0 ;
4590
- let message_ids: Vec < _ > = ( 0 ..20 )
4590
+ let message_ids: Vec < _ > = ( 0 ..30 )
4591
4591
. map ( |_| random_message ( & mut seq, & topics) )
4592
4592
. map ( |msg| gs. data_transform . inbound_transform ( msg) . unwrap ( ) )
4593
4593
. map ( |msg| config. message_id ( & msg) )
@@ -4629,7 +4629,7 @@ fn test_ignore_too_many_messages_in_ihave() {
4629
4629
gs. heartbeat ( ) ;
4630
4630
gs. handle_ihave (
4631
4631
& peer,
4632
- vec ! [ ( topics[ 0 ] . clone( ) , message_ids[ 10 .. 20 ] . to_vec( ) ) ] ,
4632
+ vec ! [ ( topics[ 0 ] . clone( ) , message_ids[ 20 .. 30 ] . to_vec( ) ) ] ,
4633
4633
) ;
4634
4634
4635
4635
//we sent 10 iwant messages ids via a IWANT rpc.
@@ -5252,7 +5252,7 @@ fn sends_idontwant() {
5252
5252
. to_subscribe ( true )
5253
5253
. gs_config ( Config :: default ( ) )
5254
5254
. explicit ( 1 )
5255
- . peer_kind ( PeerKind :: Gossipsubv1_2 )
5255
+ . peer_kind ( PeerKind :: Gossipsubv1_2_beta )
5256
5256
. create_network ( ) ;
5257
5257
5258
5258
let local_id = PeerId :: random ( ) ;
@@ -5337,7 +5337,7 @@ fn doesnt_forward_idontwant() {
5337
5337
. to_subscribe ( true )
5338
5338
. gs_config ( Config :: default ( ) )
5339
5339
. explicit ( 1 )
5340
- . peer_kind ( PeerKind :: Gossipsubv1_2 )
5340
+ . peer_kind ( PeerKind :: Gossipsubv1_2_beta )
5341
5341
. create_network ( ) ;
5342
5342
5343
5343
let local_id = PeerId :: random ( ) ;
@@ -5386,7 +5386,7 @@ fn parses_idontwant() {
5386
5386
. to_subscribe ( true )
5387
5387
. gs_config ( Config :: default ( ) )
5388
5388
. explicit ( 1 )
5389
- . peer_kind ( PeerKind :: Gossipsubv1_2 )
5389
+ . peer_kind ( PeerKind :: Gossipsubv1_2_beta )
5390
5390
. create_network ( ) ;
5391
5391
5392
5392
let message_id = MessageId :: new ( & [ 0 , 1 , 2 , 3 ] ) ;
@@ -5418,7 +5418,7 @@ fn clear_stale_idontwant() {
5418
5418
. to_subscribe ( true )
5419
5419
. gs_config ( Config :: default ( ) )
5420
5420
. explicit ( 1 )
5421
- . peer_kind ( PeerKind :: Gossipsubv1_2 )
5421
+ . peer_kind ( PeerKind :: Gossipsubv1_2_beta )
5422
5422
. create_network ( ) ;
5423
5423
5424
5424
let peer = gs. connected_peers . get_mut ( & peers[ 2 ] ) . unwrap ( ) ;
0 commit comments