use smoltcp::{
    phy::{self, Device, DeviceCapabilities, Medium},
    time::Instant,
};
use std::{
    io,
    net::{IpAddr, Ipv4Addr},
    sync::Arc,
    vec::Vec,
};

/// A virtual TUN (IP) interface.
pub struct WinTunInterface {
    inner: Arc<wintun::Session>,
    mtu: usize,
    medium: Medium,
}

// impl AsRawFd for WinTunInterface {
//     fn as_raw_fd(&self) -> RawFd {
//         self.inner.borrow().as_raw_fd()
//     }
// }

impl WinTunInterface {
    pub fn new(name: &str, medium: Medium) -> io::Result<WinTunInterface> {
        let wintun = unsafe { wintun::load() }.map_err(|e| io::Error::new(io::ErrorKind::Other, e))?;
        let tun_name = name;
        let adapter = match wintun::Adapter::open(&wintun, tun_name) {
            Ok(a) => a,
            Err(_) => wintun::Adapter::create(&wintun, tun_name, tun_name, None)
                .map_err(|e| io::Error::new(io::ErrorKind::Other, e))?,
        };

        let address = Ipv4Addr::new(10, 1, 0, 33);
        let mask = Ipv4Addr::new(255, 255, 255, 0);
        let gateway = Some(IpAddr::V4(Ipv4Addr::new(10, 1, 0, 1)));
        adapter
            .set_network_addresses_tuple(IpAddr::V4(address), IpAddr::V4(mask), gateway)
            .map_err(|e| io::Error::new(io::ErrorKind::Other, e))?;

        let session = adapter
            .start_session(wintun::MAX_RING_CAPACITY)
            .map_err(|e| io::Error::new(io::ErrorKind::Other, e))?;
        let inner = Arc::new(session);

        // let inner = WinTunInterfaceDesc::new(name, medium)?;
        // let mtu = inner.interface_mtu()?;
        let mtu = 1500;
        Ok(WinTunInterface { inner, mtu, medium })
    }
}

impl Drop for WinTunInterface {
    fn drop(&mut self) {
        if let Err(e) = self.inner.shutdown() {
            log::error!("phy: failed to shutdown interface: {}", e);
        }
    }
}

impl Device for WinTunInterface {
    type RxToken<'a> = RxToken;
    type TxToken<'a> = TxToken;

    fn capabilities(&self) -> DeviceCapabilities {
        let mut v = DeviceCapabilities::default();
        v.max_transmission_unit = self.mtu;
        v.medium = self.medium;
        v
    }

    fn receive(&mut self, _timestamp: Instant) -> Option<(Self::RxToken<'_>, Self::TxToken<'_>)> {
        let inner = self.inner.clone();
        match inner.receive_blocking() {
            Ok(read_pack) => Some((
                RxToken {
                    buffer: read_pack.bytes().to_vec(),
                },
                TxToken { inner },
            )),
            Err(err) => {
                log::error!("phy: failed to receive packet: {}", err);
                None
            }
        }

        // match inner.recv(&mut buffer[..]) {
        //     Ok(size) => {
        //         buffer.resize(size, 0);
        //         let rx = RxToken { buffer };
        //         let tx = TxToken {
        //             inner: self.inner.clone(),
        //         };
        //         Some((rx, tx))
        //     }
        //     Err(err) if err.kind() == io::ErrorKind::WouldBlock => None,
        //     Err(err) => panic!("{}", err),
        // }
    }

    fn transmit(&mut self, _timestamp: Instant) -> Option<Self::TxToken<'_>> {
        Some(TxToken {
            inner: self.inner.clone(),
        })
    }
}

#[doc(hidden)]
pub struct RxToken {
    buffer: Vec<u8>,
}

impl phy::RxToken for RxToken {
    fn consume<R, F>(mut self, f: F) -> R
    where
        F: FnOnce(&mut [u8]) -> R,
    {
        f(&mut self.buffer[..])
    }
}

#[doc(hidden)]
pub struct TxToken {
    inner: Arc<wintun::Session>,
}

impl phy::TxToken for TxToken {
    fn consume<R, F>(self, len: usize, f: F) -> R
    where
        F: FnOnce(&mut [u8]) -> R,
    {
        let inner = self.inner.clone();
        let mut buffer = vec![0; len];
        let result = f(&mut buffer);

        let write_pack = inner.allocate_send_packet(len as u16);
        if let Ok(mut write_pack) = write_pack {
            write_pack.bytes_mut().copy_from_slice(&buffer[..]);
            inner.send_packet(write_pack);
        } else if let Err(err) = write_pack {
            log::error!("phy: failed to allocate send packet: {}", err);
        }

        // match lower.send(&buffer[..]) {
        //     Ok(_) => {}
        //     Err(err) if err.kind() == io::ErrorKind::WouldBlock => {
        //         log::error!("phy: tx failed due to WouldBlock")
        //     }
        //     Err(err) => panic!("{}", err),
        // }
        result
    }
}