icmp-client 0.2.0

use std::{
    io::Error as IoError,
    net::{SocketAddr, UdpSocket},
    sync::Arc,
};

use async_io::Async;
use async_trait::async_trait;

use crate::{config::Config, utils::new_std_udp_socket, AsyncClient, AsyncClientWithConfigError};

//
#[derive(Debug, Clone)]
pub struct Client {
    inner: Arc<Async<UdpSocket>>,
}

impl Client {
    pub fn new(config: &Config) -> Result<Self, AsyncClientWithConfigError> {
        let udp_socket = new_std_udp_socket(config)?;
        let inner = Async::new(udp_socket)?;
        Ok(Self {
            inner: Arc::new(inner),
        })
    }
}

#[async_trait]
impl AsyncClient for Client {
    fn with_config(config: &Config) -> Result<Self, AsyncClientWithConfigError> {
        Client::new(config)
    }

    async fn send_to<A: Into<SocketAddr> + Send>(
        &self,
        buf: &[u8],
        addr: A,
    ) -> Result<usize, IoError> {
        self.inner.send_to(buf, addr.into()).await
    }
    async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr), IoError> {
        self.inner.recv_from(buf).await
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[tokio::test]
    async fn test_client() -> Result<(), Box<dyn std::error::Error>> {
        crate::tests_helper::ping_ipv4::<Client>("127.0.0.1".parse().expect("Never")).await?;

        match crate::tests_helper::ping_ipv6::<Client>("::1".parse().expect("Never")).await {
            Ok(_) => {}
            Err(err) => {
                if let Some(AsyncClientWithConfigError::IcmpV6ProtocolNotSupported(_)) =
                    err.downcast_ref::<AsyncClientWithConfigError>()
                {
                    let info = os_info::get();
                    if info.os_type() == os_info::Type::CentOS
                        && matches!(info.version(), os_info::Version::Semantic(7, 0, 0))
                    {
                        eprintln!("CentOS 7 doesn't support IcmpV6");
                    } else {
                        panic!("{err:?}")
                    }
                } else {
                    panic!("{err:?}")
                }
            }
        }

        Ok(())
    }
}