mirror of
https://github.com/nushell/nushell.git
synced 2024-10-16 23:33:49 +02:00
656f707a0b
# Description The working directory doesn't have to be set for those tests (or would be the default anyways). When appropriate also remove calls to the `pipeline()` function. In most places kept the diff minimal and only removed the superfluous part to not pollute the blame view. With simpler tests also simplified things to make them more readable overall (this included removal of the raw string literal). Work for #8670
47 lines
1.3 KiB
Rust
47 lines
1.3 KiB
Rust
use nu_test_support::{nu, pipeline};
|
|
use std::net::TcpListener;
|
|
use std::sync::mpsc;
|
|
|
|
#[test]
|
|
fn port_with_invalid_range() {
|
|
let actual = nu!("port 4000 3999");
|
|
|
|
assert!(actual.err.contains("Invalid range"))
|
|
}
|
|
|
|
#[test]
|
|
fn port_with_already_usage() {
|
|
let retry_times = 10;
|
|
for _ in 0..retry_times {
|
|
let (tx, rx) = mpsc::sync_channel(0);
|
|
|
|
// let system pick a free port for us.
|
|
let free_port = {
|
|
let listener = TcpListener::bind("127.0.0.1:0").expect("failed to pick a port");
|
|
listener.local_addr().unwrap().port()
|
|
};
|
|
let handler = std::thread::spawn(move || {
|
|
let _listener = TcpListener::bind(format!("127.0.0.1:{free_port}"));
|
|
let _ = rx.recv();
|
|
});
|
|
let actual = nu!(pipeline(&format!("port {free_port} {free_port}")));
|
|
let _ = tx.send(true);
|
|
// make sure that the thread is closed and we release the port.
|
|
handler.join().unwrap();
|
|
|
|
// check for error kind str.
|
|
if actual.err.contains("AddrInUse") {
|
|
return;
|
|
}
|
|
}
|
|
panic!("already check port report AddrInUse for several times, but still failed.");
|
|
}
|
|
|
|
#[test]
|
|
fn port_from_system_given() {
|
|
let actual = nu!("port");
|
|
|
|
// check that we can get an integer port from system.
|
|
assert!(actual.out.parse::<u16>().unwrap() > 0)
|
|
}
|