Skip to content

Commit 72de9cc

Browse files
committed
Add a test for Router's should_request_full_sync
1 parent 71021fc commit 72de9cc

File tree

1 file changed

+14
-1
lines changed

1 file changed

+14
-1
lines changed

lightning/src/ln/router.rs

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1051,7 +1051,7 @@ mod tests {
10511051
use ln::channelmanager;
10521052
use ln::router::{Router,NodeInfo,NetworkMap,ChannelInfo,DirectionalChannelInfo,RouteHint};
10531053
use ln::features::{ChannelFeatures, InitFeatures, NodeFeatures};
1054-
use ln::msgs::{LightningError, ErrorAction};
1054+
use ln::msgs::{ErrorAction, LightningError, RoutingMessageHandler};
10551055
use util::test_utils;
10561056
use util::test_utils::TestVecWriter;
10571057
use util::logger::Logger;
@@ -1845,4 +1845,17 @@ mod tests {
18451845
assert!(<NetworkMap>::read(&mut ::std::io::Cursor::new(&w.0)).unwrap() == *network);
18461846
}
18471847
}
1848+
1849+
#[test]
1850+
fn request_full_sync_finite_times() {
1851+
let (secp_ctx, _, router) = create_router();
1852+
let node_id = PublicKey::from_secret_key(&secp_ctx, &SecretKey::from_slice(&hex::decode("0202020202020202020202020202020202020202020202020202020202020202").unwrap()[..]).unwrap());
1853+
1854+
assert!(router.should_request_full_sync(&node_id));
1855+
assert!(router.should_request_full_sync(&node_id));
1856+
assert!(router.should_request_full_sync(&node_id));
1857+
assert!(router.should_request_full_sync(&node_id));
1858+
assert!(router.should_request_full_sync(&node_id));
1859+
assert!(!router.should_request_full_sync(&node_id));
1860+
}
18481861
}

0 commit comments

Comments
 (0)