1 // This file is Copyright its original authors, visible in version control
2 // history and in the source files from which this was generated.
4 // This file is licensed under the license available in the LICENSE or LICENSE.md
5 // file in the root of this repository or, if no such file exists, the same
6 // license as that which applies to the original source files from which this
7 // source was automatically generated.
9 //! Message handling for BOLT 12 Offers.
11 use alloc::str::FromStr;
12 use alloc::string::String;
13 use core::ffi::c_void;
14 use core::convert::Infallible;
15 use bitcoin::hashes::Hash;
16 use crate::c_types::*;
17 #[cfg(feature="no-std")]
18 use alloc::{vec::Vec, boxed::Box};
20 /// A handler for an [`OnionMessage`] containing a BOLT 12 Offers message as its payload.
22 /// [`OnionMessage`]: crate::ln::msgs::OnionMessage
24 pub struct OffersMessageHandler {
25 /// An opaque pointer which is passed to your function implementations as an argument.
26 /// This has no meaning in the LDK, and can be NULL or any other value.
27 pub this_arg: *mut c_void,
28 /// Handles the given message by either responding with an [`Bolt12Invoice`], sending a payment,
29 /// or replying with an error.
31 /// The returned [`OffersMessage`], if any, is enqueued to be sent by [`OnionMessenger`].
33 /// [`OnionMessenger`]: crate::onion_message::OnionMessenger
34 pub handle_message: extern "C" fn (this_arg: *const c_void, message: crate::lightning::onion_message::offers::OffersMessage) -> crate::c_types::derived::COption_OffersMessageZ,
35 /// Releases any [`OffersMessage`]s that need to be sent.
37 /// Typically, this is used for messages initiating a payment flow rather than in response to
38 /// another message. The latter should use the return value of [`Self::handle_message`].
39 pub release_pending_messages: extern "C" fn (this_arg: *const c_void) -> crate::c_types::derived::CVec_C3Tuple_OffersMessageDestinationBlindedPathZZ,
40 /// Frees any resources associated with this object given its this_arg pointer.
41 /// Does not need to free the outer struct containing function pointers and may be NULL is no resources need to be freed.
42 pub free: Option<extern "C" fn(this_arg: *mut c_void)>,
44 unsafe impl Send for OffersMessageHandler {}
45 unsafe impl Sync for OffersMessageHandler {}
47 pub(crate) fn OffersMessageHandler_clone_fields(orig: &OffersMessageHandler) -> OffersMessageHandler {
48 OffersMessageHandler {
49 this_arg: orig.this_arg,
50 handle_message: Clone::clone(&orig.handle_message),
51 release_pending_messages: Clone::clone(&orig.release_pending_messages),
52 free: Clone::clone(&orig.free),
56 use lightning::onion_message::offers::OffersMessageHandler as rustOffersMessageHandler;
57 impl rustOffersMessageHandler for OffersMessageHandler {
58 fn handle_message(&self, mut message: lightning::onion_message::offers::OffersMessage) -> Option<lightning::onion_message::offers::OffersMessage> {
59 let mut ret = (self.handle_message)(self.this_arg, crate::lightning::onion_message::offers::OffersMessage::native_into(message));
60 let mut local_ret = { /*ret*/ let ret_opt = ret; if ret_opt.is_none() { None } else { Some({ { { ret_opt.take() }.into_native() }})} };
63 fn release_pending_messages(&self) -> Vec<(lightning::onion_message::offers::OffersMessage, lightning::onion_message::messenger::Destination, Option<lightning::blinded_path::BlindedPath>)> {
64 let mut ret = (self.release_pending_messages)(self.this_arg);
65 let mut local_ret = Vec::new(); for mut item in ret.into_rust().drain(..) { local_ret.push( { let (mut orig_ret_0_0, mut orig_ret_0_1, mut orig_ret_0_2) = item.to_rust(); let mut local_orig_ret_0_2 = if orig_ret_0_2.inner.is_null() { None } else { Some( { *unsafe { Box::from_raw(orig_ret_0_2.take_inner()) } }) }; let mut local_ret_0 = (orig_ret_0_0.into_native(), orig_ret_0_1.into_native(), local_orig_ret_0_2); local_ret_0 }); };
70 // We're essentially a pointer already, or at least a set of pointers, so allow us to be used
71 // directly as a Deref trait in higher-level structs:
72 impl core::ops::Deref for OffersMessageHandler {
74 fn deref(&self) -> &Self {
78 impl core::ops::DerefMut for OffersMessageHandler {
79 fn deref_mut(&mut self) -> &mut Self {
83 /// Calls the free function if one is set
85 pub extern "C" fn OffersMessageHandler_free(this_ptr: OffersMessageHandler) { }
86 impl Drop for OffersMessageHandler {
88 if let Some(f) = self.free {
93 /// Possible BOLT 12 Offers messages sent and received via an [`OnionMessage`].
95 /// [`OnionMessage`]: crate::ln::msgs::OnionMessage
99 pub enum OffersMessage {
100 /// A request for a [`Bolt12Invoice`] for a particular [`Offer`].
102 /// [`Offer`]: crate::offers::offer::Offer
104 crate::lightning::offers::invoice_request::InvoiceRequest),
105 /// A [`Bolt12Invoice`] sent in response to an [`InvoiceRequest`] or a [`Refund`].
107 /// [`Refund`]: crate::offers::refund::Refund
109 crate::lightning::offers::invoice::Bolt12Invoice),
110 /// An error from handling an [`OffersMessage`].
112 crate::lightning::offers::invoice_error::InvoiceError),
114 use lightning::onion_message::offers::OffersMessage as OffersMessageImport;
115 pub(crate) type nativeOffersMessage = OffersMessageImport;
119 pub(crate) fn to_native(&self) -> nativeOffersMessage {
121 OffersMessage::InvoiceRequest (ref a, ) => {
122 let mut a_nonref = Clone::clone(a);
123 nativeOffersMessage::InvoiceRequest (
124 *unsafe { Box::from_raw(a_nonref.take_inner()) },
127 OffersMessage::Invoice (ref a, ) => {
128 let mut a_nonref = Clone::clone(a);
129 nativeOffersMessage::Invoice (
130 *unsafe { Box::from_raw(a_nonref.take_inner()) },
133 OffersMessage::InvoiceError (ref a, ) => {
134 let mut a_nonref = Clone::clone(a);
135 nativeOffersMessage::InvoiceError (
136 *unsafe { Box::from_raw(a_nonref.take_inner()) },
142 pub(crate) fn into_native(self) -> nativeOffersMessage {
144 OffersMessage::InvoiceRequest (mut a, ) => {
145 nativeOffersMessage::InvoiceRequest (
146 *unsafe { Box::from_raw(a.take_inner()) },
149 OffersMessage::Invoice (mut a, ) => {
150 nativeOffersMessage::Invoice (
151 *unsafe { Box::from_raw(a.take_inner()) },
154 OffersMessage::InvoiceError (mut a, ) => {
155 nativeOffersMessage::InvoiceError (
156 *unsafe { Box::from_raw(a.take_inner()) },
162 pub(crate) fn from_native(native: &nativeOffersMessage) -> Self {
164 nativeOffersMessage::InvoiceRequest (ref a, ) => {
165 let mut a_nonref = Clone::clone(a);
166 OffersMessage::InvoiceRequest (
167 crate::lightning::offers::invoice_request::InvoiceRequest { inner: ObjOps::heap_alloc(a_nonref), is_owned: true },
170 nativeOffersMessage::Invoice (ref a, ) => {
171 let mut a_nonref = Clone::clone(a);
172 OffersMessage::Invoice (
173 crate::lightning::offers::invoice::Bolt12Invoice { inner: ObjOps::heap_alloc(a_nonref), is_owned: true },
176 nativeOffersMessage::InvoiceError (ref a, ) => {
177 let mut a_nonref = Clone::clone(a);
178 OffersMessage::InvoiceError (
179 crate::lightning::offers::invoice_error::InvoiceError { inner: ObjOps::heap_alloc(a_nonref), is_owned: true },
185 pub(crate) fn native_into(native: nativeOffersMessage) -> Self {
187 nativeOffersMessage::InvoiceRequest (mut a, ) => {
188 OffersMessage::InvoiceRequest (
189 crate::lightning::offers::invoice_request::InvoiceRequest { inner: ObjOps::heap_alloc(a), is_owned: true },
192 nativeOffersMessage::Invoice (mut a, ) => {
193 OffersMessage::Invoice (
194 crate::lightning::offers::invoice::Bolt12Invoice { inner: ObjOps::heap_alloc(a), is_owned: true },
197 nativeOffersMessage::InvoiceError (mut a, ) => {
198 OffersMessage::InvoiceError (
199 crate::lightning::offers::invoice_error::InvoiceError { inner: ObjOps::heap_alloc(a), is_owned: true },
205 /// Frees any resources used by the OffersMessage
207 pub extern "C" fn OffersMessage_free(this_ptr: OffersMessage) { }
208 /// Creates a copy of the OffersMessage
210 pub extern "C" fn OffersMessage_clone(orig: &OffersMessage) -> OffersMessage {
214 /// Used only if an object of this type is returned as a trait impl by a method
215 pub(crate) extern "C" fn OffersMessage_clone_void(this_ptr: *const c_void) -> *mut c_void {
216 Box::into_raw(Box::new(unsafe { (*(this_ptr as *const OffersMessage)).clone() })) as *mut c_void
219 /// Used only if an object of this type is returned as a trait impl by a method
220 pub(crate) extern "C" fn OffersMessage_free_void(this_ptr: *mut c_void) {
221 let _ = unsafe { Box::from_raw(this_ptr as *mut OffersMessage) };
224 /// Utility method to constructs a new InvoiceRequest-variant OffersMessage
225 pub extern "C" fn OffersMessage_invoice_request(a: crate::lightning::offers::invoice_request::InvoiceRequest) -> OffersMessage {
226 OffersMessage::InvoiceRequest(a, )
229 /// Utility method to constructs a new Invoice-variant OffersMessage
230 pub extern "C" fn OffersMessage_invoice(a: crate::lightning::offers::invoice::Bolt12Invoice) -> OffersMessage {
231 OffersMessage::Invoice(a, )
234 /// Utility method to constructs a new InvoiceError-variant OffersMessage
235 pub extern "C" fn OffersMessage_invoice_error(a: crate::lightning::offers::invoice_error::InvoiceError) -> OffersMessage {
236 OffersMessage::InvoiceError(a, )
238 /// Returns whether `tlv_type` corresponds to a TLV record for Offers.
241 pub extern "C" fn OffersMessage_is_known_type(mut tlv_type: u64) -> bool {
242 let mut ret = lightning::onion_message::offers::OffersMessage::is_known_type(tlv_type);
247 /// Serialize the OffersMessage object into a byte array which can be read by OffersMessage_read
248 pub extern "C" fn OffersMessage_write(obj: &crate::lightning::onion_message::offers::OffersMessage) -> crate::c_types::derived::CVec_u8Z {
249 crate::c_types::serialize_obj(&unsafe { &*obj }.to_native())
252 pub(crate) extern "C" fn OffersMessage_write_void(obj: *const c_void) -> crate::c_types::derived::CVec_u8Z {
253 OffersMessage_write(unsafe { &*(obj as *const OffersMessage) })
256 /// Read a OffersMessage from a byte array, created by OffersMessage_write
257 pub extern "C" fn OffersMessage_read(ser: crate::c_types::u8slice, arg_a: u64, arg_b: &crate::lightning::util::logger::Logger) -> crate::c_types::derived::CResult_OffersMessageDecodeErrorZ {
258 let arg_a_conv = arg_a;
259 let arg_b_conv = arg_b;
260 let arg_conv = (arg_a_conv, arg_b_conv);
261 let res: Result<lightning::onion_message::offers::OffersMessage, lightning::ln::msgs::DecodeError> = crate::c_types::deserialize_obj_arg(ser, arg_conv);
262 let mut local_res = match res { Ok(mut o) => crate::c_types::CResultTempl::ok( { crate::lightning::onion_message::offers::OffersMessage::native_into(o) }).into(), Err(mut e) => crate::c_types::CResultTempl::err( { crate::lightning::ln::msgs::DecodeError::native_into(e) }).into() };