Skip to content

Commit 59fa1ff

Browse files
committed
Add BOLT 12 Refunds section to ChannelManager docs
1 parent 7a99f6b commit 59fa1ff

File tree

1 file changed

+96
-0
lines changed

1 file changed

+96
-0
lines changed

lightning/src/ln/channelmanager.rs

+96
Original file line numberDiff line numberDiff line change
@@ -1583,6 +1583,100 @@ where
15831583
/// # }
15841584
/// ```
15851585
///
1586+
/// ## BOLT 12 Refunds
1587+
///
1588+
/// A [`Refund`] is a request for an invoice to be paid. Like *paying* for an [`Offer`], *creating*
1589+
/// a [`Refund`] involves maintaining state since it represents a future outbound payment.
1590+
/// Therefore, use [`create_refund_builder`] when creating one, otherwise [`ChannelManager`] will
1591+
/// refuse to pay any corresponding [`Bolt12Invoice`] that it receives.
1592+
///
1593+
/// ```
1594+
/// # use core::time::Duration;
1595+
/// # use lightning::events::{Event, EventsProvider};
1596+
/// # use lightning::ln::channelmanager::{AChannelManager, PaymentId, RecentPaymentDetails, Retry};
1597+
/// # use lightning::offers::parse::Bolt12SemanticError;
1598+
/// #
1599+
/// # fn example<T: AChannelManager>(
1600+
/// # channel_manager: T, amount_msats: u64, absolute_expiry: Duration,
1601+
/// # max_total_routing_fee_msat: Option<u64>
1602+
/// # ) -> Result<(), Bolt12SemanticError> {
1603+
/// # let channel_manager = channel_manager.get_cm();
1604+
/// let payment_id = PaymentId([42; 32]);
1605+
/// let retry = Retry::Timeout(Duration::from_secs(60));
1606+
/// let refund = channel_manager
1607+
/// .create_refund_builder(
1608+
/// "coffee".to_string(), amount_msats, absolute_expiry, payment_id, retry,
1609+
/// max_total_routing_fee_msat
1610+
/// )?
1611+
/// .payer_note("refund for order 1234".to_string())
1612+
/// .build()?;
1613+
/// let bech32_refund = refund.to_string();
1614+
///
1615+
/// // First the payment will be waiting on an invoice
1616+
/// let expected_payment_id = payment_id;
1617+
/// assert!(
1618+
/// channel_manager.list_recent_payments().iter().find(|details| matches!(
1619+
/// details,
1620+
/// RecentPaymentDetails::AwaitingInvoice { payment_id: expected_payment_id }
1621+
/// )).is_some()
1622+
/// );
1623+
///
1624+
/// // Once the invoice is received, a payment will be sent
1625+
/// assert!(
1626+
/// channel_manager.list_recent_payments().iter().find(|details| matches!(
1627+
/// details,
1628+
/// RecentPaymentDetails::Pending { payment_id: expected_payment_id, .. }
1629+
/// )).is_some()
1630+
/// );
1631+
///
1632+
/// // On the event processing thread
1633+
/// channel_manager.process_pending_events(&|event| match event {
1634+
/// Event::PaymentSent { payment_id: Some(payment_id), .. } => println!("Paid {}", payment_id),
1635+
/// Event::PaymentFailed { payment_id, .. } => println!("Failed paying {}", payment_id),
1636+
/// // ...
1637+
/// # _ => {},
1638+
/// });
1639+
/// # Ok(())
1640+
/// # }
1641+
/// ```
1642+
///
1643+
/// Use [`request_refund_payment`] to send a [`Bolt12Invoice`] for receiving the refund. Similar to
1644+
/// *creating* an [`Offer`], this is stateless as it represents an inbound payment.
1645+
///
1646+
/// ```
1647+
/// # use lightning::events::{Event, EventsProvider, PaymentPurpose};
1648+
/// # use lightning::ln::channelmanager::AChannelManager;
1649+
/// # use lightning::offers::refund::Refund;
1650+
/// #
1651+
/// # fn example<T: AChannelManager>(channel_manager: T, refund: &Refund) {
1652+
/// # let channel_manager = channel_manager.get_cm();
1653+
/// match channel_manager.request_refund_payment(refund) {
1654+
/// Ok(()) => println!("Requesting payment for refund"),
1655+
/// Err(e) => println!("Unable to request payment for refund: {:?}", e),
1656+
/// }
1657+
///
1658+
/// // On the event processing thread
1659+
/// channel_manager.process_pending_events(&|event| match event {
1660+
/// Event::PaymentClaimable { payment_hash, purpose, .. } => match purpose {
1661+
/// PaymentPurpose::InvoicePayment { payment_preimage: Some(payment_preimage), .. } => {
1662+
/// println!("Claiming payment {}", payment_hash);
1663+
/// channel_manager.claim_funds(payment_preimage);
1664+
/// },
1665+
/// PaymentPurpose::InvoicePayment { payment_preimage: None, .. } => {
1666+
/// println!("Unknown payment hash: {}", payment_hash);
1667+
/// },
1668+
/// // ...
1669+
/// # _ => {},
1670+
/// },
1671+
/// Event::PaymentClaimed { payment_hash, amount_msat, .. } => {
1672+
/// println!("Claimed {} msats", amount_msat);
1673+
/// },
1674+
/// // ...
1675+
/// # _ => {},
1676+
/// });
1677+
/// # }
1678+
/// ```
1679+
///
15861680
/// # Persistence
15871681
///
15881682
/// Implements [`Writeable`] to write out all channel state to disk. Implies [`peer_disconnected`] for
@@ -1662,6 +1756,8 @@ where
16621756
/// [`create_offer_builder`]: Self::create_offer_builder
16631757
/// [`pay_for_offer`]: Self::pay_for_offer
16641758
/// [`InvoiceRequest`]: crate::offers::invoice_request::InvoiceRequest
1759+
/// [`create_refund_builder`]: Self::create_refund_builder
1760+
/// [`request_refund_payment`]: Self::request_refund_payment
16651761
/// [`peer_disconnected`]: msgs::ChannelMessageHandler::peer_disconnected
16661762
/// [`funding_created`]: msgs::FundingCreated
16671763
/// [`funding_transaction_generated`]: Self::funding_transaction_generated

0 commit comments

Comments
 (0)