Skip to content
This repository was archived by the owner on Oct 23, 2022. It is now read-only.

Commit 23fc80b

Browse files
bors[bot]koivunej
andauthored
Merge #455
455: test: split off common_tests from common r=koivunej a=koivunej Tiny refactoring to stop testing `common::tests` as part of every top level `test/*.rs`, noticed during #454. Co-authored-by: Joonas Koivunen <joonas.koivunen@gmail.com>
2 parents cf37032 + d8a282e commit 23fc80b

File tree

2 files changed

+51
-51
lines changed

2 files changed

+51
-51
lines changed

tests/common/mod.rs

Lines changed: 0 additions & 51 deletions
Original file line numberDiff line numberDiff line change
@@ -61,54 +61,3 @@ pub async fn spawn_nodes(count: usize, topology: Topology) -> Vec<Node> {
6161

6262
nodes
6363
}
64-
65-
#[cfg(test)]
66-
mod tests {
67-
use super::*;
68-
69-
const N: usize = 5;
70-
71-
#[tokio::test]
72-
async fn check_topology_line() {
73-
let nodes = spawn_nodes(N, Topology::Line).await;
74-
75-
for (i, node) in nodes.iter().enumerate() {
76-
if i == 0 || i == N - 1 {
77-
assert_eq!(node.peers().await.unwrap().len(), 1);
78-
} else {
79-
assert_eq!(node.peers().await.unwrap().len(), 2);
80-
}
81-
}
82-
}
83-
84-
#[tokio::test]
85-
async fn check_topology_ring() {
86-
let nodes = spawn_nodes(N, Topology::Ring).await;
87-
88-
for node in &nodes {
89-
assert_eq!(node.peers().await.unwrap().len(), 2);
90-
}
91-
}
92-
93-
#[tokio::test]
94-
async fn check_topology_mesh() {
95-
let nodes = spawn_nodes(N, Topology::Mesh).await;
96-
97-
for node in &nodes {
98-
assert_eq!(node.peers().await.unwrap().len(), N - 1);
99-
}
100-
}
101-
102-
#[tokio::test]
103-
async fn check_topology_star() {
104-
let nodes = spawn_nodes(N, Topology::Star).await;
105-
106-
for (i, node) in nodes.iter().enumerate() {
107-
if i == 0 {
108-
assert_eq!(node.peers().await.unwrap().len(), N - 1);
109-
} else {
110-
assert_eq!(node.peers().await.unwrap().len(), 1);
111-
}
112-
}
113-
}
114-
}

tests/common_tests.rs

Lines changed: 51 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,51 @@
1+
mod common;
2+
use common::{spawn_nodes, Topology};
3+
4+
// these tests are here instead of being under common/mod.rs so that they wont be executed as part
5+
// of every `test/` case which includes `mod common;`.
6+
7+
const N: usize = 5;
8+
9+
#[tokio::test]
10+
async fn check_topology_line() {
11+
let nodes = spawn_nodes(N, Topology::Line).await;
12+
13+
for (i, node) in nodes.iter().enumerate() {
14+
if i == 0 || i == N - 1 {
15+
assert_eq!(node.peers().await.unwrap().len(), 1);
16+
} else {
17+
assert_eq!(node.peers().await.unwrap().len(), 2);
18+
}
19+
}
20+
}
21+
22+
#[tokio::test]
23+
async fn check_topology_ring() {
24+
let nodes = spawn_nodes(N, Topology::Ring).await;
25+
26+
for node in &nodes {
27+
assert_eq!(node.peers().await.unwrap().len(), 2);
28+
}
29+
}
30+
31+
#[tokio::test]
32+
async fn check_topology_mesh() {
33+
let nodes = spawn_nodes(N, Topology::Mesh).await;
34+
35+
for node in &nodes {
36+
assert_eq!(node.peers().await.unwrap().len(), N - 1);
37+
}
38+
}
39+
40+
#[tokio::test]
41+
async fn check_topology_star() {
42+
let nodes = spawn_nodes(N, Topology::Star).await;
43+
44+
for (i, node) in nodes.iter().enumerate() {
45+
if i == 0 {
46+
assert_eq!(node.peers().await.unwrap().len(), N - 1);
47+
} else {
48+
assert_eq!(node.peers().await.unwrap().len(), 1);
49+
}
50+
}
51+
}

0 commit comments

Comments
 (0)