f - Fix fuzz test

Author: jkczyz

lightning/src/ln/channelmanager.rs

@@ -1158,8 +1158,10 @@ impl<Signer: Sign, M: Deref, T: Deref, K: Deref, F: Deref, L: Deref> ChannelMana
 
 		let their_features = {
 			let per_peer_state = self.per_peer_state.read().unwrap();
-			let peer_state = per_peer_state.get(&their_network_key).unwrap().lock().unwrap();
-			peer_state.latest_features.clone()
+			match per_peer_state.get(&their_network_key) {
+				Some(peer_state) => peer_state.lock().unwrap().latest_features.clone(),
+				None => return Err(APIError::ChannelUnavailable { err: format!("Not connected to node: {}", their_network_key) }),
+			}
 		};
 		let config = if override_config.is_some() { override_config.as_ref().unwrap() } else { &self.default_configuration };
 		let channel = Channel::new_outbound(&self.fee_estimator, &self.keys_manager, their_network_key, their_features, channel_value_satoshis, push_msat, user_id, config)?;
@@ -1264,8 +1266,10 @@ impl<Signer: Sign, M: Deref, T: Deref, K: Deref, F: Deref, L: Deref> ChannelMana
 					let counterparty_node_id = chan_entry.get().get_counterparty_node_id();
 					let their_features = {
 						let per_peer_state = self.per_peer_state.read().unwrap();
-						let peer_state = per_peer_state.get(&counterparty_node_id).unwrap().lock().unwrap();
-						peer_state.latest_features.clone()
+						match per_peer_state.get(&counterparty_node_id) {
+							Some(peer_state) => peer_state.lock().unwrap().latest_features.clone(),
+							None => return Err(APIError::ChannelUnavailable { err: format!("Not connected to node: {}", counterparty_node_id) }),
+						}
 					};
 					let (shutdown_msg, monitor_update, failed_htlcs) = chan_entry.get_mut().get_shutdown(&self.keys_manager, &their_features)?;
 					channel_state.pending_msg_events.push(events::MessageSendEvent::SendShutdown {