@@ -11633,6 +11633,34 @@ mod tests {
11633
11633
}
11634
11634
}
11635
11635
11636
+ #[test]
11637
+ fn test_channel_update_cached() {
11638
+ let chanmon_cfgs = create_chanmon_cfgs(2);
11639
+ let node_cfgs = create_node_cfgs(2, &chanmon_cfgs);
11640
+ let node_chanmgrs = create_node_chanmgrs(2, &node_cfgs, &[None, None]);
11641
+ let nodes = create_network(2, &node_cfgs, &node_chanmgrs);
11642
+
11643
+ let chan = create_announced_chan_between_nodes(&nodes, 0, 1);
11644
+
11645
+ nodes[0].node.force_close_channel_with_peer(&chan.2, &nodes[1].node.get_our_node_id(), None, true).unwrap();
11646
+ check_added_monitors!(nodes[0], 1);
11647
+ check_closed_event!(nodes[0], 1, ClosureReason::HolderForceClosed, [nodes[1].node.get_our_node_id()], 100000);
11648
+
11649
+ {
11650
+ // Assert that channelUpdate message has been added to node[2] pending msg events
11651
+ let pending_broadcast_messages= nodes[0].node.pending_broadcast_messages.lock().unwrap();
11652
+ assert_eq!(pending_broadcast_messages.len(), 1);
11653
+ }
11654
+
11655
+ // Confirm that the channel_update was not sent immediately to node[1] but was cached.
11656
+ let node_1_events = nodes[1].node.get_and_clear_pending_msg_events();
11657
+ assert_eq!(node_1_events.len(), 0);
11658
+
11659
+ // Confirm that get_and_clear_pending_msg_events correctly captures pending_broadcast_messages
11660
+ let node_0_events = nodes[0].node.get_and_clear_pending_msg_events();
11661
+ assert_eq!(node_0_events.len(), 1);
11662
+ }
11663
+
11636
11664
#[test]
11637
11665
fn test_drop_disconnected_peers_when_removing_channels() {
11638
11666
let chanmon_cfgs = create_chanmon_cfgs(2);
0 commit comments