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