Nickiel/church_controller_rust
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

each test needs a unique socket to not error

Browse source
This commit is contained in:
Nickiel12 2021-12-17 18:03:30 -08:00
parent 2d3d27fbfb
commit ebbc4ff5f9
1 changed files with 7 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
src/tests/socket_handler_tests.rs
View file

@ -5,20 +5,18 @@ use std::time::Duration;
use crate::{SERVER_ADDRESS, modules::socket_handler::Socket}; use crate::{SERVER_ADDRESS, modules::socket_handler::Socket};
#[test] #[test]
fn can_make_socket_listener(){ fn can_make_socket_listener(){
let listener = Socket::make_listener(SERVER_ADDRESS); let listener = Socket::make_listener("localhost:5001");
drop(listener); drop(listener);
} }
#[test] #[test]
fn create_and_connect_to_listener() { fn create_and_connect_to_listener() {
let listener = Socket::make_listener(SERVER_ADDRESS); let listener = Socket::make_listener("localhost:5002");
let join_handle = std::thread::spawn(move || { let join_handle = std::thread::spawn(move || {
let _outgoing = std::net::TcpStream::connect(SERVER_ADDRESS).unwrap(); let _outgoing = std::net::TcpStream::connect("localhost:5002").unwrap();
}); });
join_handle.join().unwrap(); join_handle.join().unwrap();
drop(listener); drop(listener);
@ -27,19 +25,20 @@ fn create_and_connect_to_listener() {
#[test] #[test]
#[should_panic] #[should_panic]
fn panic_no_listener() { fn panic_no_listener() {
let _outgoing = std::net::TcpStream::connect("localhost").unwrap(); let _outgoing = std::net::TcpStream::connect("localhost:5003").unwrap();
} }
#[test] #[test]
fn can_handle_messages() { fn can_handle_messages() {
let listener = Socket::make_listener(SERVER_ADDRESS); let listener = Socket::make_listener("localhost:5004");
let (tx_1, rx_1) = mpsc::channel::<String>(); let (tx_1, rx_1) = mpsc::channel::<String>();
let (mut flag, connection_handle) = Socket::handle_connections(listener, tx_1); let (mut flag, connection_handle) = Socket::handle_connections(listener, tx_1);
let join_handle = std::thread::spawn(move || { let join_handle = std::thread::spawn(move || {
let mut outgoing = std::net::TcpStream::connect(SERVER_ADDRESS).unwrap(); let mut outgoing = std::net::TcpStream::connect("localhost:5004").unwrap();
outgoing.write("this is a test".as_bytes()).unwrap(); outgoing.write("this is a test".as_bytes()).unwrap();
drop(outgoing);
}); });
join_handle.join().unwrap(); join_handle.join().unwrap();
thread::sleep(Duration::from_millis(1000)); thread::sleep(Duration::from_millis(1000));