@@ -5492,7 +5492,7 @@ where
54925492	}
54935493
54945494	fn claim_funds_internal(&self, source: HTLCSource, payment_preimage: PaymentPreimage,
5495- 		forwarded_htlc_value_msat: Option<u64>, from_onchain: bool,
5495+ 		forwarded_htlc_value_msat: Option<u64>, from_onchain: bool, startup_replay: bool, 
54965496		next_channel_counterparty_node_id: Option<PublicKey>, next_channel_outpoint: OutPoint
54975497	) {
54985498		match source {
@@ -6410,7 +6410,7 @@ where
64106410				hash_map::Entry::Vacant(_) => return Err(MsgHandleErrInternal::send_err_msg_no_close(format!("Got a message for a channel from the wrong node! No such channel for the passed counterparty_node_id {}", counterparty_node_id), msg.channel_id))
64116411			}
64126412		};
6413- 		self.claim_funds_internal(htlc_source, msg.payment_preimage.clone(), Some(forwarded_htlc_value), false, Some(*counterparty_node_id), funding_txo);
6413+ 		self.claim_funds_internal(htlc_source, msg.payment_preimage.clone(), Some(forwarded_htlc_value), false, false,  Some(*counterparty_node_id), funding_txo);
64146414		Ok(())
64156415	}
64166416
@@ -6863,7 +6863,7 @@ where
68636863					MonitorEvent::HTLCEvent(htlc_update) => {
68646864						if let Some(preimage) = htlc_update.payment_preimage {
68656865							log_trace!(self.logger, "Claiming HTLC with preimage {} from our monitor", preimage);
6866- 							self.claim_funds_internal(htlc_update.source, preimage, htlc_update.htlc_value_satoshis.map(|v| v * 1000), true, counterparty_node_id, funding_outpoint);
6866+ 							self.claim_funds_internal(htlc_update.source, preimage, htlc_update.htlc_value_satoshis.map(|v| v * 1000), true, false,  counterparty_node_id, funding_outpoint);
68676867						} else {
68686868							log_trace!(self.logger, "Failing HTLC with hash {} from our monitor", &htlc_update.payment_hash);
68696869							let receiver = HTLCDestination::NextHopChannel { node_id: counterparty_node_id, channel_id: funding_outpoint.to_channel_id() };
@@ -10059,7 +10059,7 @@ where
1005910059			// don't remember in the `ChannelMonitor` where we got a preimage from, but if the
1006010060			// channel is closed we just assume that it probably came from an on-chain claim.
1006110061			channel_manager.claim_funds_internal(source, preimage, Some(downstream_value),
10062- 				downstream_closed, downstream_node_id, downstream_funding);
10062+ 				downstream_closed, true,  downstream_node_id, downstream_funding);
1006310063		}
1006410064
1006510065		//TODO: Broadcast channel update for closed channels, but only after we've made a
0 commit comments