Add an `inbound` flag to the `peer_connected` message handlers
[rust-lightning] / lightning / src / onion_message / messenger.rs
index 2c71e9c3fb34e2d15d13933dbf0e6b37a17f570a..7814ccb6508c77a10abfa32ee189914493a62278 100644 (file)
@@ -417,7 +417,7 @@ impl<ES: Deref, NS: Deref, L: Deref, CMH: Deref> OnionMessageHandler for OnionMe
                };
        }
 
-       fn peer_connected(&self, their_node_id: &PublicKey, init: &msgs::Init) -> Result<(), ()> {
+       fn peer_connected(&self, their_node_id: &PublicKey, init: &msgs::Init, _inbound: bool) -> Result<(), ()> {
                if init.features.supports_onion_messages() {
                        let mut peers = self.pending_messages.lock().unwrap();
                        peers.insert(their_node_id.clone(), VecDeque::new());