Print version at startup

Author: ufoscout

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "wait"
-version = "2.7.0"
+version = "2.7.1"
 authors = ["ufoscout <[email protected]>"]
 edition = "2018"
 

Cargo.toml

@@ -41,5 +41,4 @@ mod test {
         nanosec = nanosec + 10;
         assert_eq!(nanosec.to_string(), env_var(&env_key, nanosec.to_string()));
     }
-
 }

src/env_reader/mod.rs

@@ -20,10 +20,18 @@ pub fn wait(
     on_timeout: &mut dyn FnMut(),
 ) {
     println!("{}", LINE_SEPARATOR);
-    println!("docker-compose-wait - starting with configuration:");
+    println!(" docker-compose-wait {}", env!("CARGO_PKG_VERSION"));
+    println!("---------------------------");
+    println!("Starting with configuration:");
     println!(" - Hosts to be waiting for: [{}]", config.hosts);
-    println!(" - Timeout before failure: {} seconds ", config.global_timeout);
-    println!(" - TCP connection timeout before retry: {} seconds ", config.tcp_connection_timeout);
+    println!(
+        " - Timeout before failure: {} seconds ",
+        config.global_timeout
+    );
+    println!(
+        " - TCP connection timeout before retry: {} seconds ",
+        config.tcp_connection_timeout
+    );
     println!(
         " - Sleeping time before checking for hosts availability: {} seconds",
         config.wait_before
@@ -51,7 +59,14 @@ pub fn wait(
         sleep.reset();
         for host in config.hosts.trim().split(',') {
             println!("Checking availability of {}", host);
-            while !port_check::is_port_reachable_with_timeout(&host.trim().to_string().parse().expect("The host IP should be valid"), Duration::from_secs(config.tcp_connection_timeout)) {
+            while !port_check::is_port_reachable_with_timeout(
+                &host
+                    .trim()
+                    .to_string()
+                    .parse()
+                    .expect("The host IP should be valid"),
+                Duration::from_secs(config.tcp_connection_timeout),
+            ) {
                 println!("Host {} not yet available...", host);
                 if sleep.elapsed(config.global_timeout) {
                     println!(
@@ -188,7 +203,14 @@ mod test {
         assert_eq!(1, config.wait_sleep_interval);
     }
 
-    fn set_env(hosts: &str, timeout: &str, before: &str, after: &str, sleep: &str, tcp_timeout: &str) {
+    fn set_env(
+        hosts: &str,
+        timeout: &str,
+        before: &str,
+        after: &str,
+        sleep: &str,
+        tcp_timeout: &str,
+    ) {
         env::set_var("WAIT_BEFORE_HOSTS", before.to_string());
         env::set_var("WAIT_AFTER_HOSTS", after.to_string());
         env::set_var("WAIT_HOSTS_TIMEOUT", timeout.to_string());

src/lib.rs

@@ -47,15 +47,23 @@ fn should_wait_before_and_after() {
 fn should_execute_without_wait() {
     let start = Instant::now();
     let mut sleeper = MillisSleeper::default();
-    wait::wait(&mut sleeper, &new_config("", 1, 0, 0, 1, 1), &mut on_timeout);
+    wait::wait(
+        &mut sleeper,
+        &new_config("", 1, 0, 0, 1, 1),
+        &mut on_timeout,
+    );
     assert!(millis_elapsed(start) <= 5)
 }
 
 #[test]
 fn should_sleep_the_specified_time_between_checks() {
     let start = Instant::now();
     let mut sleeper = MillisSleeper::default();
-    wait::wait(&mut sleeper, &new_config("198.19.255.255:1", 2_000, 0, 0, 10, 1), &mut on_timeout);
+    wait::wait(
+        &mut sleeper,
+        &new_config("198.19.255.255:1", 2_000, 0, 0, 10, 1),
+        &mut on_timeout,
+    );
     let elapsed = millis_elapsed(start);
     assert!(elapsed >= 2010);
     assert!(elapsed < 3000);
@@ -192,7 +200,14 @@ fn should_fail_if_not_all_hosts_are_available() {
 
 fn on_timeout() {}
 
-fn new_config(hosts: &str, timeout: u64, before: u64, after: u64, sleep: u64, tcp_connection_timeout: u64) -> wait::Config {
+fn new_config(
+    hosts: &str,
+    timeout: u64,
+    before: u64,
+    after: u64,
+    sleep: u64,
+    tcp_connection_timeout: u64,
+) -> wait::Config {
     wait::Config {
         hosts: hosts.to_string(),
         global_timeout: timeout,