Persist inbound channel coming through OpenChannelRequest

  - Add `peer_store` and `peer_manager` to `[EventHandler::new]`
    function
  - Persist channel peer info in `[LdkEvent::OpenChannelRequest]` event

Author: jbesraa

src/event.rs

@@ -1,5 +1,8 @@
+use crate::peer_store::{PeerInfo, PeerStore};
+use crate::types::PeerManager;
 use crate::{
 	hex_utils, ChannelManager, Config, Error, KeysManager, NetworkGraph, UserChannelId, Wallet,
+	FilesystemLogger
 };
 
 use crate::payment_store::{
@@ -251,6 +254,8 @@ where
 	runtime: Arc<RwLock<Option<tokio::runtime::Runtime>>>,
 	logger: L,
 	config: Arc<Config>,
+	peer_manager: Arc<PeerManager<K>>,
+	peer_store: Arc<PeerStore<K, Arc<FilesystemLogger>>>,
 }
 
 impl<K: KVStore + Sync + Send + 'static, L: Deref> EventHandler<K, L>
@@ -262,6 +267,8 @@ where
 		channel_manager: Arc<ChannelManager<K>>, network_graph: Arc<NetworkGraph>,
 		keys_manager: Arc<KeysManager>, payment_store: Arc<PaymentStore<K, L>>,
 		runtime: Arc<RwLock<Option<tokio::runtime::Runtime>>>, logger: L, config: Arc<Config>,
+		peer_manager: Arc<PeerManager<K>>,
+		peer_store: Arc<PeerStore<K, Arc<FilesystemLogger>>>,
 	) -> Self {
 		Self {
 			event_queue,
@@ -273,6 +280,8 @@ where
 			logger,
 			runtime,
 			config,
+			peer_manager,
+			peer_store
 		}
 	}
 
@@ -641,6 +650,25 @@ where
 							if allow_0conf { " trusted" } else { "" },
 							counterparty_node_id,
 						);
+						// Persist channel
+						let peer_node_ids = self.peer_manager.get_peer_node_ids();
+						if let Some(peer) = peer_node_ids.iter().find(|(node_id, _)| node_id == &counterparty_node_id) {
+							let address = match peer.1.clone() {
+								Some(address) => address,
+								None => {
+									log_error!(self.logger, "Failed to add peer to peer store: no network address found");
+									return;
+								}
+							};
+							let peer = PeerInfo { node_id: counterparty_node_id, address: address.into() };
+							if let Err(e) = self.peer_store.add_peer(peer) {
+									log_error!(self.logger, "Failed to add peer to peer store: {}", e);
+							};
+							log_info!(
+								self.logger,
+								"Persisted inbound channel from peer {}", counterparty_node_id
+							);
+						}
 					}
 					Err(e) => {
 						log_error!(

src/lib.rs

@@ -656,6 +656,8 @@ impl<K: KVStore + Sync + Send + 'static> Node<K> {
 			Arc::clone(&self.runtime),
 			Arc::clone(&self.logger),
 			Arc::clone(&self.config),
+			Arc::clone(&self.peer_manager),
+			Arc::clone(&self.peer_store),
 		));
 
 		// Setup background processing