From d8a282eb65e33e882b0c83604f5d5f01ef300bfe Mon Sep 17 00:00:00 2001 From: Joonas Koivunen Date: Thu, 28 Jan 2021 08:53:16 +0200 Subject: [PATCH] test: split off common_tests from common --- tests/common/mod.rs | 51 ------------------------------------------- tests/common_tests.rs | 51 +++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 51 insertions(+), 51 deletions(-) create mode 100644 tests/common_tests.rs diff --git a/tests/common/mod.rs b/tests/common/mod.rs index 558e42ecf..f88567eed 100644 --- a/tests/common/mod.rs +++ b/tests/common/mod.rs @@ -61,54 +61,3 @@ pub async fn spawn_nodes(count: usize, topology: Topology) -> Vec { nodes } - -#[cfg(test)] -mod tests { - use super::*; - - const N: usize = 5; - - #[tokio::test] - async fn check_topology_line() { - let nodes = spawn_nodes(N, Topology::Line).await; - - for (i, node) in nodes.iter().enumerate() { - if i == 0 || i == N - 1 { - assert_eq!(node.peers().await.unwrap().len(), 1); - } else { - assert_eq!(node.peers().await.unwrap().len(), 2); - } - } - } - - #[tokio::test] - async fn check_topology_ring() { - let nodes = spawn_nodes(N, Topology::Ring).await; - - for node in &nodes { - assert_eq!(node.peers().await.unwrap().len(), 2); - } - } - - #[tokio::test] - async fn check_topology_mesh() { - let nodes = spawn_nodes(N, Topology::Mesh).await; - - for node in &nodes { - assert_eq!(node.peers().await.unwrap().len(), N - 1); - } - } - - #[tokio::test] - async fn check_topology_star() { - let nodes = spawn_nodes(N, Topology::Star).await; - - for (i, node) in nodes.iter().enumerate() { - if i == 0 { - assert_eq!(node.peers().await.unwrap().len(), N - 1); - } else { - assert_eq!(node.peers().await.unwrap().len(), 1); - } - } - } -} diff --git a/tests/common_tests.rs b/tests/common_tests.rs new file mode 100644 index 000000000..7c63820ec --- /dev/null +++ b/tests/common_tests.rs @@ -0,0 +1,51 @@ +mod common; +use common::{spawn_nodes, Topology}; + +// these tests are here instead of being under common/mod.rs so that they wont be executed as part +// of every `test/` case which includes `mod common;`. + +const N: usize = 5; + +#[tokio::test] +async fn check_topology_line() { + let nodes = spawn_nodes(N, Topology::Line).await; + + for (i, node) in nodes.iter().enumerate() { + if i == 0 || i == N - 1 { + assert_eq!(node.peers().await.unwrap().len(), 1); + } else { + assert_eq!(node.peers().await.unwrap().len(), 2); + } + } +} + +#[tokio::test] +async fn check_topology_ring() { + let nodes = spawn_nodes(N, Topology::Ring).await; + + for node in &nodes { + assert_eq!(node.peers().await.unwrap().len(), 2); + } +} + +#[tokio::test] +async fn check_topology_mesh() { + let nodes = spawn_nodes(N, Topology::Mesh).await; + + for node in &nodes { + assert_eq!(node.peers().await.unwrap().len(), N - 1); + } +} + +#[tokio::test] +async fn check_topology_star() { + let nodes = spawn_nodes(N, Topology::Star).await; + + for (i, node) in nodes.iter().enumerate() { + if i == 0 { + assert_eq!(node.peers().await.unwrap().len(), N - 1); + } else { + assert_eq!(node.peers().await.unwrap().len(), 1); + } + } +}