From 63cebd27cd586f1e047a2d247e4aa3fc3ac18868 Mon Sep 17 00:00:00 2001 From: Jedrzej Stuczynski Date: Tue, 14 Jan 2020 12:40:04 +0000 Subject: [PATCH] Filtering topology by node version --- common/topology/src/lib.rs | 28 ++++++++++++++++++++++++---- 1 file changed, 24 insertions(+), 4 deletions(-) diff --git a/common/topology/src/lib.rs b/common/topology/src/lib.rs index f4fa4a2e88..62c5ca5c2f 100644 --- a/common/topology/src/lib.rs +++ b/common/topology/src/lib.rs @@ -165,10 +165,30 @@ pub trait NymTopology: Sized { Ok(all_paths) } - fn filter_node_versions(&self, mix_version: &str, provider_version: &str, coco_version: &str) -> Self { - let filtered_mixes = self.get_mix_nodes().iter().cloned().filter(|mix_node| mix_node.version == mix_version).collect(); - let filtered_providers = self.get_mix_provider_nodes().iter().cloned().filter(|provider_node| provider_node.version == provider_version).collect(); - let filtered_coco_nodes = self.get_coco_nodes().iter().cloned().filter(|coco_node| coco_node.version == coco_version).collect(); + fn filter_node_versions( + &self, + mix_version: &str, + provider_version: &str, + coco_version: &str, + ) -> Self { + let filtered_mixes = self + .get_mix_nodes() + .iter() + .cloned() + .filter(|mix_node| mix_node.version == mix_version) + .collect(); + let filtered_providers = self + .get_mix_provider_nodes() + .iter() + .cloned() + .filter(|provider_node| provider_node.version == provider_version) + .collect(); + let filtered_coco_nodes = self + .get_coco_nodes() + .iter() + .cloned() + .filter(|coco_node| coco_node.version == coco_version) + .collect(); Self::new_from_nodes(filtered_mixes, filtered_providers, filtered_coco_nodes) }