aboutsummaryrefslogtreecommitdiff
path: root/server/src
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2025-12-18 20:38:43 +0100
committermetamuffin <metamuffin@disroot.org>2025-12-18 22:49:18 +0100
commiteb9412a2847a199f04e74d8a17481b7d0c9e36a6 (patch)
tree6d6860f9a769d3d01a9d7dce0d8717fe211b2792 /server/src
parent384973975e8d9760d4be6d25c3e8d3dab3758d6f (diff)
downloadhurrycurry-eb9412a2847a199f04e74d8a17481b7d0c9e36a6.tar
hurrycurry-eb9412a2847a199f04e74d8a17481b7d0c9e36a6.tar.bz2
hurrycurry-eb9412a2847a199f04e74d8a17481b7d0c9e36a6.tar.zst
remove tokio from unit tests
Diffstat (limited to 'server/src')
-rw-r--r--server/src/main.rs98
1 files changed, 39 insertions, 59 deletions
diff --git a/server/src/main.rs b/server/src/main.rs
index 0b1ab375..cca5ec95 100644
--- a/server/src/main.rs
+++ b/server/src/main.rs
@@ -333,16 +333,8 @@ mod test {
ConnectionID,
server::{Server, ServerConfig},
};
- use std::future::Future;
use tokio::sync::broadcast;
- fn harness(body: impl Future) {
- tokio::runtime::Builder::new_current_thread()
- .enable_all()
- .build()
- .unwrap()
- .block_on(body);
- }
fn server() -> Server {
Server::new(
"../data".into(),
@@ -354,76 +346,64 @@ mod test {
#[test]
fn init_server() {
- harness(async {
- server();
- });
+ server();
}
#[test]
fn full_game() {
- harness(async {
- let mut s = server();
- s.load(s.index.generate_with_book("junior").unwrap(), None);
- while s.tick(0.1).is_none() {}
- });
+ let mut s = server();
+ s.load(s.index.generate_with_book("junior").unwrap(), None);
+ while s.tick(0.1).is_none() {}
}
#[test]
fn map_load() {
- harness(async {
- let mut s = server();
- s.load(s.index.generate("5star").unwrap(), None);
- });
+ let mut s = server();
+ s.load(s.index.generate("5star").unwrap(), None);
}
#[test]
fn map_load_book() {
- harness(async {
- let mut s = server();
- s.load(s.index.generate_with_book("lobby").unwrap(), None);
- });
+ let mut s = server();
+ s.load(s.index.generate_with_book("lobby").unwrap(), None);
}
#[test]
fn tick() {
- harness(async {
- let mut s = server();
- for _ in 0..100 {
- s.tick(0.1);
- }
- });
+ let mut s = server();
+ for _ in 0..100 {
+ s.tick(0.1);
+ }
}
#[test]
fn packet_sender_verif() {
- harness(async {
- let mut s = server();
+ let mut s = server();
- for (conn, p) in [
- PacketS::Effect {
- player: PlayerID(0),
- name: "test".to_owned(),
- },
- PacketS::Leave {
- player: PlayerID(0),
+ for (conn, p) in [
+ PacketS::Effect {
+ player: PlayerID(0),
+ name: "test".to_owned(),
+ },
+ PacketS::Leave {
+ player: PlayerID(0),
+ },
+ PacketS::ReplayTick { dt: 1. },
+ ]
+ .into_iter()
+ .enumerate()
+ {
+ s.packet_in_outer(
+ ConnectionID(conn.try_into().unwrap()),
+ PacketS::Join {
+ name: format!("test {conn}"),
+ character: Character::default(),
+ class: PlayerClass::Chef,
+ id: None,
+ position: None,
},
- PacketS::ReplayTick { dt: 1. },
- ]
- .into_iter()
- .enumerate()
- {
- s.packet_in_outer(
- ConnectionID(conn.try_into().unwrap()),
- PacketS::Join {
- name: format!("test {conn}"),
- character: Character::default(),
- class: PlayerClass::Chef,
- id: None,
- position: None,
- },
- )
- .unwrap();
+ )
+ .unwrap();
- let x = s.packet_in_outer(ConnectionID(conn.try_into().unwrap()), p);
- assert!(x.is_ok(), "test {} {:?}", conn, x)
- }
- });
+ let x = s.packet_in_outer(ConnectionID(conn.try_into().unwrap()), p);
+ assert!(x.is_ok(), "test {} {:?}", conn, x)
+ }
}
}