@@ -64,7 +64,7 @@ use crate::ln::wire::Encode;
64
64
use crate::offers::invoice::{BlindedPayInfo, Bolt12Invoice, DEFAULT_RELATIVE_EXPIRY, DerivedSigningPubkey, ExplicitSigningPubkey, InvoiceBuilder, UnsignedBolt12Invoice};
65
65
use crate::offers::invoice_error::InvoiceError;
66
66
use crate::offers::invoice_request::{DerivedPayerId, InvoiceRequestBuilder};
67
- use crate::offers::offer::{Offer, OfferBuilder};
67
+ use crate::offers::offer::{Offer, OfferBuilder, Amount };
68
68
use crate::offers::parse::Bolt12SemanticError;
69
69
use crate::offers::refund::{Refund, RefundBuilder};
70
70
use crate::onion_message::async_payments::{AsyncPaymentsMessage, HeldHtlcAvailable, ReleaseHeldHtlc, AsyncPaymentsMessageHandler};
@@ -8818,6 +8818,22 @@ where
8818
8818
};
8819
8819
let invoice_request = builder.build_and_sign()?;
8820
8820
8821
+ let total_liquidity: u64 = self.list_usable_channels().iter().map(|channel| channel.next_outbound_htlc_limit_msat).sum();
8822
+ let total_amount_msats = match invoice_request.amount_msats() {
8823
+ Some(amount_msats) => Some(amount_msats),
8824
+ None => match offer.amount() {
8825
+ Some(Amount::Bitcoin { amount_msats }) => Some(amount_msats),
8826
+ _ => None,
8827
+ },
8828
+ };
8829
+
8830
+ if let Some(amount) = total_amount_msats {
8831
+ if amount > total_liquidity {
8832
+ log_error!(self.logger, "Insufficient liquidity for payment with payment id: {}", payment_id);
8833
+ return Err(Bolt12SemanticError::InsufficientLiquidity);
8834
+ }
8835
+ }
8836
+
8821
8837
let context = OffersContext::OutboundPayment { payment_id };
8822
8838
let reply_path = self.create_blinded_path(context).map_err(|_| Bolt12SemanticError::MissingPaths)?;
8823
8839
0 commit comments