@@ -1436,25 +1436,19 @@ where
1436
1436
"Received an onion message with path_id {:02x?} and {} reply_path: {:?}" ,
1437
1437
path_id, if reply_path. is_some( ) { "a" } else { "no" } , message) ;
1438
1438
1439
+ let responder = reply_path. map (
1440
+ |reply_path| Responder :: new ( reply_path, path_id)
1441
+ ) ;
1439
1442
match message {
1440
1443
ParsedOnionMessageContents :: Offers ( msg) => {
1441
- let responder = reply_path. map (
1442
- |reply_path| Responder :: new ( reply_path, path_id)
1443
- ) ;
1444
1444
let response_instructions = self . offers_handler . handle_message ( msg, responder) ;
1445
1445
let _ = self . handle_onion_message_response ( response_instructions) ;
1446
1446
} ,
1447
1447
ParsedOnionMessageContents :: AsyncPayments ( msg) => {
1448
- let responder = reply_path. map (
1449
- |reply_path| Responder :: new ( reply_path, path_id)
1450
- ) ;
1451
1448
let response_instructions = self . async_payments_handler . handle_message ( msg, responder) ;
1452
1449
let _ = self . handle_onion_message_response ( response_instructions) ;
1453
1450
} ,
1454
1451
ParsedOnionMessageContents :: Custom ( msg) => {
1455
- let responder = reply_path. map (
1456
- |reply_path| Responder :: new ( reply_path, path_id)
1457
- ) ;
1458
1452
let response_instructions = self . custom_handler . handle_custom_message ( msg, responder) ;
1459
1453
let _ = self . handle_onion_message_response ( response_instructions) ;
1460
1454
} ,
0 commit comments