@@ -14,6 +14,7 @@ use std::sync::{Arc, Mutex};
1414use bitcoin:: blockdata:: locktime:: absolute:: LockTime ;
1515use bitcoin:: secp256k1:: PublicKey ;
1616use bitcoin:: { Amount , OutPoint } ;
17+ use lightning:: blinded_path:: message:: NextMessageHop ;
1718use lightning:: events:: bump_transaction:: BumpTransactionEvent ;
1819#[ cfg( not( feature = "uniffi" ) ) ]
1920use lightning:: events:: PaidBolt12Invoice ;
@@ -29,7 +30,10 @@ use lightning::util::config::{ChannelConfigOverrides, ChannelConfigUpdate};
2930use lightning:: util:: errors:: APIError ;
3031use lightning:: util:: persist:: KVStore ;
3132use lightning:: util:: ser:: { Readable , ReadableArgs , Writeable , Writer } ;
32- use lightning:: { impl_writeable_tlv_based, impl_writeable_tlv_based_enum} ;
33+ use lightning:: {
34+ impl_ser_tlv_based as impl_writeable_tlv_based,
35+ impl_ser_tlv_based_enum as impl_writeable_tlv_based_enum,
36+ } ;
3337use lightning_liquidity:: lsps2:: utils:: compute_opening_fee;
3438use lightning_types:: payment:: { PaymentHash , PaymentPreimage } ;
3539
@@ -1725,7 +1729,11 @@ where
17251729
17261730 self . bump_tx_event_handler . handle_event ( & bte) . await ;
17271731 } ,
1728- LdkEvent :: OnionMessageIntercepted { peer_node_id, message } => {
1732+ LdkEvent :: OnionMessageIntercepted {
1733+ next_hop : NextMessageHop :: NodeId ( peer_node_id) ,
1734+ message,
1735+ ..
1736+ } => {
17291737 if let Some ( om_mailbox) = self . om_mailbox . as_ref ( ) {
17301738 om_mailbox. onion_message_intercepted ( peer_node_id, message) ;
17311739 } else {
@@ -1735,6 +1743,12 @@ where
17351743 ) ;
17361744 }
17371745 } ,
1746+ LdkEvent :: OnionMessageIntercepted {
1747+ next_hop : NextMessageHop :: ShortChannelId ( _) ,
1748+ ..
1749+ } => {
1750+ log_trace ! ( self . logger, "Ignoring onion message intercepted for unknown SCID" ) ;
1751+ } ,
17381752 LdkEvent :: OnionMessagePeerConnected { peer_node_id } => {
17391753 if let Some ( om_mailbox) = self . om_mailbox . as_ref ( ) {
17401754 let messages = om_mailbox. onion_message_peer_connected ( peer_node_id) ;
0 commit comments