use std::net::IpAddr;
use std::time::Duration;
use tokio::sync::mpsc::Sender;
use tokio::task;

pub enum PingResult {
    NoPingErr { id: u32, error: String },
    Ping { rrt: u64, ttl: u32, id: u32 },
}

pub fn spawn_ping(target: IpAddr, tx: Sender<PingResult>, id: u32) {
    // let _ = tx.try_send(PingResult::NoPingErr { id, error: "Test Ping".to_string() });
    task::spawn_blocking(move || {
        let result = do_ping(target, id);
        let _ = tx.try_send(result);
    });
}

fn do_ping(target: IpAddr, id: u32) -> PingResult {
    let payload: [u8; 24] = [0u8; 24];

    let result = ping::new(target)
        .timeout(Duration::from_secs(3))
        .payload(&payload)
        .send();

    match result {
        Ok(reply) => PingResult::Ping {
            rrt: reply.rtt.as_millis() as u64,
            ttl: reply.ttl.unwrap_or(0) as u32,
            id,
        },
        Err(e) => PingResult::NoPingErr { id, error: format!("Ping failed: {}", e) },
    }
}