Skip to content

Commit e6bb711

Browse files
committed
Add BOLT 12 Refunds section to ChannelManager docs
1 parent 437e007 commit e6bb711

File tree

1 file changed

+95
-0
lines changed

1 file changed

+95
-0
lines changed

lightning/src/ln/channelmanager.rs

+95
Original file line numberDiff line numberDiff line change
@@ -1621,6 +1621,99 @@ where
16211621
/// # }
16221622
/// ```
16231623
///
1624+
/// ## BOLT 12 Refunds
1625+
///
1626+
/// A [`Refund`] is a request for an invoice to be paid. Like *paying* for an [`Offer`], *creating*
1627+
/// a [`Refund`] involves maintaining state since it represents a future outbound payment.
1628+
/// Therefore, use [`create_refund_builder`] when creating one, otherwise [`ChannelManager`] will
1629+
/// refuse to pay any corresponding [`Bolt12Invoice`] that it receives.
1630+
///
1631+
/// ```
1632+
/// # use core::time::Duration;
1633+
/// # use lightning::events::{Event, EventsProvider};
1634+
/// # use lightning::ln::channelmanager::{AChannelManager, PaymentId, RecentPaymentDetails, Retry};
1635+
/// # use lightning::offers::parse::Bolt12SemanticError;
1636+
/// #
1637+
/// # fn example<T: AChannelManager>(
1638+
/// # channel_manager: T, amount_msats: u64, absolute_expiry: Duration, retry: Retry,
1639+
/// # max_total_routing_fee_msat: Option<u64>
1640+
/// # ) -> Result<(), Bolt12SemanticError> {
1641+
/// # let channel_manager = channel_manager.get_cm();
1642+
/// let payment_id = PaymentId([42; 32]);
1643+
/// let refund = channel_manager
1644+
/// .create_refund_builder(
1645+
/// "coffee".to_string(), amount_msats, absolute_expiry, payment_id, retry,
1646+
/// max_total_routing_fee_msat
1647+
/// )?
1648+
/// .payer_note("refund for order 1234".to_string())
1649+
/// .build()?;
1650+
/// let bech32_refund = refund.to_string();
1651+
///
1652+
/// // First the payment will be waiting on an invoice
1653+
/// let expected_payment_id = payment_id;
1654+
/// assert!(
1655+
/// channel_manager.list_recent_payments().iter().find(|details| matches!(
1656+
/// details,
1657+
/// RecentPaymentDetails::AwaitingInvoice { payment_id: expected_payment_id }
1658+
/// )).is_some()
1659+
/// );
1660+
///
1661+
/// // Once the invoice is received, a payment will be sent
1662+
/// assert!(
1663+
/// channel_manager.list_recent_payments().iter().find(|details| matches!(
1664+
/// details,
1665+
/// RecentPaymentDetails::Pending { payment_id: expected_payment_id, .. }
1666+
/// )).is_some()
1667+
/// );
1668+
///
1669+
/// // On the event processing thread
1670+
/// channel_manager.process_pending_events(&|event| match event {
1671+
/// Event::PaymentSent { payment_id: Some(payment_id), .. } => println!("Paid {}", payment_id),
1672+
/// Event::PaymentFailed { payment_id, .. } => println!("Failed paying {}", payment_id),
1673+
/// // ...
1674+
/// # _ => {},
1675+
/// });
1676+
/// # Ok(())
1677+
/// # }
1678+
/// ```
1679+
///
1680+
/// Use [`request_refund_payment`] to send a [`Bolt12Invoice`] for receiving the refund. Similar to
1681+
/// *creating* an [`Offer`], this is stateless as it represents an inbound payment.
1682+
///
1683+
/// ```
1684+
/// # use lightning::events::{Event, EventsProvider, PaymentPurpose};
1685+
/// # use lightning::ln::channelmanager::AChannelManager;
1686+
/// # use lightning::offers::refund::Refund;
1687+
/// #
1688+
/// # fn example<T: AChannelManager>(channel_manager: T, refund: &Refund) {
1689+
/// # let channel_manager = channel_manager.get_cm();
1690+
/// match channel_manager.request_refund_payment(refund) {
1691+
/// Ok(()) => println!("Requesting payment for refund"),
1692+
/// Err(e) => println!("Unable to request payment for refund: {:?}", e),
1693+
/// }
1694+
///
1695+
/// // On the event processing thread
1696+
/// channel_manager.process_pending_events(&|event| match event {
1697+
/// Event::PaymentClaimable { payment_hash, purpose, .. } => match purpose {
1698+
/// PaymentPurpose::InvoicePayment { payment_preimage: Some(payment_preimage), .. } => {
1699+
/// println!("Claiming payment {}", payment_hash);
1700+
/// channel_manager.claim_funds(payment_preimage);
1701+
/// },
1702+
/// PaymentPurpose::InvoicePayment { payment_preimage: None, .. } => {
1703+
/// println!("Unknown payment hash: {}", payment_hash);
1704+
/// },
1705+
/// // ...
1706+
/// # _ => {},
1707+
/// },
1708+
/// Event::PaymentClaimed { payment_hash, amount_msat, .. } => {
1709+
/// println!("Claimed {} msats", amount_msat);
1710+
/// },
1711+
/// // ...
1712+
/// # _ => {},
1713+
/// });
1714+
/// # }
1715+
/// ```
1716+
///
16241717
/// # Persistence
16251718
///
16261719
/// Implements [`Writeable`] to write out all channel state to disk. Implies [`peer_disconnected`] for
@@ -1700,6 +1793,8 @@ where
17001793
/// [`create_offer_builder`]: Self::create_offer_builder
17011794
/// [`pay_for_offer`]: Self::pay_for_offer
17021795
/// [`InvoiceRequest`]: crate::offers::invoice_request::InvoiceRequest
1796+
/// [`create_refund_builder`]: Self::create_refund_builder
1797+
/// [`request_refund_payment`]: Self::request_refund_payment
17031798
/// [`peer_disconnected`]: msgs::ChannelMessageHandler::peer_disconnected
17041799
/// [`funding_created`]: msgs::FundingCreated
17051800
/// [`funding_transaction_generated`]: Self::funding_transaction_generated

0 commit comments

Comments
 (0)