@@ -24,7 +24,7 @@ use crate::ln::onion_utils::{DecodedOnionFailure, HTLCFailReason};
2424use  crate :: offers:: invoice:: Bolt12Invoice ; 
2525use  crate :: offers:: invoice_request:: InvoiceRequest ; 
2626use  crate :: offers:: nonce:: Nonce ; 
27- use  crate :: routing:: router:: { BlindedTail ,  InFlightHtlcs ,  Path ,  PaymentParameters ,  Route ,  RouteParameters ,  Router } ; 
27+ use  crate :: routing:: router:: { BlindedTail ,  InFlightHtlcs ,  RouteParametersOverride ,   Path ,  PaymentParameters ,  Route ,  RouteParameters ,  Router } ; 
2828use  crate :: sign:: { EntropySource ,  NodeSigner ,  Recipient } ; 
2929use  crate :: util:: errors:: APIError ; 
3030use  crate :: util:: logger:: Logger ; 
@@ -61,7 +61,11 @@ pub(crate) enum PendingOutboundPayment {
6161	AwaitingInvoice  { 
6262		expiration :  StaleExpiration , 
6363		retry_strategy :  Retry , 
64+ 		// Deprecated: Retained for backward compatibility. 
65+ 		// If set during read, this field overrides `RouteParameters::max_total_routing_fee_msat` 
66+ 		// instead of `RouteParametersOverride::max_total_routing_fee_msat`. 
6467		max_total_routing_fee_msat :  Option < u64 > , 
68+ 		route_params_override :  Option < RouteParametersOverride > , 
6569		retryable_invoice_request :  Option < RetryableInvoiceRequest > 
6670	} , 
6771	// This state will never be persisted to disk because we transition from `AwaitingInvoice` to 
@@ -70,9 +74,10 @@ pub(crate) enum PendingOutboundPayment {
7074	InvoiceReceived  { 
7175		payment_hash :  PaymentHash , 
7276		retry_strategy :  Retry , 
73- 		// Note this field is currently just replicated from AwaitingInvoice but not actually 
74- 		// used anywhere. 
75- 		max_total_routing_fee_msat :  Option < u64 > , 
77+ 		// Currently unused, but replicated from `AwaitingInvoice` to avoid potential 
78+ 		// race conditions where this field might be missing upon reload. It may be required 
79+ 		// for future retries. 
80+ 		route_params_override :  Option < RouteParametersOverride > , 
7681	} , 
7782	// This state applies when we are paying an often-offline recipient and another node on the 
7883	// network served us a static invoice on the recipient's behalf in response to our invoice 
@@ -849,14 +854,16 @@ impl OutboundPayments {
849854		match  self . pending_outbound_payments . lock ( ) . unwrap ( ) . entry ( payment_id)  { 
850855			hash_map:: Entry :: Occupied ( entry)  => match  entry. get ( )  { 
851856				PendingOutboundPayment :: AwaitingInvoice  { 
852- 					retry_strategy :  retry,  max_total_routing_fee_msat :  max_total_fee ,  ..
857+ 					retry_strategy :  retry,  route_params_override ,  ..
853858				}  => { 
854859					retry_strategy = * retry; 
855- 					max_total_routing_fee_msat = * max_total_fee; 
860+ 					max_total_routing_fee_msat = route_params_override. and_then ( 
861+ 						|params| params. max_total_routing_fee_msat 
862+ 					) ; 
856863					* entry. into_mut ( )  = PendingOutboundPayment :: InvoiceReceived  { 
857864						payment_hash, 
858865						retry_strategy :  * retry, 
859- 						max_total_routing_fee_msat , 
866+ 						route_params_override :   * route_params_override , 
860867					} ; 
861868				} , 
862869				_ => return  Err ( Bolt12PaymentError :: DuplicateInvoice ) , 
@@ -1004,7 +1011,7 @@ impl OutboundPayments {
10041011		match  self . pending_outbound_payments . lock ( ) . unwrap ( ) . entry ( payment_id)  { 
10051012			hash_map:: Entry :: Occupied ( mut  entry)  => match  entry. get ( )  { 
10061013				PendingOutboundPayment :: AwaitingInvoice  { 
1007- 					retry_strategy,  retryable_invoice_request,  max_total_routing_fee_msat ,  ..
1014+ 					retry_strategy,  retryable_invoice_request,  route_params_override ,  ..
10081015				}  => { 
10091016					let  invreq = & retryable_invoice_request
10101017						. as_ref ( ) 
@@ -1031,7 +1038,7 @@ impl OutboundPayments {
10311038					let  payment_hash = PaymentHash ( Sha256 :: hash ( & keysend_preimage. 0 ) . to_byte_array ( ) ) ; 
10321039					let  pay_params = PaymentParameters :: from_static_invoice ( invoice) ; 
10331040					let  mut  route_params = RouteParameters :: from_payment_params_and_value ( pay_params,  amount_msat) ; 
1034- 					route_params. max_total_routing_fee_msat  = * max_total_routing_fee_msat; 
1041+ 					route_params. max_total_routing_fee_msat  = route_params_override . map ( |params| params . max_total_routing_fee_msat ) . flatten ( ) ; 
10351042
10361043					if  let  Err ( ( ) )  = onion_utils:: set_max_path_length ( 
10371044						& mut  route_params,  & RecipientOnionFields :: spontaneous_empty ( ) ,  Some ( keysend_preimage) , 
@@ -1599,6 +1606,10 @@ impl OutboundPayments {
15991606		max_total_routing_fee_msat :  Option < u64 > ,  retryable_invoice_request :  Option < RetryableInvoiceRequest > 
16001607	)  -> Result < ( ) ,  ( ) >  { 
16011608		let  mut  pending_outbounds = self . pending_outbound_payments . lock ( ) . unwrap ( ) ; 
1609+ 		let  route_params_override = max_total_routing_fee_msat. map ( 
1610+ 			|fee_msats| RouteParametersOverride :: new ( ) 
1611+ 				. with_max_total_routing_fee_msat ( fee_msats) 
1612+ 		) ; 
16021613		match  pending_outbounds. entry ( payment_id)  { 
16031614			hash_map:: Entry :: Occupied ( _)  => Err ( ( ) ) , 
16041615			hash_map:: Entry :: Vacant ( entry)  => { 
@@ -1608,7 +1619,9 @@ impl OutboundPayments {
16081619				entry. insert ( PendingOutboundPayment :: AwaitingInvoice  { 
16091620					expiration, 
16101621					retry_strategy, 
1611- 					max_total_routing_fee_msat, 
1622+ 					route_params_override, 
1623+ 					// Retained for downgrade support. 
1624+ 					max_total_routing_fee_msat :  None , 
16121625					retryable_invoice_request, 
16131626				} ) ; 
16141627
@@ -2240,11 +2253,12 @@ impl_writeable_tlv_based_enum_upgradable!(PendingOutboundPayment,
22402253		( 2 ,  retry_strategy,  required) , 
22412254		( 4 ,  max_total_routing_fee_msat,  option) , 
22422255		( 5 ,  retryable_invoice_request,  option) , 
2256+ 		( 7 ,  route_params_override,  option) , 
22432257	} , 
22442258	( 7 ,  InvoiceReceived )  => { 
22452259		( 0 ,  payment_hash,  required) , 
22462260		( 2 ,  retry_strategy,  required) , 
2247- 		( 4 ,  max_total_routing_fee_msat ,  option) , 
2261+ 		( 3 ,  route_params_override ,  option) , 
22482262	} , 
22492263	// Added in 0.0.125. Prior versions will drop these outbounds on downgrade, which is safe because 
22502264	// no HTLCs are in-flight. 
0 commit comments