diff --git a/noxis-rs/src/utils/services.rs b/noxis-rs/src/utils/services.rs index cdee768..0d90921 100644 --- a/noxis-rs/src/utils/services.rs +++ b/noxis-rs/src/utils/services.rs @@ -1,6 +1,5 @@ -use crate::options::structs::CustomError; use log::{error, warn}; -use std::net::{TcpStream, ToSocketAddrs}; +use std::net::ToSocketAddrs; use std::sync::Arc; use tokio::time::Duration; use tokio::sync::mpsc::Sender as Sender; @@ -236,31 +235,15 @@ pub mod v2 { } } - -async fn check_service(hostname: &str, port: &u32) -> Result<(), CustomError> { - let addr = format!("{}:{}", hostname, port); - - match addr.to_socket_addrs() { - Ok(mut addrs) => { - if addrs.any(|a| TcpStream::connect_timeout(&a, Duration::new(1, 0)).is_ok()) { - Ok(()) - } else { - Err(CustomError::Fatal) - } - } - Err(_) => Err(CustomError::Fatal), - } -} - #[cfg(test)] mod service_unittests { - use super::check_service; - #[tokio::test] - async fn check_available_service() { - assert!(check_service("ya.ru", &443).await.is_ok()); - } - #[tokio::test] - async fn check_unavailable_service() { - assert!(check_service("unavailable.service", &1111).await.is_err()); - } + // use super::check_service; + // #[tokio::test] + // async fn check_available_service() { + // assert!(check_service("ya.ru", &443).await.is_ok()); + // } + // #[tokio::test] + // async fn check_unavailable_service() { + // assert!(check_service("unavailable.service", &1111).await.is_err()); + // } }