@@ -2470,6 +2470,9 @@ pub struct PassAlongPathArgs<'a, 'b, 'c, 'd> {
2470
2470
pub clear_recipient_events : bool ,
2471
2471
pub expected_preimage : Option < PaymentPreimage > ,
2472
2472
pub is_probe : bool ,
2473
+ // Allow overpayment to the recipient up to this amount. Useful for payments to blinded paths
2474
+ // where rounding errors during `BlindedPayInfo` aggregation may result in overpayment.
2475
+ pub overpay_limit : u64 ,
2473
2476
}
2474
2477
2475
2478
impl < ' a , ' b , ' c , ' d > PassAlongPathArgs < ' a , ' b , ' c , ' d > {
@@ -2480,7 +2483,7 @@ impl<'a, 'b, 'c, 'd> PassAlongPathArgs<'a, 'b, 'c, 'd> {
2480
2483
Self {
2481
2484
origin_node, expected_path, recv_value, payment_hash, payment_secret : None , event,
2482
2485
payment_claimable_expected : true , clear_recipient_events : true , expected_preimage : None ,
2483
- is_probe : false ,
2486
+ is_probe : false , overpay_limit : 0 ,
2484
2487
}
2485
2488
}
2486
2489
pub fn clear_recipient_events ( mut self , clear_recipient_events : bool ) -> Self {
@@ -2504,13 +2507,17 @@ impl<'a, 'b, 'c, 'd> PassAlongPathArgs<'a, 'b, 'c, 'd> {
2504
2507
self . expected_preimage = Some ( payment_preimage) ;
2505
2508
self
2506
2509
}
2510
+ pub fn with_overpay_limit ( mut self , overpay_limit : u64 ) -> Self {
2511
+ self . overpay_limit = overpay_limit;
2512
+ self
2513
+ }
2507
2514
}
2508
2515
2509
2516
pub fn do_pass_along_path < ' a , ' b , ' c > ( args : PassAlongPathArgs ) -> Option < Event > {
2510
2517
let PassAlongPathArgs {
2511
2518
origin_node, expected_path, recv_value, payment_hash : our_payment_hash,
2512
2519
payment_secret : our_payment_secret, event : ev, payment_claimable_expected,
2513
- clear_recipient_events, expected_preimage, is_probe
2520
+ clear_recipient_events, expected_preimage, is_probe, overpay_limit ,
2514
2521
} = args;
2515
2522
2516
2523
let mut payment_event = SendEvent :: from_event ( ev) ;
@@ -2554,7 +2561,8 @@ pub fn do_pass_along_path<'a, 'b, 'c>(args: PassAlongPathArgs) -> Option<Event>
2554
2561
assert_eq ! ( our_payment_secret, onion_fields. as_ref( ) . unwrap( ) . payment_secret) ;
2555
2562
} ,
2556
2563
}
2557
- assert_eq ! ( * amount_msat, recv_value) ;
2564
+ assert ! ( * amount_msat >= recv_value) ;
2565
+ assert ! ( * amount_msat <= recv_value + overpay_limit) ;
2558
2566
assert ! ( node. node. list_channels( ) . iter( ) . any( |details| details. channel_id == via_channel_id. unwrap( ) ) ) ;
2559
2567
assert ! ( node. node. list_channels( ) . iter( ) . any( |details| details. user_channel_id == via_user_channel_id. unwrap( ) ) ) ;
2560
2568
assert ! ( claim_deadline. unwrap( ) > node. best_block_info( ) . 1 ) ;
0 commit comments