AsyncPaymentsMessageHandler trait for OnionMessenger
[rust-lightning] / fuzz / src / onion_message.rs
1 // Imports that need to be added manually
2 use bech32::u5;
3 use bitcoin::blockdata::script::ScriptBuf;
4 use bitcoin::secp256k1::ecdh::SharedSecret;
5 use bitcoin::secp256k1::ecdsa::RecoverableSignature;
6 use bitcoin::secp256k1::schnorr;
7 use bitcoin::secp256k1::{self, PublicKey, Scalar, Secp256k1, SecretKey};
8
9 use lightning::blinded_path::{BlindedPath, EmptyNodeIdLookUp};
10 use lightning::ln::features::InitFeatures;
11 use lightning::ln::msgs::{self, DecodeError, OnionMessageHandler};
12 use lightning::ln::script::ShutdownScript;
13 use lightning::offers::invoice::UnsignedBolt12Invoice;
14 use lightning::offers::invoice_request::UnsignedInvoiceRequest;
15 use lightning::onion_message::async_payments::{
16         AsyncPaymentsMessage, AsyncPaymentsMessageHandler, HeldHtlcAvailable, ReleaseHeldHtlc,
17 };
18 use lightning::onion_message::messenger::{
19         CustomOnionMessageHandler, Destination, MessageRouter, OnionMessagePath, OnionMessenger,
20         PendingOnionMessage, Responder, ResponseInstruction,
21 };
22 use lightning::onion_message::offers::{OffersMessage, OffersMessageHandler};
23 use lightning::onion_message::packet::OnionMessageContents;
24 use lightning::sign::{EntropySource, KeyMaterial, NodeSigner, Recipient, SignerProvider};
25 use lightning::util::logger::Logger;
26 use lightning::util::ser::{Readable, Writeable, Writer};
27 use lightning::util::test_channel_signer::TestChannelSigner;
28
29 use crate::utils::test_logger;
30
31 use std::io::{self, Cursor};
32 use std::sync::atomic::{AtomicU64, Ordering};
33
34 #[inline]
35 /// Actual fuzz test, method signature and name are fixed
36 pub fn do_test<L: Logger>(data: &[u8], logger: &L) {
37         if let Ok(msg) = <msgs::OnionMessage as Readable>::read(&mut Cursor::new(data)) {
38                 let mut secret_bytes = [1; 32];
39                 secret_bytes[31] = 2;
40                 let secret = SecretKey::from_slice(&secret_bytes).unwrap();
41                 let keys_manager = KeyProvider { node_secret: secret, counter: AtomicU64::new(0) };
42                 let node_id_lookup = EmptyNodeIdLookUp {};
43                 let message_router = TestMessageRouter {};
44                 let offers_msg_handler = TestOffersMessageHandler {};
45                 let async_payments_msg_handler = TestAsyncPaymentsMessageHandler {};
46                 let custom_msg_handler = TestCustomMessageHandler {};
47                 let onion_messenger = OnionMessenger::new(
48                         &keys_manager,
49                         &keys_manager,
50                         logger,
51                         &node_id_lookup,
52                         &message_router,
53                         &offers_msg_handler,
54                         &async_payments_msg_handler,
55                         &custom_msg_handler,
56                 );
57
58                 let peer_node_id = {
59                         let mut secret_bytes = [0; 32];
60                         secret_bytes[31] = 2;
61                         let secret = SecretKey::from_slice(&secret_bytes).unwrap();
62                         PublicKey::from_secret_key(&Secp256k1::signing_only(), &secret)
63                 };
64
65                 let mut features = InitFeatures::empty();
66                 features.set_onion_messages_optional();
67                 let init = msgs::Init { features, networks: None, remote_network_address: None };
68
69                 onion_messenger.peer_connected(&peer_node_id, &init, false).unwrap();
70                 onion_messenger.handle_onion_message(&peer_node_id, &msg);
71         }
72 }
73
74 /// Method that needs to be added manually, {name}_test
75 pub fn onion_message_test<Out: test_logger::Output>(data: &[u8], out: Out) {
76         let logger = test_logger::TestLogger::new("".to_owned(), out);
77         do_test(data, &logger);
78 }
79
80 /// Method that needs to be added manually, {name}_run
81 #[no_mangle]
82 pub extern "C" fn onion_message_run(data: *const u8, datalen: usize) {
83         let logger = test_logger::TestLogger::new("".to_owned(), test_logger::DevNull {});
84         do_test(unsafe { std::slice::from_raw_parts(data, datalen) }, &logger);
85 }
86
87 struct TestMessageRouter {}
88
89 impl MessageRouter for TestMessageRouter {
90         fn find_path(
91                 &self, _sender: PublicKey, _peers: Vec<PublicKey>, destination: Destination,
92         ) -> Result<OnionMessagePath, ()> {
93                 Ok(OnionMessagePath { intermediate_nodes: vec![], destination, first_node_addresses: None })
94         }
95
96         fn create_blinded_paths<T: secp256k1::Signing + secp256k1::Verification>(
97                 &self, _recipient: PublicKey, _peers: Vec<PublicKey>, _secp_ctx: &Secp256k1<T>,
98         ) -> Result<Vec<BlindedPath>, ()> {
99                 unreachable!()
100         }
101 }
102
103 struct TestOffersMessageHandler {}
104
105 impl OffersMessageHandler for TestOffersMessageHandler {
106         fn handle_message(
107                 &self, _message: OffersMessage, _responder: Option<Responder>,
108         ) -> ResponseInstruction<OffersMessage> {
109                 ResponseInstruction::NoResponse
110         }
111 }
112
113 struct TestAsyncPaymentsMessageHandler {}
114
115 impl AsyncPaymentsMessageHandler for TestAsyncPaymentsMessageHandler {
116         fn held_htlc_available(
117                 &self, _message: HeldHtlcAvailable, _responder: Option<Responder>,
118         ) -> ResponseInstruction<ReleaseHeldHtlc> {
119                 ResponseInstruction::NoResponse
120         }
121         fn release_held_htlc(&self, _message: ReleaseHeldHtlc) {}
122 }
123
124 #[derive(Debug)]
125 struct TestCustomMessage {}
126
127 const CUSTOM_MESSAGE_TYPE: u64 = 4242;
128 const CUSTOM_MESSAGE_CONTENTS: [u8; 32] = [42; 32];
129
130 impl OnionMessageContents for TestCustomMessage {
131         fn tlv_type(&self) -> u64 {
132                 CUSTOM_MESSAGE_TYPE
133         }
134         fn msg_type(&self) -> &'static str {
135                 "Custom Message"
136         }
137 }
138
139 impl Writeable for TestCustomMessage {
140         fn write<W: Writer>(&self, w: &mut W) -> Result<(), io::Error> {
141                 Ok(CUSTOM_MESSAGE_CONTENTS.write(w)?)
142         }
143 }
144
145 struct TestCustomMessageHandler {}
146
147 impl CustomOnionMessageHandler for TestCustomMessageHandler {
148         type CustomMessage = TestCustomMessage;
149         fn handle_custom_message(
150                 &self, message: Self::CustomMessage, responder: Option<Responder>,
151         ) -> ResponseInstruction<Self::CustomMessage> {
152                 match responder {
153                         Some(responder) => responder.respond(message),
154                         None => ResponseInstruction::NoResponse,
155                 }
156         }
157         fn read_custom_message<R: io::Read>(
158                 &self, _message_type: u64, buffer: &mut R,
159         ) -> Result<Option<Self::CustomMessage>, msgs::DecodeError> {
160                 let mut buf = Vec::new();
161                 buffer.read_to_end(&mut buf)?;
162                 return Ok(Some(TestCustomMessage {}));
163         }
164         fn release_pending_custom_messages(&self) -> Vec<PendingOnionMessage<Self::CustomMessage>> {
165                 vec![]
166         }
167 }
168
169 pub struct VecWriter(pub Vec<u8>);
170 impl Writer for VecWriter {
171         fn write_all(&mut self, buf: &[u8]) -> Result<(), ::std::io::Error> {
172                 self.0.extend_from_slice(buf);
173                 Ok(())
174         }
175 }
176 struct KeyProvider {
177         node_secret: SecretKey,
178         counter: AtomicU64,
179 }
180
181 impl EntropySource for KeyProvider {
182         fn get_secure_random_bytes(&self) -> [u8; 32] {
183                 let ctr = self.counter.fetch_add(1, Ordering::Relaxed);
184                 #[rustfmt::skip]
185                 let random_bytes = [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
186                         (ctr >> 8*7) as u8, (ctr >> 8*6) as u8, (ctr >> 8*5) as u8, (ctr >> 8*4) as u8,
187                         (ctr >> 8*3) as u8, (ctr >> 8*2) as u8, (ctr >> 8*1) as u8, 14, (ctr >> 8*0) as u8];
188                 random_bytes
189         }
190 }
191
192 impl NodeSigner for KeyProvider {
193         fn get_node_id(&self, recipient: Recipient) -> Result<PublicKey, ()> {
194                 let node_secret = match recipient {
195                         Recipient::Node => Ok(&self.node_secret),
196                         Recipient::PhantomNode => Err(()),
197                 }?;
198                 Ok(PublicKey::from_secret_key(&Secp256k1::signing_only(), node_secret))
199         }
200
201         fn ecdh(
202                 &self, recipient: Recipient, other_key: &PublicKey, tweak: Option<&Scalar>,
203         ) -> Result<SharedSecret, ()> {
204                 let mut node_secret = match recipient {
205                         Recipient::Node => Ok(self.node_secret.clone()),
206                         Recipient::PhantomNode => Err(()),
207                 }?;
208                 if let Some(tweak) = tweak {
209                         node_secret = node_secret.mul_tweak(tweak).map_err(|_| ())?;
210                 }
211                 Ok(SharedSecret::new(other_key, &node_secret))
212         }
213
214         fn get_inbound_payment_key_material(&self) -> KeyMaterial {
215                 unreachable!()
216         }
217
218         fn sign_invoice(
219                 &self, _hrp_bytes: &[u8], _invoice_data: &[u5], _recipient: Recipient,
220         ) -> Result<RecoverableSignature, ()> {
221                 unreachable!()
222         }
223
224         fn sign_bolt12_invoice_request(
225                 &self, _invoice_request: &UnsignedInvoiceRequest,
226         ) -> Result<schnorr::Signature, ()> {
227                 unreachable!()
228         }
229
230         fn sign_bolt12_invoice(
231                 &self, _invoice: &UnsignedBolt12Invoice,
232         ) -> Result<schnorr::Signature, ()> {
233                 unreachable!()
234         }
235
236         fn sign_gossip_message(
237                 &self, _msg: lightning::ln::msgs::UnsignedGossipMessage,
238         ) -> Result<bitcoin::secp256k1::ecdsa::Signature, ()> {
239                 unreachable!()
240         }
241 }
242
243 impl SignerProvider for KeyProvider {
244         type EcdsaSigner = TestChannelSigner;
245         #[cfg(taproot)]
246         type TaprootSigner = TestChannelSigner;
247
248         fn generate_channel_keys_id(
249                 &self, _inbound: bool, _channel_value_satoshis: u64, _user_channel_id: u128,
250         ) -> [u8; 32] {
251                 unreachable!()
252         }
253
254         fn derive_channel_signer(
255                 &self, _channel_value_satoshis: u64, _channel_keys_id: [u8; 32],
256         ) -> Self::EcdsaSigner {
257                 unreachable!()
258         }
259
260         fn read_chan_signer(&self, _data: &[u8]) -> Result<TestChannelSigner, DecodeError> {
261                 unreachable!()
262         }
263
264         fn get_destination_script(&self, _channel_keys_id: [u8; 32]) -> Result<ScriptBuf, ()> {
265                 unreachable!()
266         }
267
268         fn get_shutdown_scriptpubkey(&self) -> Result<ShutdownScript, ()> {
269                 unreachable!()
270         }
271 }
272
273 #[cfg(test)]
274 mod tests {
275         use bitcoin::hashes::hex::FromHex;
276         use lightning::util::logger::{Logger, Record};
277         use std::collections::HashMap;
278         use std::sync::Mutex;
279
280         struct TrackingLogger {
281                 /// (module, message) -> count
282                 pub lines: Mutex<HashMap<(String, String), usize>>,
283         }
284         impl Logger for TrackingLogger {
285                 fn log(&self, record: Record) {
286                         let mut lines_lock = self.lines.lock().unwrap();
287                         let key = (record.module_path.to_string(), format!("{}", record.args));
288                         *lines_lock.entry(key).or_insert(0) += 1;
289                         println!(
290                                 "{:<5} [{} : {}, {}] {}",
291                                 record.level.to_string(),
292                                 record.module_path,
293                                 record.file,
294                                 record.line,
295                                 record.args
296                         );
297                 }
298         }
299
300         #[test]
301         fn test_no_onion_message_breakage() {
302                 let one_hop_om = "\
303                         020000000000000000000000000000000000000000000000000000000000000e01055600020000000000000\
304                         000000000000000000000000000000000000000000000000e01ae0276020000000000000000000000000000\
305                         000000000000000000000000000000000002020000000000000000000000000000000000000000000000000\
306                         000000000000e0101022a0000000000000000000000000000014551231950b75fc4402da1732fc9bebf0010\
307                         9500000000000000000000000000000004106d000000000000000000000000000000fd1092202a2a2a2a2a2\
308                         a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a0000000000000000000000000000000000\
309                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
310                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
311                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
312                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
313                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
314                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
315                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
316                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
317                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
318                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
319                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
320                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
321                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
322                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
323                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
324                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
325                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
326                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
327                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
328                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
329                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
330                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
331                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
332                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
333                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
334                         000000000000000000000000000000000000000005600000000000000000000000000000000000000000000\
335                         000000000000000000";
336                 let logger = TrackingLogger { lines: Mutex::new(HashMap::new()) };
337                 super::do_test(&<Vec<u8>>::from_hex(one_hop_om).unwrap(), &logger);
338                 {
339                         let log_entries = logger.lines.lock().unwrap();
340                         assert_eq!(log_entries.get(&("lightning::onion_message::messenger".to_string(),
341                                                 "Received an onion message with path_id None and a reply_path: Custom(TestCustomMessage)"
342                                                 .to_string())), Some(&1));
343                         assert_eq!(log_entries.get(&("lightning::onion_message::messenger".to_string(),
344                                                 "Constructing onion message when responding with Custom Message to an onion message with path_id None: TestCustomMessage".to_string())), Some(&1));
345                         assert_eq!(log_entries.get(&("lightning::onion_message::messenger".to_string(),
346                                                 "Buffered onion message when responding with Custom Message to an onion message with path_id None".to_string())), Some(&1));
347                 }
348
349                 let two_unblinded_hops_om = "\
350                         020000000000000000000000000000000000000000000000000000000000000e01055600020000000000000\
351                         000000000000000000000000000000000000000000000000e01350433042102020202020202020202020202\
352                         02020202020202020202020202020202020202026d000000000000000000000000000000eb0000000000000\
353                         000000000000000000000000000000000000000000000000036041096000000000000000000000000000000\
354                         fd1092202a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a000000000000000\
355                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
356                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
357                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
358                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
359                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
360                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
361                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
362                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
363                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
364                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
365                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
366                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
367                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
368                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
369                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
370                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
371                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
372                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
373                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
374                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
375                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
376                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
377                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
378                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
379                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
380                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
381                         000000000000000000000000000000000000000004800000000000000000000000000000000000000000000\
382                         000000000000000000";
383                 let logger = TrackingLogger { lines: Mutex::new(HashMap::new()) };
384                 super::do_test(&<Vec<u8>>::from_hex(two_unblinded_hops_om).unwrap(), &logger);
385                 {
386                         let log_entries = logger.lines.lock().unwrap();
387                         assert_eq!(log_entries.get(&("lightning::onion_message::messenger".to_string(), "Forwarding an onion message to peer 020202020202020202020202020202020202020202020202020202020202020202".to_string())), Some(&1));
388                 }
389
390                 let two_unblinded_two_blinded_om = "\
391                         020000000000000000000000000000000000000000000000000000000000000e01055600020000000000000\
392                         000000000000000000000000000000000000000000000000e01350433042102020202020202020202020202\
393                         02020202020202020202020202020202020202026d0000000000000000000000000000009e0000000000000\
394                         000000000000000000000000000000000000000000000000058045604210203030303030303030303030303\
395                         030303030303030303030303030303030303020821020000000000000000000000000000000000000000000\
396                         000000000000000000e0196000000000000000000000000000000e900000000000000000000000000000000\
397                         000000000000000000000000000000350433042102040404040404040404040404040404040404040404040\
398                         4040404040404040402ca000000000000000000000000000000420000000000000000000000000000000000\
399                         00000000000000000000000000003604103f000000000000000000000000000000fd1092202a2a2a2a2a2a2\
400                         a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a000000000000000000000000000000000000\
401                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
402                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
403                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
404                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
405                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
406                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
407                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
408                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
409                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
410                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
411                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
412                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
413                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
414                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
415                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
416                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
417                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
418                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
419                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
420                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
421                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
422                         000000000000000000000000000000000000000004800000000000000000000000000000000000000000000\
423                         000000000000000000";
424                 let logger = TrackingLogger { lines: Mutex::new(HashMap::new()) };
425                 super::do_test(&<Vec<u8>>::from_hex(two_unblinded_two_blinded_om).unwrap(), &logger);
426                 {
427                         let log_entries = logger.lines.lock().unwrap();
428                         assert_eq!(log_entries.get(&("lightning::onion_message::messenger".to_string(), "Forwarding an onion message to peer 020202020202020202020202020202020202020202020202020202020202020202".to_string())), Some(&1));
429                 }
430
431                 let three_blinded_om = "\
432                         020000000000000000000000000000000000000000000000000000000000000e01055600020000000000000\
433                         000000000000000000000000000000000000000000000000e01350433042102020202020202020202020202\
434                         02020202020202020202020202020202020202026d000000000000000000000000000000b20000000000000\
435                         000000000000000000000000000000000000000000000000035043304210203030303030303030303030303\
436                         030303030303030303030303030303030303029600000000000000000000000000000033000000000000000\
437                         000000000000000000000000000000000000000000000003604104e000000000000000000000000000000fd\
438                         1092202a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a2a00000000000000000\
439                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
440                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
441                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
442                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
443                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
444                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
445                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
446                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
447                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
448                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
449                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
450                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
451                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
452                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
453                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
454                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
455                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
456                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
457                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
458                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
459                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
460                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
461                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
462                         000000000000000000000000000000000000000000000000000000000000000000000000000000000000000\
463                         000000000000000000000000000000000000000004800000000000000000000000000000000000000000000\
464                         000000000000000000";
465                 let logger = TrackingLogger { lines: Mutex::new(HashMap::new()) };
466                 super::do_test(&<Vec<u8>>::from_hex(three_blinded_om).unwrap(), &logger);
467                 {
468                         let log_entries = logger.lines.lock().unwrap();
469                         assert_eq!(log_entries.get(&("lightning::onion_message::messenger".to_string(), "Forwarding an onion message to peer 020202020202020202020202020202020202020202020202020202020202020202".to_string())), Some(&1));
470                 }
471         }
472 }