Rustfmt touch ups

Author: joostjager

lightning/src/ln/channel.rs

@@ -6220,10 +6220,9 @@ where
 		let mut htlc_value_msat = 0;
 		for (idx, htlc) in self.context.pending_inbound_htlcs.iter().enumerate() {
 			if htlc.htlc_id == htlc_id_arg {
-				debug_assert_eq!(
-					htlc.payment_hash,
-					PaymentHash(Sha256::hash(&payment_preimage_arg.0[..]).to_byte_array())
-				);
+				let expected_hash =
+					PaymentHash(Sha256::hash(&payment_preimage_arg.0[..]).to_byte_array());
+				debug_assert_eq!(htlc.payment_hash, expected_hash);
 				log_debug!(
 					logger,
 					"Claiming inbound HTLC id {} with payment hash {} with preimage {}",
@@ -6377,10 +6376,8 @@ where
 					self.context.latest_monitor_update_id = monitor_update.update_id;
 					monitor_update.updates.append(&mut additional_update.updates);
 				} else {
-					let new_mon_id = self
-						.context
-						.blocked_monitor_updates
-						.get(0)
+					let blocked_upd = self.context.blocked_monitor_updates.get(0);
+					let new_mon_id = blocked_upd
 						.map(|upd| upd.update.update_id)
 						.unwrap_or(monitor_update.update_id);
 					monitor_update.update_id = new_mon_id;
@@ -6712,11 +6709,9 @@ where
 			));
 		}
 
-		self.mark_outbound_htlc_removed(
-			msg.htlc_id,
-			OutboundHTLCOutcome::Success(msg.payment_preimage),
-		)
-		.map(|htlc| (htlc.source.clone(), htlc.amount_msat, htlc.skimmed_fee_msat))
+		let outcome = OutboundHTLCOutcome::Success(msg.payment_preimage);
+		self.mark_outbound_htlc_removed(msg.htlc_id, outcome)
+			.map(|htlc| (htlc.source.clone(), htlc.amount_msat, htlc.skimmed_fee_msat))
 	}
 
 	#[rustfmt::skip]
@@ -12465,12 +12460,8 @@ where
 
 		// Write out the old serialization for shutdown_pubkey for backwards compatibility, if
 		// deserialized from that format.
-		match self
-			.context
-			.shutdown_scriptpubkey
-			.as_ref()
-			.and_then(|script| script.as_legacy_pubkey())
-		{
+		let shutdown_scriptpubkey = self.context.shutdown_scriptpubkey.as_ref();
+		match shutdown_scriptpubkey.and_then(|script| script.as_legacy_pubkey()) {
 			Some(shutdown_pubkey) => shutdown_pubkey.write(writer)?,
 			None => [0u8; PUBLIC_KEY_SIZE].write(writer)?,
 		}
@@ -12749,11 +12740,11 @@ where
 		// the default, and when `holder_max_htlc_value_in_flight_msat` is configured to be set to
 		// a different percentage of the channel value then 10%, which older versions of LDK used
 		// to set it to before the percentage was made configurable.
+		let legacy_reserve_satoshis = get_legacy_default_holder_selected_channel_reserve_satoshis(
+			self.funding.get_value_satoshis(),
+		);
 		let serialized_holder_selected_reserve =
-			if self.funding.holder_selected_channel_reserve_satoshis
-				!= get_legacy_default_holder_selected_channel_reserve_satoshis(
-					self.funding.get_value_satoshis(),
-				) {
+			if self.funding.holder_selected_channel_reserve_satoshis != legacy_reserve_satoshis {
 				Some(self.funding.holder_selected_channel_reserve_satoshis)
 			} else {
 				None
@@ -12762,12 +12753,12 @@ where
 		let mut old_max_in_flight_percent_config = UserConfig::default().channel_handshake_config;
 		old_max_in_flight_percent_config.max_inbound_htlc_value_in_flight_percent_of_channel =
 			MAX_IN_FLIGHT_PERCENT_LEGACY;
+		let max_in_flight_msat = get_holder_max_htlc_value_in_flight_msat(
+			self.funding.get_value_satoshis(),
+			&old_max_in_flight_percent_config,
+		);
 		let serialized_holder_htlc_max_in_flight =
-			if self.context.holder_max_htlc_value_in_flight_msat
-				!= get_holder_max_htlc_value_in_flight_msat(
-					self.funding.get_value_satoshis(),
-					&old_max_in_flight_percent_config,
-				) {
+			if self.context.holder_max_htlc_value_in_flight_msat != max_in_flight_msat {
 				Some(self.context.holder_max_htlc_value_in_flight_msat)
 			} else {
 				None
@@ -14262,16 +14253,17 @@ mod tests {
 			&logger,
 		)
 		.unwrap();
+		let open_channel_msg = &outbound_chan
+			.get_open_channel(ChainHash::using_genesis_block(network), &&logger)
+			.unwrap();
 		let mut inbound_chan = InboundV1Channel::<&TestKeysInterface>::new(
 			&feeest,
 			&&keys_provider,
 			&&keys_provider,
 			node_b_node_id,
 			&channelmanager::provided_channel_type_features(&config),
 			&features,
-			&outbound_chan
-				.get_open_channel(ChainHash::using_genesis_block(network), &&logger)
-				.unwrap(),
+			open_channel_msg,
 			7,
 			&config,
 			0,

lightning/src/ln/channelmanager.rs

@@ -15025,13 +15025,9 @@ where
 					}
 
 					for short_channel_id in channel.context.historical_scids() {
-						short_to_chan_info.insert(
-							*short_channel_id,
-							(
-								channel.context.get_counterparty_node_id(),
-								channel.context.channel_id(),
-							),
-						);
+						let cp_id = channel.context.get_counterparty_node_id();
+						let chan_id = channel.context.channel_id();
+						short_to_chan_info.insert(*short_channel_id, (cp_id, chan_id));
 					}
 
 					per_peer_state
@@ -15865,10 +15861,8 @@ where
 					.into_iter()
 					.zip(onion_fields.into_iter().zip(claimable_htlcs_list.into_iter()))
 				{
-					let existing_payment = claimable_payments.insert(
-						payment_hash,
-						ClaimablePayment { purpose, htlcs, onion_fields: onion },
-					);
+					let claimable = ClaimablePayment { purpose, htlcs, onion_fields: onion };
+					let existing_payment = claimable_payments.insert(payment_hash, claimable);
 					if existing_payment.is_some() {
 						return Err(DecodeError::InvalidValue);
 					}
@@ -15877,10 +15871,8 @@ where
 				for (purpose, (payment_hash, htlcs)) in
 					purposes.into_iter().zip(claimable_htlcs_list.into_iter())
 				{
-					let existing_payment = claimable_payments.insert(
-						payment_hash,
-						ClaimablePayment { purpose, htlcs, onion_fields: None },
-					);
+					let claimable = ClaimablePayment { purpose, htlcs, onion_fields: None };
+					let existing_payment = claimable_payments.insert(payment_hash, claimable);
 					if existing_payment.is_some() {
 						return Err(DecodeError::InvalidValue);
 					}
@@ -16001,13 +15993,9 @@ where
 						return Err(DecodeError::InvalidValue);
 					}
 					if funded_chan.context.is_usable() {
-						if short_to_chan_info
-							.insert(
-								funded_chan.context.outbound_scid_alias(),
-								(funded_chan.context.get_counterparty_node_id(), *chan_id),
-							)
-							.is_some()
-						{
+						let alias = funded_chan.context.outbound_scid_alias();
+						let cp_id = funded_chan.context.get_counterparty_node_id();
+						if short_to_chan_info.insert(alias, (cp_id, *chan_id)).is_some() {
 							// Note that in rare cases its possible to hit this while reading an older
 							// channel if we just happened to pick a colliding outbound alias above.
 							log_error!(
@@ -16396,21 +16384,17 @@ where
 						let mut pending_events = channel_manager.pending_events.lock().unwrap();
 						let payment_id =
 							payment.inbound_payment_id(&inbound_payment_id_secret.unwrap());
+						let htlcs = payment.htlcs.iter().map(events::ClaimedHTLC::from).collect();
+						let sender_intended_total_msat =
+							payment.htlcs.first().map(|htlc| htlc.total_msat);
 						pending_events.push_back((
 							events::Event::PaymentClaimed {
 								receiver_node_id,
 								payment_hash,
 								purpose: payment.purpose,
 								amount_msat: claimable_amt_msat,
-								htlcs: payment
-									.htlcs
-									.iter()
-									.map(events::ClaimedHTLC::from)
-									.collect(),
-								sender_intended_total_msat: payment
-									.htlcs
-									.first()
-									.map(|htlc| htlc.total_msat),
+								htlcs,
+								sender_intended_total_msat,
 								onion_fields: payment.onion_fields,
 								payment_id: Some(payment_id),
 							},