From 10fabf4266a33bf3ee7684eea54bdf55a328846a Mon Sep 17 00:00:00 2001 From: shaavan Date: Sun, 3 Dec 2023 18:18:24 +0530 Subject: [PATCH] Add test to check the introduced behaviour --- lightning/src/ln/channelmanager.rs | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) diff --git a/lightning/src/ln/channelmanager.rs b/lightning/src/ln/channelmanager.rs index a1df2190f66..fcc1af062be 100644 --- a/lightning/src/ln/channelmanager.rs +++ b/lightning/src/ln/channelmanager.rs @@ -11293,6 +11293,36 @@ mod tests { } } + #[test] + fn test_channel_close_when_not_timely_accepted() { + // Create network of two nodes + let chanmon_cfgs = create_chanmon_cfgs(2); + let node_cfgs = create_node_cfgs(2, &chanmon_cfgs); + let node_chanmgrs = create_node_chanmgrs(2, &node_cfgs, &[None, None]); + let nodes = create_network(2, &node_cfgs, &node_chanmgrs); + + // Try to create a channel from node 0, to 1. + // The channel is initiated from the node 0 side, + // But the accept channel message was never back sent by node 1 + // And hence never handled. + let create_chan_id = nodes[0].node.create_channel(nodes[1].node.get_our_node_id(), 100000, 10001, 42, None, None).unwrap(); + let open_channel_msg = get_event_msg!(nodes[0], MessageSendEvent::SendOpenChannel, nodes[1].node.get_our_node_id()); + assert_eq!(open_channel_msg.temporary_channel_id, create_chan_id); + + // In the meantime, two timer tick passed + nodes[0].node.timer_tick_occurred(); + nodes[0].node.timer_tick_occurred(); + + // Since accept channel message was never received + // The channel should be forced close by now from node 0 side + let events = nodes[0].node.get_and_clear_pending_msg_events(); + assert_eq!(events.len(), 1); + + let node_0_per_peer_state = nodes[0].node.per_peer_state.read().unwrap(); + let per_peer_state = node_0_per_peer_state.get(&nodes[1].node.get_our_node_id()).unwrap().lock().unwrap(); + assert_eq!(per_peer_state.channel_by_id.len(), 0); + } + #[test] fn test_drop_disconnected_peers_when_removing_channels() { let chanmon_cfgs = create_chanmon_cfgs(2);