X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=lightning%2Fsrc%2Fonion_message%2Foffers.rs;h=faf539f868261a97768e6051b22451861db737ca;hb=6264a442599fbadd54b0cc24949fc0fd9de08fb3;hp=f5945cd55054dc6c368a668fcf4aa777f15d6a21;hpb=840efd533468cf7cacd8b4bab27ce2db86b3eb93;p=rust-lightning diff --git a/lightning/src/onion_message/offers.rs b/lightning/src/onion_message/offers.rs index f5945cd5..faf539f8 100644 --- a/lightning/src/onion_message/offers.rs +++ b/lightning/src/onion_message/offers.rs @@ -9,16 +9,18 @@ //! Message handling for BOLT 12 Offers. -use core::convert::TryFrom; +use core::fmt; use crate::io::{self, Read}; use crate::ln::msgs::DecodeError; use crate::offers::invoice_error::InvoiceError; use crate::offers::invoice_request::InvoiceRequest; use crate::offers::invoice::Bolt12Invoice; use crate::offers::parse::Bolt12ParseError; -use crate::onion_message::OnionMessageContents; +use crate::onion_message::packet::OnionMessageContents; use crate::util::logger::Logger; use crate::util::ser::{Readable, ReadableArgs, Writeable, Writer}; +#[cfg(not(c_bindings))] +use crate::onion_message::messenger::PendingOnionMessage; use crate::prelude::*; @@ -33,13 +35,31 @@ const INVOICE_ERROR_TLV_TYPE: u64 = 68; pub trait OffersMessageHandler { /// Handles the given message by either responding with an [`Bolt12Invoice`], sending a payment, /// or replying with an error. + /// + /// The returned [`OffersMessage`], if any, is enqueued to be sent by [`OnionMessenger`]. + /// + /// [`OnionMessenger`]: crate::onion_message::messenger::OnionMessenger fn handle_message(&self, message: OffersMessage) -> Option; + + /// Releases any [`OffersMessage`]s that need to be sent. + /// + /// Typically, this is used for messages initiating a payment flow rather than in response to + /// another message. The latter should use the return value of [`Self::handle_message`]. + #[cfg(not(c_bindings))] + fn release_pending_messages(&self) -> Vec> { vec![] } + + /// Releases any [`OffersMessage`]s that need to be sent. + /// + /// Typically, this is used for messages initiating a payment flow rather than in response to + /// another message. The latter should use the return value of [`Self::handle_message`]. + #[cfg(c_bindings)] + fn release_pending_messages(&self) -> Vec<(OffersMessage, crate::onion_message::messenger::Destination, Option)> { vec![] } } /// Possible BOLT 12 Offers messages sent and received via an [`OnionMessage`]. /// /// [`OnionMessage`]: crate::ln::msgs::OnionMessage -#[derive(Clone, Debug)] +#[derive(Clone)] pub enum OffersMessage { /// A request for a [`Bolt12Invoice`] for a particular [`Offer`]. /// @@ -73,6 +93,22 @@ impl OffersMessage { } } +impl fmt::Debug for OffersMessage { + fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { + match self { + OffersMessage::InvoiceRequest(message) => { + write!(f, "{:?}", message.as_tlv_stream()) + } + OffersMessage::Invoice(message) => { + write!(f, "{:?}", message.as_tlv_stream()) + } + OffersMessage::InvoiceError(message) => { + write!(f, "{:?}", message) + } + } + } +} + impl OnionMessageContents for OffersMessage { fn tlv_type(&self) -> u64 { match self {