test: Add test coverage

lightning/src/ln/channelmanager.rs

@@ -11353,6 +11353,78 @@ mod tests {
 		}
 	}
 
+	fn do_test_peer_disconnect_just_before_create_channel(reconnect_on_time: bool) {
+		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);
+
+		// Create a channel to prevent removal of peer when disconnected.
+		let _ = create_announced_chan_between_nodes(&nodes, 0, 1);
+
+		// Disconnect Peers
+		nodes[0].node.peer_disconnected(&nodes[1].node.get_our_node_id());
+		nodes[1].node.peer_disconnected(&nodes[0].node.get_our_node_id());
+
+		// Call create_channel from node_0 to node_1
+		let _chan_id = nodes[0].node.create_channel(nodes[1].node.get_our_node_id(), 100000, 10001, 42, None).unwrap();
+
+		// Accquire the peer state from node_0 perspective
+		let nodes_0_per_peer_state = nodes[0].node.per_peer_state.read().unwrap();
+		let per_state_mutex = nodes_0_per_peer_state.get(&nodes[1].node.get_our_node_id()).unwrap();
+		let peer_state = per_state_mutex.lock().unwrap();
+
+		// Check that SendOpenChannel message is not added to pending_msg_events
+		assert_eq!(peer_state.pending_msg_events.len(), 0);
+
+		// Check that the number of channels from node_0 to node_1 is two: from previously created channel and the unsend channel
+		assert_eq!(peer_state.channel_by_id.len(), 2);
+
+		// Simulate not reconnected on time by ticking the timer
+		if !reconnect_on_time {
+			// Run timer twice
+			nodes[0].node.timer_tick_occurred();
+			nodes[0].node.timer_tick_occurred();
+		}
+		// If not reconnected on time..
+		if !reconnect_on_time {
+			// the pending_msg_events should not contain SendOpenChannel msg
+			assert_eq!(peer_state.pending_msg_events.len(), 0);
+			// And the number of channels from node_0 perspective should be reduced to 1
+			assert_eq!(peer_state.channel_by_id.len(), 1);
+		}
+
+		// TODO: Make the test part for reconnect work.
+		// // Now Reconnect
+		// {
+		// 	nodes[0].node.peer_connected(&nodes[1].node.get_our_node_id(), &msgs::Init {
+		// 		features: nodes[1].node.init_features(), networks: None, remote_network_address: None
+		// 	}, true).unwrap();
+		// 	let reestablish_1 = get_chan_reestablish_msgs!(nodes[0], nodes[1]);
+		// 	assert_eq!(reestablish_1.len(), 1);
+		// 	nodes[1].node.peer_connected(&nodes[0].node.get_our_node_id(), &msgs::Init {
+		// 		features: nodes[0].node.init_features(), networks: None, remote_network_address: None
+		// 	}, false).unwrap();
+		// 	let reestablish_2 = get_chan_reestablish_msgs!(nodes[1], nodes[0]);
+		// 	assert_eq!(reestablish_2.len(), 1);
+		// }
+
+		// // If reconnected on time..
+		// if reconnect_on_time {
+		// 	// the pending_msg_events should contain SendOpenChannel msg
+		// 	assert_eq!(peer_state.pending_msg_events.len(), 1);
+		// 	// the number of channels from node_0 perspective should be 2
+		// 	assert_eq!(peer_state.channel_by_id.len(), 2);
+		// }
+
+	}
+
+	#[test]
+	fn test_peer_disconnect_just_before_create_channel() {
+		// do_test_peer_disconnect_just_before_create_channel(false);
+		do_test_peer_disconnect_just_before_create_channel(true);
+	}
+
 	#[test]
 	fn bad_inbound_payment_hash() {
 		// Add coverage for checking that a user-provided payment hash matches the payment secret.