add to last vala

Author: Aditya Sharma

lightning/src/ln/channelmanager.rs

@@ -8172,7 +8172,29 @@ This indicates a bug inside LDK. Please report this error at https://github.com/
 		}
 	}
 
-	fn internal_peer_storage_retrieval(&self, _counterparty_node_id: &PublicKey, _msg: &msgs::PeerStorageRetrievalMessage) {}
+	fn internal_peer_storage_retrieval(&self, counterparty_node_id: &PublicKey, _msg: &msgs::PeerStorageRetrievalMessage) {
+		// TODO: Decrypt and check if have any stale or missing ChannelMonitor.
+		let per_peer_state = self.per_peer_state.read().unwrap();
+		let peer_state_mutex = match per_peer_state.get(counterparty_node_id) {
+			Some(peer_state_mutex) => peer_state_mutex,
+			None => return,
+		};
+		let mut peer_state_lock = peer_state_mutex.lock().unwrap();
+		let peer_state = &mut *peer_state_lock;
+		let logger = WithContext::from(&self.logger, Some(*counterparty_node_id), None, None);
+
+		log_debug!(logger, "Received unexpected peer_storage_retrieval from {}. This is unusual since we do not yet distribute peer storage. Sending a warning.", log_pubkey!(counterparty_node_id));
+		peer_state.pending_msg_events.push(events::MessageSendEvent::HandleError {
+			node_id: counterparty_node_id.clone(),
+			action: msgs::ErrorAction::SendWarningMessage {
+				msg: msgs::WarningMessage {
+					channel_id: ChannelId([0; 32]),
+					data: "Invalid peer_storage_retrieval message received.".to_owned()
+				},
+				log_level: Level::Trace,
+			}
+		});
+	}
 
 	fn internal_peer_storage(&self, counterparty_node_id: &PublicKey, msg: &msgs::PeerStorageMessage) {
 		let per_peer_state = self.per_peer_state.read().unwrap();