@@ -3491,21 +3491,40 @@ where
3491
3491
/// [`events::Event::PaymentClaimed`] events even for payments you intend to fail, especially on
3492
3492
/// startup during which time claims that were in-progress at shutdown may be replayed.
3493
3493
pub fn fail_htlc_backwards ( & self , payment_hash : & PaymentHash ) {
3494
+ self . fail_htlc_backwards_with_reason ( payment_hash, & FailureCode :: IncorrectOrUnknownPaymentDetails ) ;
3495
+ }
3496
+
3497
+ /// This is a variant of [`ChannelManager::fail_htlc_backwards`] that allows you to specify the
3498
+ /// reason for the failure.
3499
+ ///
3500
+ /// See [`FailureCode`] for valid failure codes.
3501
+ pub fn fail_htlc_backwards_with_reason ( & self , payment_hash : & PaymentHash , failure_code : & FailureCode ) {
3494
3502
let _persistence_guard = PersistenceNotifierGuard :: notify_on_drop ( & self . total_consistency_lock , & self . persistence_notifier ) ;
3495
3503
3496
3504
let removed_source = self . claimable_payments . lock ( ) . unwrap ( ) . claimable_htlcs . remove ( payment_hash) ;
3497
3505
if let Some ( ( _, mut sources) ) = removed_source {
3498
3506
for htlc in sources. drain ( ..) {
3499
- let mut htlc_msat_height_data = htlc. value . to_be_bytes ( ) . to_vec ( ) ;
3500
- htlc_msat_height_data. extend_from_slice ( & self . best_block . read ( ) . unwrap ( ) . height ( ) . to_be_bytes ( ) ) ;
3501
- let source = HTLCSource :: PreviousHopData ( htlc. prev_hop ) ;
3502
- let reason = HTLCFailReason :: reason ( 0x4000 | 15 , htlc_msat_height_data) ;
3507
+ let source = HTLCSource :: PreviousHopData ( htlc. prev_hop . clone ( ) ) ;
3503
3508
let receiver = HTLCDestination :: FailedPayment { payment_hash : * payment_hash } ;
3509
+ let reason = self . get_htlc_fail_reason_from_failure_code ( failure_code, & htlc) ;
3504
3510
self . fail_htlc_backwards_internal ( & source, & payment_hash, & reason, receiver) ;
3505
3511
}
3506
3512
}
3507
3513
}
3508
3514
3515
+ /// Gets error data to form an [`HTLCFailReason`] given a [`FailureCode`] and [`ClaimableHTLC`].
3516
+ fn get_htlc_fail_reason_from_failure_code ( & self , failure_code : & FailureCode , htlc : & ClaimableHTLC ) -> HTLCFailReason {
3517
+ match failure_code {
3518
+ FailureCode :: TemporaryNodeFailure => HTLCFailReason :: from_failure_code ( * failure_code as u16 ) ,
3519
+ FailureCode :: RequiredNodeFeatureMissing => HTLCFailReason :: from_failure_code ( * failure_code as u16 ) ,
3520
+ FailureCode :: IncorrectOrUnknownPaymentDetails => {
3521
+ let mut htlc_msat_height_data = htlc. value . to_be_bytes ( ) . to_vec ( ) ;
3522
+ htlc_msat_height_data. extend_from_slice ( & self . best_block . read ( ) . unwrap ( ) . height ( ) . to_be_bytes ( ) ) ;
3523
+ HTLCFailReason :: reason ( * failure_code as u16 , htlc_msat_height_data)
3524
+ }
3525
+ }
3526
+ }
3527
+
3509
3528
/// Gets an HTLC onion failure code and error data for an `UPDATE` error, given the error code
3510
3529
/// that we want to return and a channel.
3511
3530
///
0 commit comments