Add txid to on-chain event tracking

When using Electrum, transactions are individually unconfirmed during a
reorg rather than by block. Store the txid of the transaction creating
the on-chain event so that it can be used to determine which events need
to be removed when a transaction is unconfirmed.

Author: jkczyz

lightning/src/chain/channelmonitor.rs

@@ -468,6 +468,7 @@ pub(crate) struct ClaimRequest {
 /// TODO: Write docs
 #[derive(PartialEq)]
 struct OnchainEventEntry {
+	txid: Txid,
 	height: u32,
 	event: OnchainEvent,
 }
@@ -954,6 +955,7 @@ impl<Signer: Sign> Writeable for ChannelMonitorImpl<Signer> {
 
 		writer.write_all(&byte_utils::be64_to_array(self.onchain_events_waiting_threshold_conf.len() as u64))?;
 		for ref entry in self.onchain_events_waiting_threshold_conf.iter() {
+			entry.txid.write(writer)?;
 			writer.write_all(&byte_utils::be32_to_array(entry.height))?;
 			match entry.event {
 				OnchainEvent::HTLCUpdate { ref htlc_update } => {
@@ -1665,6 +1667,7 @@ impl<Signer: Sign> ChannelMonitorImpl<Signer> {
 										}
 									});
 									let entry = OnchainEventEntry {
+										txid: *$txid,
 										height,
 										event: OnchainEvent::HTLCUpdate {
 											htlc_update: ((**source).clone(), htlc.payment_hash.clone())
@@ -1730,6 +1733,7 @@ impl<Signer: Sign> ChannelMonitorImpl<Signer> {
 									}
 								});
 								self.onchain_events_waiting_threshold_conf.push(OnchainEventEntry {
+									txid: *$txid,
 									height,
 									event: OnchainEvent::HTLCUpdate {
 										htlc_update: ((**source).clone(), htlc.payment_hash.clone())
@@ -1885,6 +1889,7 @@ impl<Signer: Sign> ChannelMonitorImpl<Signer> {
 					}
 				});
 				let entry = OnchainEventEntry {
+					txid: commitment_txid,
 					height,
 					event: OnchainEvent::HTLCUpdate { htlc_update: ($source, $payment_hash) },
 				};
@@ -2368,6 +2373,7 @@ impl<Signer: Sign> ChannelMonitorImpl<Signer> {
 						}
 					});
 					let entry = OnchainEventEntry {
+						txid: tx.txid(),
 						height,
 						event: OnchainEvent::HTLCUpdate { htlc_update: (source, payment_hash) },
 					};
@@ -2432,6 +2438,7 @@ impl<Signer: Sign> ChannelMonitorImpl<Signer> {
 		}
 		if let Some(spendable_output) = spendable_output {
 			let entry = OnchainEventEntry {
+				txid: tx.txid(),
 				height: height,
 				event: OnchainEvent::MaturingOutput { descriptor: spendable_output.clone() },
 			};
@@ -2704,6 +2711,7 @@ impl<'a, Signer: Sign, K: KeysInterface<Signer = Signer>> ReadableArgs<&'a K>
 		let waiting_threshold_conf_len: u64 = Readable::read(reader)?;
 		let mut onchain_events_waiting_threshold_conf = Vec::with_capacity(cmp::min(waiting_threshold_conf_len as usize, MAX_ALLOC_SIZE / 128));
 		for _ in 0..waiting_threshold_conf_len {
+			let txid = Readable::read(reader)?;
 			let height = Readable::read(reader)?;
 			let event = match <u8 as Readable>::read(reader)? {
 				0 => {
@@ -2721,7 +2729,7 @@ impl<'a, Signer: Sign, K: KeysInterface<Signer = Signer>> ReadableArgs<&'a K>
 				},
 				_ => return Err(DecodeError::InvalidValue),
 			};
-			onchain_events_waiting_threshold_conf.push(OnchainEventEntry { height, event });
+			onchain_events_waiting_threshold_conf.push(OnchainEventEntry { txid, height, event });
 		}
 
 		let outputs_to_watch_len: u64 = Readable::read(reader)?;

lightning/src/ln/onchaintx.rs

@@ -42,6 +42,7 @@ const MAX_ALLOC_SIZE: usize = 64*1024;
 /// TODO: Write docs
 #[derive(PartialEq)]
 struct OnchainEventEntry {
+	txid: Txid,
 	height: u32,
 	event: OnchainEvent,
 }
@@ -336,6 +337,7 @@ impl<ChannelSigner: Sign> OnchainTxHandler<ChannelSigner> {
 
 		writer.write_all(&byte_utils::be64_to_array(self.onchain_events_waiting_threshold_conf.len() as u64))?;
 		for ref entry in self.onchain_events_waiting_threshold_conf.iter() {
+			entry.txid.write(writer)?;
 			writer.write_all(&byte_utils::be32_to_array(entry.height))?;
 			match entry.event {
 				OnchainEvent::Claim { ref claim_request } => {
@@ -393,6 +395,7 @@ impl<'a, K: KeysInterface> ReadableArgs<&'a K> for OnchainTxHandler<K::Signer> {
 		let waiting_threshold_conf_len: u64 = Readable::read(reader)?;
 		let mut onchain_events_waiting_threshold_conf = Vec::with_capacity(cmp::min(waiting_threshold_conf_len as usize, MAX_ALLOC_SIZE / 128));
 		for _ in 0..waiting_threshold_conf_len {
+			let txid = Readable::read(reader)?;
 			let height = Readable::read(reader)?;
 			let event = match <u8 as Readable>::read(reader)? {
 				0 => {
@@ -411,7 +414,7 @@ impl<'a, K: KeysInterface> ReadableArgs<&'a K> for OnchainTxHandler<K::Signer> {
 				}
 				_ => return Err(DecodeError::InvalidValue),
 			};
-			onchain_events_waiting_threshold_conf.push(OnchainEventEntry { height, event });
+			onchain_events_waiting_threshold_conf.push(OnchainEventEntry { txid, height, event });
 		}
 		let latest_height = Readable::read(reader)?;
 
@@ -766,6 +769,7 @@ impl<ChannelSigner: Sign> OnchainTxHandler<ChannelSigner> {
 						macro_rules! clean_claim_request_after_safety_delay {
 							() => {
 								let entry = OnchainEventEntry {
+									txid: tx.txid(),
 									height,
 									event: OnchainEvent::Claim { claim_request: first_claim_txid_height.0.clone() }
 								};
@@ -805,6 +809,7 @@ impl<ChannelSigner: Sign> OnchainTxHandler<ChannelSigner> {
 			}
 			for (outpoint, input_material) in claimed_outputs_material.drain(..) {
 				let entry = OnchainEventEntry {
+					txid: tx.txid(),
 					height,
 					event: OnchainEvent::ContentiousOutpoint { outpoint, input_material },
 				};