Reintroduce cfg(dual_funding) for handling of open_channel2 messages

Author: dunxen

Cargo.toml

@@ -65,4 +65,5 @@ check-cfg = [
     "cfg(require_route_graph_test)",
     "cfg(splicing)",
     "cfg(async_payments)",
+    "cfg(dual_funding)",
 ]

lightning-net-tokio/src/lib.rs

@@ -742,6 +742,7 @@ mod tests {
 		) {
 		}
 		fn handle_channel_update(&self, _their_node_id: PublicKey, _msg: &ChannelUpdate) {}
+		#[cfg(dual_funding)]
 		fn handle_open_channel_v2(&self, _their_node_id: PublicKey, _msg: &OpenChannelV2) {}
 		fn handle_accept_channel_v2(&self, _their_node_id: PublicKey, _msg: &AcceptChannelV2) {}
 		fn handle_stfu(&self, _their_node_id: PublicKey, _msg: &Stfu) {}

lightning/src/ln/channelmanager.rs

@@ -1376,11 +1376,13 @@ impl <SP: Deref> PeerState<SP> where SP::Target: SignerProvider {
 #[derive(Clone)]
 pub(super) enum OpenChannelMessage {
 	V1(msgs::OpenChannel),
+	#[cfg(dual_funding)]
 	V2(msgs::OpenChannelV2),
 }
 
 pub(super) enum OpenChannelMessageRef<'a> {
 	V1(&'a msgs::OpenChannel),
+	#[cfg(dual_funding)]
 	V2(&'a msgs::OpenChannelV2),
 }
 
@@ -7728,6 +7730,7 @@ where
 							(*temporary_channel_id, ChannelPhase::UnfundedInboundV1(channel), message_send_event)
 						})
 					},
+					#[cfg(dual_funding)]
 					OpenChannelMessage::V2(open_channel_msg) => {
 						InboundV2Channel::new(&self.fee_estimator, &self.entropy_source, &self.signer_provider,
 							self.get_our_node_id(), *counterparty_node_id, &self.channel_type_features(), &peer_state.latest_features,
@@ -7882,6 +7885,7 @@ where
 	fn internal_open_channel(&self, counterparty_node_id: &PublicKey, msg: OpenChannelMessageRef<'_>) -> Result<(), MsgHandleErrInternal> {
 		let common_fields = match msg {
 			OpenChannelMessageRef::V1(msg) => &msg.common_fields,
+			#[cfg(dual_funding)]
 			OpenChannelMessageRef::V2(msg) => &msg.common_fields,
 		};
 
@@ -7959,6 +7963,7 @@ where
 				funding_satoshis: common_fields.funding_satoshis,
 				channel_negotiation_type: match msg {
 					OpenChannelMessageRef::V1(msg) => InboundChannelFunds::PushMsat(msg.push_msat),
+					#[cfg(dual_funding)]
 					OpenChannelMessageRef::V2(_) => InboundChannelFunds::DualFunded,
 				},
 				channel_type,
@@ -7968,6 +7973,7 @@ where
 			peer_state.inbound_channel_request_by_id.insert(channel_id, InboundChannelRequest {
 				open_channel_msg: match msg {
 					OpenChannelMessageRef::V1(msg) => OpenChannelMessage::V1(msg.clone()),
+					#[cfg(dual_funding)]
 					OpenChannelMessageRef::V2(msg) => OpenChannelMessage::V2(msg.clone()),
 				},
 				ticks_remaining: UNACCEPTED_INBOUND_CHANNEL_AGE_LIMIT_TICKS,
@@ -8000,6 +8006,7 @@ where
 				};
 				(ChannelPhase::UnfundedInboundV1(channel), message_send_event)
 			},
+			#[cfg(dual_funding)]
 			OpenChannelMessageRef::V2(msg) => {
 				let channel = InboundV2Channel::new(&self.fee_estimator, &self.entropy_source,
 					&self.signer_provider, self.get_our_node_id(), *counterparty_node_id,
@@ -11269,6 +11276,7 @@ where
 		});
 	}
 
+	#[cfg(dual_funding)]
 	fn handle_open_channel_v2(&self, counterparty_node_id: PublicKey, msg: &msgs::OpenChannelV2) {
 		// Note that we never need to persist the updated ChannelManager for an inbound
 		// open_channel message - pre-funded channels are never written so there should be no

lightning/src/ln/dual_funding_tests.rs

@@ -9,32 +9,36 @@
 
 //! Tests that test the creation of dual-funded channels in ChannelManager.
 
-use bitcoin::Weight;
-
-use crate::chain::chaininterface::{ConfirmationTarget, FeeEstimator, LowerBoundedFeeEstimator};
-use crate::events::{Event, MessageSendEvent, MessageSendEventsProvider};
-use crate::ln::chan_utils::{
-	make_funding_redeemscript, ChannelPublicKeys, ChannelTransactionParameters,
-	CounterpartyChannelTransactionParameters,
-};
-use crate::ln::channel::{
-	calculate_our_funding_satoshis, OutboundV2Channel, MIN_CHAN_DUST_LIMIT_SATOSHIS,
+#[cfg(dual_funding)]
+use {
+	crate::chain::chaininterface::{ConfirmationTarget, FeeEstimator, LowerBoundedFeeEstimator},
+	crate::events::{Event, MessageSendEvent, MessageSendEventsProvider},
+	crate::ln::chan_utils::{
+		make_funding_redeemscript, ChannelPublicKeys, ChannelTransactionParameters,
+		CounterpartyChannelTransactionParameters,
+	},
+	crate::ln::channel::{
+		calculate_our_funding_satoshis, OutboundV2Channel, MIN_CHAN_DUST_LIMIT_SATOSHIS,
+	},
+	crate::ln::channel_keys::{DelayedPaymentBasepoint, HtlcBasepoint, RevocationBasepoint},
+	crate::ln::functional_test_utils::*,
+	crate::ln::msgs::ChannelMessageHandler,
+	crate::ln::msgs::{CommitmentSigned, TxAddInput, TxAddOutput, TxComplete},
+	crate::ln::types::ChannelId,
+	crate::prelude::*,
+	crate::sign::{ChannelSigner as _, P2WPKH_WITNESS_WEIGHT},
+	crate::util::ser::TransactionU16LenLimited,
+	crate::util::test_utils,
+	bitcoin::Weight,
 };
-use crate::ln::channel_keys::{DelayedPaymentBasepoint, HtlcBasepoint, RevocationBasepoint};
-use crate::ln::functional_test_utils::*;
-use crate::ln::msgs::ChannelMessageHandler;
-use crate::ln::msgs::{CommitmentSigned, TxAddInput, TxAddOutput, TxComplete};
-use crate::ln::types::ChannelId;
-use crate::prelude::*;
-use crate::sign::{ChannelSigner as _, P2WPKH_WITNESS_WEIGHT};
-use crate::util::ser::TransactionU16LenLimited;
-use crate::util::test_utils;
 
+#[cfg(dual_funding)]
 // Dual-funding: V2 Channel Establishment Tests
 struct V2ChannelEstablishmentTestSession {
 	initiator_input_value_satoshis: u64,
 }
 
+#[cfg(dual_funding)]
 // TODO(dual_funding): Use real node and API for creating V2 channels as initiator when available,
 // instead of manually constructing messages.
 fn do_test_v2_channel_establishment(
@@ -252,6 +256,7 @@ fn do_test_v2_channel_establishment(
 }
 
 #[test]
+#[cfg(dual_funding)]
 fn test_v2_channel_establishment() {
 	// Only initiator contributes, no persist pending
 	do_test_v2_channel_establishment(

lightning/src/ln/msgs.rs

@@ -1494,6 +1494,7 @@ pub trait ChannelMessageHandler : MessageSendEventsProvider {
 	/// Handle an incoming `open_channel` message from the given peer.
 	fn handle_open_channel(&self, their_node_id: PublicKey, msg: &OpenChannel);
 	/// Handle an incoming `open_channel2` message from the given peer.
+	#[cfg(dual_funding)]
 	fn handle_open_channel_v2(&self, their_node_id: PublicKey, msg: &OpenChannelV2);
 	/// Handle an incoming `accept_channel` message from the given peer.
 	fn handle_accept_channel(&self, their_node_id: PublicKey, msg: &AcceptChannel);

lightning/src/ln/peer_handler.rs

@@ -355,6 +355,7 @@ impl ChannelMessageHandler for ErroringMessageHandler {
 		None
 	}
 
+	#[cfg(dual_funding)]
 	fn handle_open_channel_v2(&self, their_node_id: PublicKey, msg: &msgs::OpenChannelV2) {
 		ErroringMessageHandler::push_error(self, their_node_id, msg.common_fields.temporary_channel_id);
 	}
@@ -1820,8 +1821,9 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
 			wire::Message::OpenChannel(msg) => {
 				self.message_handler.chan_handler.handle_open_channel(their_node_id, &msg);
 			},
-			wire::Message::OpenChannelV2(msg) => {
-				self.message_handler.chan_handler.handle_open_channel_v2(their_node_id, &msg);
+			wire::Message::OpenChannelV2(_msg) => {
+				#[cfg(dual_funding)]
+				self.message_handler.chan_handler.handle_open_channel_v2(their_node_id, &_msg);
 			},
 			wire::Message::AcceptChannel(msg) => {
 				self.message_handler.chan_handler.handle_accept_channel(their_node_id, &msg);

lightning/src/util/test_utils.rs

@@ -872,6 +872,7 @@ impl msgs::ChannelMessageHandler for TestChannelMessageHandler {
 		Some(vec![self.chain_hash])
 	}
 
+	#[cfg(dual_funding)]
 	fn handle_open_channel_v2(&self, _their_node_id: PublicKey, msg: &msgs::OpenChannelV2) {
 		self.received_msg(wire::Message::OpenChannelV2(msg.clone()));
 	}