Stowage/noita_entangled_worlds
2
0
Fork 0
mirror of https://github.com/IntQuant/noita_entangled_worlds.git synced 2025-10-19 15:13:16 +00:00
Code Issues Projects Releases Packages Wiki Activity

Make a test for p2p in tangled

Browse source
This commit is contained in:
IQuant 2024-10-13 14:03:43 +03:00
parent da5f767623
commit bf5a2079dd
1 changed files with 26 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

26
noita-proxy/tangled/src/lib.rs
View file

@ -254,4 +254,30 @@ mod test {
assert_eq!(peer1.recv().next(), None); assert_eq!(peer1.recv().next(), None);
} }
#[test_log::test(tokio::test)]
async fn test_p2p() {
let settings: Option<Settings> = Some(Default::default());
let addr = "127.0.0.1:56005".parse().unwrap();
let host = Peer::host(addr, settings.clone()).unwrap();
assert_eq!(host.shared.remote_peers.len(), 1);
let peer1 = Peer::connect(addr, settings.clone()).unwrap();
let peer2 = Peer::connect(addr, settings.clone()).unwrap();
tokio::time::sleep(Duration::from_millis(10)).await;
assert_eq!(host.shared.remote_peers.len(), 3);
peer1
.send(
peer2.my_id().unwrap(),
vec![123, 32, 51],
Reliability::Reliable,
)
.unwrap();
tokio::time::sleep(Duration::from_millis(10)).await;
let events = peer2.recv().collect::<Vec<_>>();
assert!(events.contains(&NetworkEvent::Message(Message {
src: peer1.my_id().unwrap(),
data: vec![123, 32, 51],
})))
}
} }