@@ -1809,26 +1809,23 @@ fn test_network_result_update() {
1809
1809
}
1810
1810
1811
1811
#[ rstest]
1812
- #[ case:: none_to_none ( None , None , 0 ) ]
1813
- #[ case:: none_to_some ( None , Some ( 10 ) , 10 ) ]
1814
- #[ case:: some_to_none ( Some ( 10 ) , None , 10 ) ]
1815
- #[ case:: new_height_higher ( Some ( 10 ) , Some ( 20 ) , 20 ) ]
1816
- #[ case:: new_height_lower ( Some ( 20 ) , Some ( 10 ) , 20 ) ]
1812
+ #[ case( None , None , false ) ]
1813
+ #[ case( None , Some ( 10 ) , true ) ]
1814
+ #[ case( Some ( 10 ) , None , false ) ]
1815
+ #[ case( Some ( 10 ) , Some ( 20 ) , true ) ]
1816
+ #[ case( Some ( 20 ) , Some ( 10 ) , false ) ]
1817
1817
fn test_update_highest_stacks_height_of_neighbors (
1818
1818
#[ case] old_height : Option < u64 > ,
1819
1819
#[ case] new_height : Option < u64 > ,
1820
- #[ case] expected_height : u64 ,
1820
+ #[ case] is_update_accepted : bool ,
1821
1821
) {
1822
1822
let peer_config = TestPeerConfig :: new ( function_name ! ( ) , 0 , 0 ) ;
1823
1823
let mut peer = TestPeer :: new ( peer_config) ;
1824
- if let Some ( old_height) = old_height {
1825
- peer. network . highest_stacks_neighbor = Some ( (
1826
- SocketAddr :: new ( IpAddr :: V4 ( Ipv4Addr :: new ( 127 , 0 , 0 , 1 ) ) , 8080 ) ,
1827
- old_height,
1828
- ) ) ;
1829
- } else {
1830
- peer. network . highest_stacks_neighbor = None ;
1831
- }
1824
+
1825
+ let prev_highest_neighbor =
1826
+ old_height. map ( |h| ( SocketAddr :: new ( IpAddr :: V4 ( Ipv4Addr :: LOCALHOST ) , 8080 ) , h) ) ;
1827
+ peer. network . highest_stacks_neighbor = prev_highest_neighbor. clone ( ) ;
1828
+
1832
1829
let peer_sortdb = peer. sortdb . take ( ) . unwrap ( ) ;
1833
1830
let mut peer_stacks_node = peer. stacks_node . take ( ) . unwrap ( ) ;
1834
1831
let mut peer_mempool = peer. mempool . take ( ) . unwrap ( ) ;
@@ -1843,14 +1840,14 @@ fn test_update_highest_stacks_height_of_neighbors(
1843
1840
false ,
1844
1841
) ;
1845
1842
1846
- let new_addr = SocketAddr :: new ( IpAddr :: V4 ( Ipv4Addr :: new ( 127 , 0 , 0 , 1 ) ) , 8081 ) ;
1847
- node_state. update_highest_stacks_neighbor ( & new_addr, new_height) ;
1848
- if let Some ( new_height) = new_height {
1849
- assert_eq ! (
1850
- peer. network. highest_stacks_neighbor,
1851
- Some ( ( new_addr, expected_height) )
1852
- ) ;
1843
+ let new_peer_addr = SocketAddr :: new ( IpAddr :: V4 ( Ipv4Addr :: LOCALHOST ) , 8081 ) ;
1844
+ node_state. update_highest_stacks_neighbor ( & new_peer_addr, new_height) ;
1845
+
1846
+ let expected_highest_peer = if is_update_accepted {
1847
+ Some ( ( new_peer_addr, new_height. unwrap ( ) ) )
1853
1848
} else {
1854
- assert_eq ! ( peer. network. highest_stacks_neighbor, None ) ;
1855
- }
1849
+ prev_highest_neighbor
1850
+ } ;
1851
+
1852
+ assert_eq ! ( peer. network. highest_stacks_neighbor, expected_highest_peer) ;
1856
1853
}
0 commit comments