Check unconfirmation of pending funding transactions

When a splice funding transaction is unconfirmed, update the
corresponding FundingScope just as is done when the initial funding
transaction is unconfirmed.

Author: jkczyz

lightning/src/ln/channel.rs

@@ -8711,32 +8711,46 @@ impl<SP: Deref> FundedChannel<SP> where
 		Ok((None, timed_out_htlcs, announcement_sigs))
 	}
 
-	/// Indicates the funding transaction is no longer confirmed in the main chain. This may
+	/// Checks if any funding transaction is no longer confirmed in the main chain. This may
 	/// force-close the channel, but may also indicate a harmless reorganization of a block or two
-	/// before the channel has reached channel_ready and we can just wait for more blocks.
-	pub fn funding_transaction_unconfirmed<L: Deref>(&mut self, logger: &L) -> Result<(), ClosureReason> where L::Target: Logger {
-		if self.funding.funding_tx_confirmation_height != 0 {
-			// We handle the funding disconnection by calling best_block_updated with a height one
-			// below where our funding was connected, implying a reorg back to conf_height - 1.
-			let reorg_height = self.funding.funding_tx_confirmation_height - 1;
-			// We use the time field to bump the current time we set on channel updates if its
-			// larger. If we don't know that time has moved forward, we can just set it to the last
-			// time we saw and it will be ignored.
-			let best_time = self.context.update_time_counter;
-
-			self.funding.funding_tx_confirmation_height = 0;
-
-			match self.do_best_block_updated(reorg_height, best_time, None::<(ChainHash, &&dyn NodeSigner, &UserConfig)>, logger) {
-				Ok((channel_ready, timed_out_htlcs, announcement_sigs)) => {
-					assert!(channel_ready.is_none(), "We can't generate a funding with 0 confirmations?");
-					assert!(timed_out_htlcs.is_empty(), "We can't have accepted HTLCs with a timeout before our funding confirmation?");
-					assert!(announcement_sigs.is_none(), "We can't generate an announcement_sigs with 0 confirmations?");
-					Ok(())
-				},
-				Err(e) => Err(e)
+	/// before the channel has reached channel_ready or splice_locked, and we can just wait for more
+	/// blocks.
+	pub fn transaction_unconfirmed<L: Deref>(
+		&mut self, txid: &Txid, logger: &L,
+	) -> Result<(), ClosureReason>
+	where
+		L::Target: Logger,
+	{
+		let unconfirmed_funding = core::iter::once(&mut self.funding)
+			.chain(self.pending_funding.iter_mut())
+			.find(|funding| funding.get_funding_txid() == Some(*txid));
+
+		if let Some(funding) = unconfirmed_funding {
+			if funding.funding_tx_confirmation_height != 0 {
+				// We handle the funding disconnection by calling best_block_updated with a height one
+				// below where our funding was connected, implying a reorg back to conf_height - 1.
+				let reorg_height = funding.funding_tx_confirmation_height - 1;
+				// We use the time field to bump the current time we set on channel updates if its
+				// larger. If we don't know that time has moved forward, we can just set it to the last
+				// time we saw and it will be ignored.
+				let best_time = self.context.update_time_counter;
+
+				funding.funding_tx_confirmation_height = 0;
+
+				match self.do_best_block_updated(reorg_height, best_time, None::<(ChainHash, &&dyn NodeSigner, &UserConfig)>, logger) {
+					Ok((channel_ready, timed_out_htlcs, announcement_sigs)) => {
+						assert!(channel_ready.is_none(), "We can't generate a funding with 0 confirmations?");
+						assert!(timed_out_htlcs.is_empty(), "We can't have accepted HTLCs with a timeout before our funding confirmation?");
+						assert!(announcement_sigs.is_none(), "We can't generate an announcement_sigs with 0 confirmations?");
+						Ok(())
+					},
+					Err(e) => Err(e),
+				}
+			} else {
+				// We never learned about the funding confirmation anyway, just ignore
+				Ok(())
 			}
 		} else {
-			// We never learned about the funding confirmation anyway, just ignore
 			Ok(())
 		}
 	}

lightning/src/ln/channelmanager.rs

@@ -11689,11 +11689,8 @@ where
 			PersistenceNotifierGuard::optionally_notify_skipping_background_events(
 				self, || -> NotifyOption { NotifyOption::DoPersist });
 		self.do_chain_event(None, |channel| {
-			if let Some(funding_txo) = channel.funding.get_funding_txo() {
-				if funding_txo.txid == *txid {
-					channel.funding_transaction_unconfirmed(&&WithChannelContext::from(&self.logger, &channel.context, None)).map(|()| (None, Vec::new(), None))
-				} else { Ok((None, Vec::new(), None)) }
-			} else { Ok((None, Vec::new(), None)) }
+			let logger = WithChannelContext::from(&self.logger, &channel.context, None);
+			channel.transaction_unconfirmed(txid, &&logger).map(|()| (None, Vec::new(), None))
 		});
 	}
 }