From: Antoine Riard <dev@ariard.me>
Date: Tue, 13 Jul 2021 16:55:32 +0000 (-0400)
Subject: Extend MsgHandleErrInternal with a new chan_id field Option<[u8; 32]>
X-Git-Url: http://git.bitcoin.ninja/?a=commitdiff_plain;h=4f5ac107c4a06e7f9a4089a37a955567c9bdfc27;p=rust-lightning

Extend MsgHandleErrInternal with a new chan_id field Option<[u8; 32]>

This field is used in next commit to generate appropriate
ChannelClosed event at `handle_error()` processing.
---

diff --git a/lightning/src/ln/channelmanager.rs b/lightning/src/ln/channelmanager.rs
index 46cbaac32..dccca13ff 100644
--- a/lightning/src/ln/channelmanager.rs
+++ b/lightning/src/ln/channelmanager.rs
@@ -242,6 +242,7 @@ type ShutdownResult = (Option<(OutPoint, ChannelMonitorUpdate)>, Vec<(HTLCSource
 
 struct MsgHandleErrInternal {
 	err: msgs::LightningError,
+	chan_id: Option<[u8; 32]>,
 	shutdown_finish: Option<(ShutdownResult, Option<msgs::ChannelUpdate>)>,
 }
 impl MsgHandleErrInternal {
@@ -257,6 +258,7 @@ impl MsgHandleErrInternal {
 					},
 				},
 			},
+			chan_id: Some(channel_id),
 			shutdown_finish: None,
 		}
 	}
@@ -267,12 +269,13 @@ impl MsgHandleErrInternal {
 				err,
 				action: msgs::ErrorAction::IgnoreError,
 			},
+			chan_id: None,
 			shutdown_finish: None,
 		}
 	}
 	#[inline]
 	fn from_no_close(err: msgs::LightningError) -> Self {
-		Self { err, shutdown_finish: None }
+		Self { err, chan_id: None, shutdown_finish: None }
 	}
 	#[inline]
 	fn from_finish_shutdown(err: String, channel_id: [u8; 32], shutdown_res: ShutdownResult, channel_update: Option<msgs::ChannelUpdate>) -> Self {
@@ -286,6 +289,7 @@ impl MsgHandleErrInternal {
 					},
 				},
 			},
+			chan_id: Some(channel_id),
 			shutdown_finish: Some((shutdown_res, channel_update)),
 		}
 	}
@@ -320,6 +324,7 @@ impl MsgHandleErrInternal {
 					},
 				},
 			},
+			chan_id: Some(channel_id),
 			shutdown_finish: None,
 		}
 	}
@@ -813,7 +818,7 @@ macro_rules! handle_error {
 	($self: ident, $internal: expr, $counterparty_node_id: expr) => {
 		match $internal {
 			Ok(msg) => Ok(msg),
-			Err(MsgHandleErrInternal { err, shutdown_finish }) => {
+			Err(MsgHandleErrInternal { err, chan_id, shutdown_finish }) => {
 				#[cfg(debug_assertions)]
 				{
 					// In testing, ensure there are no deadlocks where the lock is already held upon