pistol 4.0.18

use pnet::datalink::MacAddr;
use pnet::datalink::NetworkInterface;
use pnet::datalink::interfaces;
use pnet::ipnetwork::IpNetwork;
use pnet::packet::ethernet::EtherTypes;
use pnet::packet::ethernet::EthernetPacket;
use pnet::packet::icmpv6;
use pnet::packet::icmpv6::Icmpv6Code;
use pnet::packet::icmpv6::Icmpv6Type;
use pnet::packet::icmpv6::Icmpv6Types;
use pnet::packet::icmpv6::MutableIcmpv6Packet;
use pnet::packet::icmpv6::ndp::MutableRouterSolicitPacket;
use pnet::packet::icmpv6::ndp::NdpOption;
use pnet::packet::icmpv6::ndp::NdpOptionTypes;
use pnet::packet::ip::IpNextHeaderProtocols;
use pnet::packet::ipv6::MutableIpv6Packet;
use regex::Regex;
use std::collections::HashMap;
use std::fmt;
use std::net::IpAddr;
use std::net::Ipv4Addr;
use std::net::Ipv6Addr;
use std::panic::Location;
use std::process::Command;
use std::str::FromStr;
use std::sync::Arc;
use std::sync::Mutex;
use std::time::Duration;
use tracing::debug;
use tracing::warn;

use crate::DST_CACHE;
use crate::LayerMatch;
use crate::NEIGHBOR_SCAN_STATUS;
use crate::SYSTEM_NET_CACHE;
use crate::error::PistolError;
use crate::layer::ICMPV6_RS_HEADER_SIZE;
use crate::layer::IPV6_HEADER_SIZE;
use crate::layer::Layer3Match;
use crate::layer::Layer4MatchIcmpv6;
use crate::layer::PayloadMatch;
use crate::layer::PayloadMatchIcmpv6;
use crate::layer::PayloadMatchIp;
use crate::layer::find_interface_by_index;
use crate::layer::find_interface_by_src;
use crate::layer::layer2_work;
use crate::scan::arp::send_arp_scan_packet;
use crate::scan::ndp_ns::send_ndp_ns_scan_packet;
use crate::utils::neigh_cache_update;

#[cfg(any(
    target_os = "linux",
    target_os = "freebsd",
    target_os = "openbsd",
    target_os = "netbsd",
    target_os = "macos"
))]
fn find_interface_by_name(name: &str) -> Option<NetworkInterface> {
    for interface in interfaces() {
        if interface.name == name {
            return Some(interface);
        }
    }
    None
}

fn ipv6_addr_bsd_fix(dst_str: &str) -> Result<String, PistolError> {
    // Remove the %em0 .etc
    // fe80::%lo0/10 => fe80::/10
    // fe80::20c:29ff:fe1f:6f71%lo0 => fe80::20c:29ff:fe1f:6f71
    if dst_str.contains("%") {
        let bsd_fix_re = Regex::new(r"(?P<subnet>[^\s^%^/]+)(%(?P<dev>\w+))?(/(?P<mask>\d+))?")?;
        match bsd_fix_re.captures(dst_str) {
            Some(caps) => {
                let addr = caps.name("subnet").map_or("", |m| m.as_str());
                let mask = caps.name("mask").map_or("", |m| m.as_str());
                if dst_str.contains("/") {
                    let output = addr.to_string() + "/" + mask;
                    return Ok(output);
                } else {
                    return Ok(addr.to_string());
                }
            }
            None => {
                warn!("line: [{}] bsd_fix_re no match", dst_str);
                Ok(String::new())
            }
        }
    } else {
        Ok(dst_str.to_string())
    }
}

#[derive(Debug, Clone)]
pub struct DefaultRoute {
    pub via: IpAddr,           // Next hop gateway address
    pub dev: NetworkInterface, // Device interface name
}

impl fmt::Display for DefaultRoute {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        let default_routes_string = format!(
            "default dst: {}, default interface: {}",
            self.via, self.dev.name
        );
        write!(f, "{}", default_routes_string)
    }
}

#[derive(Debug, Clone, PartialEq, Eq, Hash)]
pub enum RouteAddr {
    IpNetwork(IpNetwork),
    IpAddr(IpAddr),
}

impl fmt::Display for RouteAddr {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        let output_str = match self {
            RouteAddr::IpNetwork(ipn) => format!("{}", ipn),
            RouteAddr::IpAddr(ip) => format!("{}", ip),
        };
        write!(f, "{}", output_str)
    }
}

impl RouteAddr {
    pub fn contains(&self, ip: IpAddr) -> bool {
        match self {
            RouteAddr::IpNetwork(ip_network) => ip_network.contains(ip),
            RouteAddr::IpAddr(ip_addr) => {
                if *ip_addr == ip {
                    true
                } else {
                    false
                }
            }
        }
    }
    pub fn is_unspecified(&self) -> bool {
        match self {
            RouteAddr::IpNetwork(ip_network) => ip_network.ip().is_unspecified(),
            RouteAddr::IpAddr(ip_addr) => ip_addr.is_unspecified(),
        }
    }
}

#[derive(Debug, Clone)]
struct InnerDefaultRoute {
    via: IpAddr,
    // only the name is stored here, not converted into a formal NetworkInterface struct
    #[cfg(any(
        target_os = "linux",
        target_os = "freebsd",
        target_os = "openbsd",
        target_os = "netbsd",
        target_os = "macos"
    ))]
    dev: String,
    #[cfg(target_os = "windows")]
    if_index: u32,
}

impl fmt::Display for InnerDefaultRoute {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        #[cfg(any(
            target_os = "linux",
            target_os = "freebsd",
            target_os = "openbsd",
            target_os = "netbsd",
            target_os = "macos"
        ))]
        let default_routes_string =
            format!("default via: {}, default interface: {}", self.via, self.dev);
        #[cfg(target_os = "windows")]
        let default_routes_string = format!(
            "default via: {}, default interface index: {}",
            self.via, self.if_index
        );
        write!(f, "{}", default_routes_string)
    }
}

#[derive(Debug, Clone)]
struct InnerRouteInfo {
    /// linux and unix interface name
    #[cfg(any(
        target_os = "linux",
        target_os = "freebsd",
        target_os = "openbsd",
        target_os = "netbsd",
        target_os = "macos"
    ))]
    dev: String,
    /// windows interface ids
    #[cfg(target_os = "windows")]
    dev: u32,
    via: Option<String>,
}

// intermediate layer representation, used for testing
#[derive(Debug, Clone)]
struct InnerRouteTable {
    default_route: Option<InnerDefaultRoute>,
    default_route6: Option<InnerDefaultRoute>,
    /// (192.168.1.0/24, (dev_name, via_ip)) linux and unix
    /// (192.168.1.0/24, (if_index, via_ip)) windows
    routes: HashMap<RouteAddr, InnerRouteInfo>,
}

impl fmt::Display for InnerRouteTable {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        let mut new_routes = HashMap::new();
        for (r, n) in &self.routes {
            let addr = match r {
                RouteAddr::IpAddr(i) => i.to_string(),
                RouteAddr::IpNetwork(i) => i.to_string(),
            };
            new_routes.insert(addr, n);
        }
        let mut output = String::new();
        match &self.default_route {
            Some(r) => {
                output += &format!("ipv4: {}, ", r);
            }
            None => (),
        }
        match &self.default_route6 {
            Some(r) => {
                output += &format!("ipv6: {}, ", r);
            }
            None => (),
        }
        let routes_string = format!("routes: {:?}", new_routes);
        output += &routes_string;
        match output.strip_suffix(", ") {
            Some(o) => write!(f, "{}", o),
            None => write!(f, "{}", output),
        }
    }
}

impl InnerRouteTable {
    #[cfg(target_os = "linux")]
    fn parser(system_route_lines: &[String]) -> Result<InnerRouteTable, PistolError> {
        let mut default_route = None;
        let mut default_route6 = None;
        let mut routes = HashMap::new();

        for line in system_route_lines {
            let line = line.trim();
            if line.len() == 0 {
                continue;
            }
            // default via 192.168.72.2 dev ens33
            // default via 192.168.72.2 dev ens33 proto dhcp metric 100
            let default_route_judge = |line: &str| -> bool { line.starts_with("default") };
            if default_route_judge(&line) {
                let default_route_re =
                    Regex::new(r"^default\s+via\s+(?P<via>[^\s]+)\s+dev\s+(?P<dev>[^\s]+)(.+)?")?;
                match default_route_re.captures(&line) {
                    Some(caps) => {
                        let via_str = caps.name("via").map_or("", |m| m.as_str());
                        let via: IpAddr = match via_str.parse() {
                            Ok(v) => v,
                            Err(e) => {
                                warn!(
                                    "parse route table 'via' [{}] into IpAddr error: {}",
                                    via_str, e
                                );
                                continue;
                            }
                        };
                        let dev = caps.name("dev").map_or("", |m| m.as_str()).to_string();
                        let inner_default_route = InnerDefaultRoute { via, dev };

                        let mut is_ipv4 = true;
                        if via_str.contains(":") {
                            is_ipv4 = false;
                        }

                        if is_ipv4 {
                            default_route = Some(inner_default_route);
                        } else {
                            default_route6 = Some(inner_default_route);
                        }
                    }
                    None => warn!("line: [{}] default_route_re no match", line),
                }
            } else {
                // 192.168.1.0/24 dev ens36 proto kernel scope link src 192.168.1.132
                // 192.168.72.0/24 dev ens33 proto kernel scope link src 192.168.72.128
                // fe80::/64 dev ens33 proto kernel metric 256 pref medium
                // 192.168.72.0/24 dev ens33 proto kernel scope link src 192.168.72.138 metric 100
                // 10.179.252.0/24 via 10.179.141.129 dev eth0 proto static metric 100
                let route_re_1 = Regex::new(r"^(?P<subnet>[^\s]+)\s+dev\s+(?P<dev>[^\s]+)(.+)?")?;
                let route_re_2 = Regex::new(
                    r"^(?P<subnet>[^\s]+)\s+via\s+(?P<via>[^\s]+)\s+dev\s+(?P<dev>[^\s]+)(.+)?",
                )?;
                // there are many regex to match different output
                let caps = if let Some(caps) = route_re_1.captures(&line) {
                    Some(caps)
                } else if let Some(caps) = route_re_2.captures(&line) {
                    Some(caps)
                } else {
                    None
                };

                if let Some(caps) = caps {
                    let dst_str = caps.name("subnet").map_or("", |m| m.as_str());
                    let dst = if dst_str.contains("/") {
                        let dst = match IpNetwork::from_str(dst_str) {
                            Ok(d) => d,
                            Err(e) => {
                                warn!("parse route table 'dst' [{}] error: {}", dst_str, e);
                                continue;
                            }
                        };
                        let dst = RouteAddr::IpNetwork(dst);
                        dst
                    } else {
                        let dst: IpAddr = match dst_str.parse() {
                            Ok(d) => d,
                            Err(e) => {
                                warn!("parse route table 'dst' [{}] error: {}", dst_str, e);
                                continue;
                            }
                        };
                        let dst = RouteAddr::IpAddr(dst);
                        dst
                    };
                    let dev = caps.name("dev").map_or("", |m| m.as_str()).to_string();
                    let via = caps.name("via").map_or(None, |m| Some(m.as_str().into()));
                    let inner_route_info = InnerRouteInfo { dev, via };
                    routes.insert(dst, inner_route_info);
                } else {
                    warn!("line: [{}] route_re_1 and route_re_2 both no match", line);
                }
            }
        }

        Ok(InnerRouteTable {
            default_route,
            default_route6,
            routes,
        })
    }
    #[cfg(any(
        target_os = "freebsd",
        target_os = "openbsd",
        target_os = "netbsd",
        target_os = "macos"
    ))]
    fn parser(system_route_lines: &[String]) -> Result<InnerRouteTable, PistolError> {
        let mut default_route = None;
        let mut default_route6 = None;
        let mut routes = HashMap::new();

        for line in system_route_lines {
            if line.len() == 0
                || line.starts_with("R")
                || line.starts_with("I")
                || line.starts_with("D")
            {
                continue;
            }
            let default_route_judge = |line: &str| -> bool { line.starts_with("default") };
            if default_route_judge(&line) {
                let line = line.trim();
                // default 192.168.72.2 UGS em0
                // default fe80::4a5f:8ff:fee0:1394%em1 UG em1
                let line_split: Vec<&str> = line
                    .split(" ")
                    .map(|x| x.trim())
                    .filter(|x| x.len() > 0)
                    .collect();
                if line_split.len() >= 2 {
                    let via_str = line_split[1];
                    let via_str = ipv6_addr_bsd_fix(via_str)?;
                    let via: IpAddr = match via_str.parse() {
                        Ok(v) => v,
                        Err(e) => {
                            warn!(
                                "parse route table 'via' [{}] into IpAddr error: {}",
                                via_str, e
                            );
                            continue;
                        }
                    };
                    let dev = line_split[line_split.len() - 1].to_string();

                    let mut is_ipv4 = true;
                    if via_str.contains(":") {
                        is_ipv4 = false;
                    }

                    let inner_default_route = InnerDefaultRoute { via, dev };

                    if is_ipv4 {
                        default_route = Some(inner_default_route);
                    } else {
                        default_route6 = Some(inner_default_route);
                    }
                } else {
                    warn!("line: [{}] default route split no match", line);
                }
            } else {
                // 127.0.0.1          link#2             UH          lo0
                let line_split: Vec<&str> = line
                    .split(" ")
                    .map(|x| x.trim())
                    .filter(|x| x.len() > 0)
                    .collect();
                if line_split.len() >= 3 {
                    let dst_str = line_split[0];
                    let dst_str = ipv6_addr_bsd_fix(dst_str)?;
                    let dst = if dst_str.contains("/") {
                        let dst = match IpNetwork::from_str(&dst_str) {
                            Ok(d) => d,
                            Err(e) => {
                                warn!("parse route table 'dst' [{}] error: {}", dst_str, e);
                                continue;
                            }
                        };
                        let dst = RouteAddr::IpNetwork(dst);
                        dst
                    } else {
                        let dst: IpAddr = match dst_str.parse() {
                            Ok(d) => d,
                            Err(e) => {
                                warn!("parse route table 'dst' [{}] error: {}", dst_str, e);
                                continue;
                            }
                        };
                        let dst = RouteAddr::IpAddr(dst);
                        dst
                    };
                    let dev = line_split[line_split.len() - 1].to_string();
                    let via = Some(line_split[1].to_string());
                    let inner_route_info = InnerRouteInfo { dev, via };
                    routes.insert(dst, inner_route_info);
                } else {
                    warn!("line: [{}] route split no match", line);
                }
            }
        }
        Ok(InnerRouteTable {
            default_route,
            default_route6,
            routes,
        })
    }
    #[cfg(target_os = "windows")]
    fn parser(system_route_lines: &[String]) -> Result<InnerRouteTable, PistolError> {
        let mut default_route = None;
        let mut default_route6 = None;
        let mut routes = HashMap::new();

        for line in system_route_lines {
            let line = line.trim();
            if line.len() == 0 || line.starts_with("-") || line.starts_with("i") {
                continue;
            }
            let default_route_judge =
                |line: &str| -> bool { line.contains("0.0.0.0/0") || line.contains("::/0") };
            if default_route_judge(&line) {
                // 19 0.0.0.0/0 192.168.1.4 256 35 ActiveStore
                let default_route_re =
                    Regex::new(r"^(?P<index>[^\s]+)\s+[^\s]+\s+(?P<via>[^\s]+)(.+)?")?;
                match default_route_re.captures(&line) {
                    Some(caps) => {
                        let if_index = caps.name("index").map_or("", |m| m.as_str());
                        let if_index: u32 = match if_index.parse() {
                            Ok(i) => i,
                            Err(e) => {
                                warn!("parse route table 'if_index' [{}] error: {}", if_index, e);
                                continue;
                            }
                        };

                        let via_str = caps.name("via").map_or("", |m| m.as_str());
                        let via: IpAddr = match via_str.parse() {
                            Ok(v) => v,
                            Err(e) => {
                                warn!(
                                    "parse route table 'via' [{}] into IpAddr error: {}",
                                    via_str, e
                                );
                                continue;
                            }
                        };

                        let mut is_ipv4 = true;
                        if via_str.contains(":") {
                            is_ipv4 = false;
                        }

                        let inner_default_route = InnerDefaultRoute { via, if_index };

                        if is_ipv4 {
                            default_route = Some(inner_default_route);
                        } else {
                            default_route6 = Some(inner_default_route);
                        }
                    }
                    None => warn!("line: [{}] default_route_re no match", line),
                }
            } else {
                // 17 255.255.255.255/32 0.0.0.0 256 25 ActiveStore
                // 17 fe80::d547:79a9:84eb:767d/128 :: 256 25 ActiveStore
                let route_re =
                    Regex::new(r"^(?P<index>[^\s]+)\s+(?P<dst>[^\s]+)\s+(?P<via>[^\s]+)(.+)?")?;
                match route_re.captures(&line) {
                    Some(caps) => {
                        let if_index = caps.name("index").map_or("", |m| m.as_str());
                        let if_index: u32 = match if_index.parse() {
                            Ok(i) => i,
                            Err(e) => {
                                warn!("parse route table 'if_index' [{}] error: {}", if_index, e);
                                continue;
                            }
                        };

                        let dst_str = caps.name("dst").map_or("", |m| m.as_str());
                        let dst = match IpNetwork::from_str(dst_str) {
                            Ok(d) => d,
                            Err(e) => {
                                warn!("parse route table 'dst' [{}] error: {}", dst_str, e);
                                continue;
                            }
                        };
                        let dst = RouteAddr::IpNetwork(dst);
                        let via = caps.name("via").map_or(None, |m| Some(m.as_str().into()));
                        let inner_route_info = InnerRouteInfo { dev: if_index, via };
                        routes.insert(dst, inner_route_info);
                    }
                    None => warn!("line: [{}] default_route_re no match", line),
                }
            }
        }

        Ok(InnerRouteTable {
            default_route,
            default_route6,
            routes,
        })
    }
}

/// Destination mac address and interface cache
pub struct DstCache {
    pub dst_addr: IpAddr,
    pub src_addr: IpAddr,
    pub mac: MacAddr,
    pub interface: NetworkInterface,
}

impl DstCache {
    // the same target address does not need to be searched again
    pub fn update(
        dst_addr: IpAddr,
        src_addr: IpAddr,
        mac: MacAddr,
        interface: NetworkInterface,
    ) -> Result<(), PistolError> {
        match DST_CACHE.lock() {
            Ok(mut dst_cache) => {
                if !dst_cache.contains_key(&dst_addr) {
                    let dc = DstCache {
                        dst_addr,
                        src_addr,
                        mac,
                        interface,
                    };
                    let _ = dst_cache.insert(dst_addr, dc);
                }
                Ok(())
            }
            Err(e) => Err(PistolError::TryLockGlobalVarFailed {
                var_name: String::from("DST_CACHE"),
                e: e.to_string(),
            }),
        }
    }
    pub fn get(dst_addr: IpAddr) -> Result<Option<(MacAddr, NetworkInterface)>, PistolError> {
        match DST_CACHE.lock() {
            Ok(dst_cache) => {
                let ret = dst_cache.get(&dst_addr);
                if let Some(dc) = ret {
                    debug!("dst {} found in DST_CACHE", dst_addr);
                    Ok(Some((dc.mac, dc.interface.clone())))
                } else {
                    debug!("dst {} not found in DST_CACHE", dst_addr);
                    Ok(None)
                }
            }
            Err(e) => Err(PistolError::TryLockGlobalVarFailed {
                var_name: String::from("DST_CACHE"),
                e: e.to_string(),
            }),
        }
    }
}

fn find_loopback_interface() -> Option<NetworkInterface> {
    for interface in interfaces() {
        if interface.is_loopback() {
            return Some(interface);
        }
    }
    None
}

/// Check if the target IP address is one of the system IP address.
fn addr_is_my_ip(ip: IpAddr) -> bool {
    for interface in interfaces() {
        for ipn in interface.ips {
            if ipn.ip() == ip {
                return true;
            }
        }
    }
    debug!("dst {} is not in host", ip);
    false
}

/// Check if the target IP address is in the local.
fn addr_in_local_net(ip: IpAddr) -> bool {
    for interface in interfaces() {
        for ipn in interface.ips {
            if ipn.contains(ip) {
                return true;
            }
        }
    }
    // all data for other addresses are sent to the default route
    debug!("dst {} is not in local net", ip);
    false
}

/// return ipv4 and ipv6 default route
pub fn get_default_route() -> Result<(Option<DefaultRoute>, Option<DefaultRoute>), PistolError> {
    // release the lock when leaving the function
    let snc = match SYSTEM_NET_CACHE.lock() {
        Ok(snc) => snc.clone(),
        Err(e) => {
            return Err(PistolError::TryLockGlobalVarFailed {
                var_name: String::from("SYSTEM_NET_CACHE"),
                e: e.to_string(),
            });
        }
    };
    Ok((snc.default_route, snc.default_route6))
}

/// Get the send route info from the system route table
pub fn search_route_table(dst_addr: IpAddr) -> Result<Option<RouteInfo>, PistolError> {
    let snc = match SYSTEM_NET_CACHE.lock() {
        Ok(snc) => snc,
        Err(e) => {
            return Err(PistolError::TryLockGlobalVarFailed {
                var_name: String::from("SYSTEM_NET_CACHE"),
                e: e.to_string(),
            });
        }
    };
    Ok(snc.search_route_table(dst_addr))
}

/// Get the target mac address through arp table
pub fn search_mac(dst_addr: IpAddr) -> Result<Option<MacAddr>, PistolError> {
    let snc = match SYSTEM_NET_CACHE.lock() {
        Ok(snc) => snc,
        Err(e) => {
            return Err(PistolError::TryLockGlobalVarFailed {
                var_name: String::from("SYSTEM_NET_CACHE"),
                e: e.to_string(),
            });
        }
    };
    Ok(snc.search_mac(dst_addr))
}

fn get_mac_from_ndp_rs(buff: &[u8]) -> Option<MacAddr> {
    // return mac address from ndp
    match EthernetPacket::new(buff) {
        Some(ethernet_packet) => {
            let mac = ethernet_packet.get_source();
            Some(mac)
        }
        None => None,
    }
}

fn send_ndp_rs_packet(
    src_ipv6: Ipv6Addr,
    timeout: Option<Duration>,
) -> Result<(Option<MacAddr>, Duration), PistolError> {
    // router solicitation
    let route_addr_2 = Ipv6Addr::new(0xFF02, 0, 0, 0, 0, 0, 0, 0x0002);
    // let route_addr_1 = Ipv6Addr::new(0xFF02, 0, 0, 0, 0, 0, 0, 0x0001);
    let interface = match find_interface_by_src(src_ipv6.into()) {
        Some(i) => i,
        None => return Err(PistolError::CanNotFoundInterface),
    };
    let src_mac = match interface.mac {
        Some(m) => m,
        None => return Err(PistolError::CanNotFoundMacAddress),
    };

    // ipv6
    let mut ipv6_buff = [0u8; IPV6_HEADER_SIZE + ICMPV6_RS_HEADER_SIZE];
    let mut ipv6_header = match MutableIpv6Packet::new(&mut ipv6_buff) {
        Some(p) => p,
        None => {
            return Err(PistolError::BuildPacketError {
                location: format!("{}", Location::caller()),
            });
        }
    };
    ipv6_header.set_version(6);
    ipv6_header.set_traffic_class(0);
    ipv6_header.set_flow_label(0);
    ipv6_header.set_payload_length(ICMPV6_RS_HEADER_SIZE as u16);
    ipv6_header.set_next_header(IpNextHeaderProtocols::Icmpv6);
    ipv6_header.set_hop_limit(255);
    ipv6_header.set_source(src_ipv6);
    ipv6_header.set_destination(route_addr_2);

    // icmpv6
    let mut icmpv6_header =
        match MutableRouterSolicitPacket::new(&mut ipv6_buff[IPV6_HEADER_SIZE..]) {
            Some(p) => p,
            None => {
                return Err(PistolError::BuildPacketError {
                    location: format!("{}", Location::caller()),
                });
            }
        };
    // Neighbor Solicitation
    icmpv6_header.set_icmpv6_type(Icmpv6Type(133));
    icmpv6_header.set_icmpv6_code(Icmpv6Code(0));
    icmpv6_header.set_reserved(0);
    let ndp_option = NdpOption {
        option_type: NdpOptionTypes::SourceLLAddr,
        length: 1,
        data: src_mac.octets().to_vec(),
    };
    icmpv6_header.set_options(&vec![ndp_option]);

    let mut icmpv6_header = match MutableIcmpv6Packet::new(&mut ipv6_buff[IPV6_HEADER_SIZE..]) {
        Some(p) => p,
        None => {
            return Err(PistolError::BuildPacketError {
                location: format!("{}", Location::caller()),
            });
        }
    };
    let checksum = icmpv6::checksum(&icmpv6_header.to_immutable(), &src_ipv6, &route_addr_2);
    icmpv6_header.set_checksum(checksum);

    // let layer3 = Layer3Match {
    //     layer2: None,
    //     src_addr: None,
    //     dst_addr: Some(route_addr_1.into()),
    // };
    let layer3 = Layer3Match {
        name: "ndp_ns layer3",
        layer2: None,
        src_addr: None,
        dst_addr: None,
    };
    // set the icmp payload matchs
    let payload_ip = PayloadMatchIp {
        src_addr: None,
        dst_addr: None,
    };
    let payload_icmpv6 = PayloadMatchIcmpv6 {
        layer3: Some(payload_ip),
        icmpv6_type: Some(Icmpv6Types::RouterSolicit),
        icmpv6_code: None,
    };
    let payload = PayloadMatch::PayloadMatchIcmpv6(payload_icmpv6);
    let layer4_icmpv6 = Layer4MatchIcmpv6 {
        name: "ndp_ns icmpv6",
        layer3: Some(layer3),
        icmpv6_type: Some(Icmpv6Types::RouterAdvert), // Type: Router Advertisement (134)
        icmpv6_code: None,
        payload: Some(payload),
    };
    let layer_match = LayerMatch::Layer4MatchIcmpv6(layer4_icmpv6);

    let dst_mac = MacAddr(33, 33, 00, 00, 00, 02);
    let ethernet_type = EtherTypes::Ipv6;
    let (r, rtt) = layer2_work(
        dst_mac,
        interface.clone(),
        &ipv6_buff,
        IPV6_HEADER_SIZE + ICMPV6_RS_HEADER_SIZE,
        ethernet_type,
        vec![layer_match],
        timeout,
        true,
    )?;

    let mac = get_mac_from_ndp_rs(&r);
    Ok((mac, rtt))
}

#[derive(Debug, Clone, Copy)]
pub enum RouteVia {
    // linux
    IpAddr(IpAddr),
    // windows and unix
    IfIndex(u32),
    // unix
    MacAddr(MacAddr),
}

impl fmt::Display for RouteVia {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        let output = match self {
            RouteVia::IpAddr(ip_addr) => format!("via ip_addr {}", ip_addr),
            RouteVia::IfIndex(if_index) => format!("via if_index {}", if_index),
            RouteVia::MacAddr(mac_addr) => format!("via mac_addr {}", mac_addr),
        };
        write!(f, "{}", output)
    }
}

impl RouteVia {
    fn standard_process(
        dst_addr: IpAddr,
        src_addr: IpAddr,
        src_interface: NetworkInterface,
        timeout: Option<Duration>,
    ) -> Result<MacAddr, PistolError> {
        if dst_addr.is_loopback() || addr_is_my_ip(dst_addr) {
            // target is your own machine, such as when using localhost or 127.0.0.1 as the target
            match src_interface.mac {
                Some(dst_mac) => Ok(dst_mac),
                None => Err(PistolError::CanNotFoundMacAddress),
            }
        } else if addr_in_local_net(dst_addr) {
            match search_mac(dst_addr)? {
                Some(dst_mac) => {
                    debug!("found {} in arp cache", dst_addr);
                    Ok(dst_mac)
                }
                None => {
                    // if addr is local address and in local net
                    // use the arp or ndp_ns to ask the mac address
                    let src_mac = match src_interface.mac {
                        Some(m) => m,
                        None => return Err(PistolError::CanNotFoundMacAddress),
                    };

                    match dst_addr {
                        IpAddr::V4(via_ipv4) => {
                            if let IpAddr::V4(src_ipv4) = src_addr {
                                let dst_mac = match send_arp_scan_packet(
                                    via_ipv4,
                                    MacAddr::broadcast(),
                                    src_ipv4,
                                    src_mac,
                                    src_interface,
                                    timeout,
                                )? {
                                    (Some(m), _rtt) => m,
                                    (None, _rtt) => {
                                        return Err(PistolError::CanNotFoundMacAddress);
                                    }
                                };
                                neigh_cache_update(via_ipv4.into(), dst_mac)?;
                                Ok(dst_mac)
                            } else {
                                Err(PistolError::CanNotFoundMacAddress)
                            }
                        }
                        IpAddr::V6(via_ipv6) => {
                            if let IpAddr::V6(src_ipv6) = src_addr {
                                let dst_mac = match send_ndp_ns_scan_packet(
                                    via_ipv6,
                                    src_ipv6,
                                    src_mac,
                                    src_interface,
                                    timeout,
                                )? {
                                    (Some(m), _rtt) => m,
                                    (None, _rtt) => {
                                        return Err(PistolError::CanNotFoundMacAddress);
                                    }
                                };
                                neigh_cache_update(via_ipv6.into(), dst_mac)?;
                                Ok(dst_mac)
                            } else {
                                Err(PistolError::CanNotFoundMacAddress)
                            }
                        }
                    }
                }
            }
        } else {
            // finally, send it to the the default route address in layer2
            let (default_route, default_route6) = get_default_route()?;
            let dr = if dst_addr.is_ipv4() {
                if let Some(dr_ipv4) = default_route {
                    dr_ipv4
                } else {
                    return Err(PistolError::CanNotFoundRouterAddress);
                }
            } else {
                if let Some(dr_ipv6) = default_route6 {
                    dr_ipv6
                } else {
                    return Err(PistolError::CanNotFoundRouterAddress);
                }
            };

            let dst_mac = match search_mac(dr.via)? {
                Some(m) => m,
                None => {
                    let dst_mac = MacAddr::broadcast();
                    let src_mac = match src_interface.mac {
                        Some(m) => m,
                        None => return Err(PistolError::CanNotFoundMacAddress),
                    };
                    match dr.via {
                        IpAddr::V4(dr_ipv4) => {
                            debug!("try to found the dst mac by arp scan");
                            if let IpAddr::V4(src_ipv4) = src_addr {
                                match send_arp_scan_packet(
                                    dr_ipv4,
                                    dst_mac,
                                    src_ipv4,
                                    src_mac,
                                    src_interface,
                                    timeout,
                                )? {
                                    (Some(m), _rtt) => {
                                        debug!("update the neigh cache: {} - {}", dr_ipv4, m);
                                        neigh_cache_update(dr_ipv4.into(), m)?;
                                        m
                                    }
                                    (None, _rtt) => {
                                        return Err(PistolError::CanNotFoundRouteMacAddress);
                                    }
                                }
                            } else {
                                return Err(PistolError::CanNotFoundRouteMacAddress);
                            }
                        }
                        IpAddr::V6(dr_ipv6) => {
                            debug!("try to found the dst mac by ndp_ns scan");
                            if let IpAddr::V6(src_ipv6) = src_addr {
                                // this is not ndp_ns scan packet
                                match send_ndp_rs_packet(src_ipv6, timeout)? {
                                    (Some(m), _rtt) => {
                                        debug!("update the neigh cache: {} - {}", dr_ipv6, m);
                                        neigh_cache_update(dr_ipv6.into(), m)?;
                                        m
                                    }
                                    (None, _rtt) => {
                                        return Err(PistolError::CanNotFoundRouteMacAddress);
                                    }
                                }
                            } else {
                                return Err(PistolError::CanNotFoundRouteMacAddress);
                            }
                        }
                    }
                }
            };
            Ok(dst_mac)
        }
    }
    pub fn get_dst_mac_and_src_if_with_lock(
        dst_addr: IpAddr,
        src_addr: IpAddr,
        timeout: Option<Duration>,
    ) -> Result<(MacAddr, NetworkInterface), PistolError> {
        // search in the program cache
        if let Some((dst_mac, src_interface)) = DstCache::get(dst_addr)? {
            return Ok((dst_mac, src_interface));
        }

        let (src_interface, route_via) = if src_addr == dst_addr {
            let dev = match find_loopback_interface() {
                Some(i) => i,
                None => return Err(PistolError::CanNotFoundInterface),
            };
            if dst_addr.is_ipv4() {
                let via = Some(RouteVia::IpAddr(IpAddr::V4(Ipv4Addr::LOCALHOST)));
                (dev, via)
            } else {
                let via = Some(RouteVia::IpAddr(IpAddr::V6(Ipv6Addr::LOCALHOST)));
                (dev, via)
            }
        } else {
            let route_info = match search_route_table(dst_addr)? {
                Some(route_info) => route_info,
                None => {
                    // send it to the default route address
                    let (default_route, default_route6) = get_default_route()?;
                    let dr = if dst_addr.is_ipv4() {
                        if let Some(dr_ipv4) = default_route {
                            dr_ipv4
                        } else {
                            return Err(PistolError::CanNotFoundRouterAddress);
                        }
                    } else {
                        if let Some(dr_ipv6) = default_route6 {
                            dr_ipv6
                        } else {
                            return Err(PistolError::CanNotFoundRouterAddress);
                        }
                    };
                    match search_route_table(dr.via)? {
                        Some(route_info) => route_info,
                        None => return Err(PistolError::CanNotFoundInterface),
                    }
                }
            };
            // debug!(
            //     "search route table done, dev {} via {:?}",
            //     route_info.dev.name, route_info.via
            // );
            (route_info.dev, route_info.via)
        };
        debug!(
            "src interface: {}, via addr: {:?}",
            src_interface.name, route_via
        );

        match route_via {
            Some(route_via) => {
                match route_via {
                    RouteVia::IfIndex(if_index) => {
                        let src_interface = match find_interface_by_index(if_index) {
                            Some(i) => i,
                            None => return Err(PistolError::CanNotFoundInterface),
                        };
                        // no via_addr, use dst_addr here
                        let dst_mac = match search_mac(dst_addr)? {
                            Some(dst_mac) => dst_mac,
                            None => Self::standard_process(
                                dst_addr,
                                src_addr,
                                src_interface.clone(),
                                timeout,
                            )?,
                        };
                        DstCache::update(dst_addr, src_addr, dst_mac, src_interface.clone())?;
                        Ok((dst_mac, src_interface))
                    }
                    RouteVia::MacAddr(dst_mac) => {
                        DstCache::update(dst_addr, src_addr, dst_mac, src_interface.clone())?;
                        Ok((dst_mac, src_interface))
                    }
                    RouteVia::IpAddr(via_addr) => {
                        // we need to fix 0.0.0.0
                        let via_addr = if via_addr.is_unspecified() {
                            dst_addr
                        } else {
                            via_addr
                        };
                        let dst_mac = match search_mac(via_addr)? {
                            Some(m) => m,
                            None => Self::standard_process(
                                via_addr,
                                src_addr,
                                src_interface.clone(),
                                timeout,
                            )?,
                        };
                        DstCache::update(dst_addr, src_addr, dst_mac, src_interface.clone())?;
                        Ok((dst_mac, src_interface))
                    }
                }
            }
            None => {
                debug!("route_via is none");
                let dst_mac =
                    Self::standard_process(dst_addr, src_addr, src_interface.clone(), timeout)?;
                DstCache::update(dst_addr, src_addr, dst_mac, src_interface.clone())?;
                Ok((dst_mac, src_interface))
            }
        }
    }
    pub fn get_dst_mac_and_src_if(
        dst_addr: IpAddr,
        src_addr: IpAddr,
        timeout: Option<Duration>,
    ) -> Result<(MacAddr, NetworkInterface), PistolError> {
        let mut neighbor_scan_status = match NEIGHBOR_SCAN_STATUS.lock() {
            Ok(n) => n,
            Err(e) => {
                return Err(PistolError::TryLockGlobalVarFailed {
                    var_name: String::from("NEIGHBOR_SCAN_STATUS"),
                    e: e.to_string(),
                });
            }
        };
        let mutex = match neighbor_scan_status.get(&dst_addr) {
            Some(x) => (*x).clone(),
            None => {
                let x = Arc::new(Mutex::new(()));
                neighbor_scan_status.insert(dst_addr, x.clone());
                x
            }
        };

        match mutex.lock() {
            // lock and send arp scan or ndp_ns scan packet only once
            Ok(_) => Self::get_dst_mac_and_src_if_with_lock(dst_addr, src_addr, timeout),
            Err(e) => {
                return Err(PistolError::TryLockGlobalVarFailed {
                    var_name: format!("{}", dst_addr),
                    e: e.to_string(),
                });
            }
        }
    }
    pub fn parser(via_str: &str) -> Result<Option<RouteVia>, PistolError> {
        if !via_str.contains("link") {
            let ipv6_re = Regex::new(r"^[\w\d:]+(\/\d+)?")?;
            let ipv4_re = Regex::new(r"^[\d\.]+(\/\d+)?")?;
            let mac_re = Regex::new(
                r"^[\w\d]{1,2}:[\w\d]{1,2}:[\w\d]{1,2}:[\w\d]{1,2}:[\w\d]{1,2}:[\w\d]{1,2}",
            )?;
            let windows_index_re = Regex::new(r"^\d+")?;
            if ipv6_re.is_match(via_str) {
                // ipv6 address
                let ipv6_addr = ipv6_addr_bsd_fix(via_str)?;
                let via: IpAddr = match ipv6_addr.parse() {
                    Ok(d) => d,
                    Err(e) => {
                        warn!("parse 'via' [{}] into IpAddr(V6) error: {}", via_str, e);
                        return Ok(None);
                    }
                };
                Ok(Some(RouteVia::IpAddr(via.into())))
            } else if ipv4_re.is_match(via_str) {
                // ipv4 address
                let via: IpAddr = match via_str.parse() {
                    Ok(d) => d,
                    Err(e) => {
                        warn!("parse 'via' [{}] into IpAddr(V4) error: {}", via_str, e);
                        return Ok(None);
                    }
                };
                if !via.is_unspecified() {
                    Ok(Some(RouteVia::IpAddr(via.into())))
                } else {
                    Ok(None)
                }
            } else if mac_re.is_match(via_str) {
                // mac address
                let mac: MacAddr = match via_str.parse() {
                    Ok(m) => m,
                    Err(e) => {
                        warn!("parse 'via' [{}] into MacAddr error: {}", via_str, e);
                        return Ok(None);
                    }
                };
                Ok(Some(RouteVia::MacAddr(mac)))
            } else if windows_index_re.is_match(via_str) {
                let if_index: u32 = match via_str.parse() {
                    Ok(i) => i,
                    Err(e) => {
                        warn!("parse route table 'if_index' [{}] error: {}", via_str, e);
                        return Ok(None);
                    }
                };
                Ok(Some(RouteVia::IfIndex(if_index)))
            } else {
                debug!("via string [{}] no match any regex rules", via_str);
                Ok(None)
            }
        } else {
            // link#12
            let unix_index_re = Regex::new(r"^link#\d+")?;
            if unix_index_re.is_match(via_str) {
                // if_index
                let via_str_split: Vec<&str> = via_str
                    .split("#")
                    .map(|x| x.trim())
                    .filter(|x| x.len() > 0)
                    .collect();
                if via_str_split.len() > 1 {
                    let if_index = via_str_split[1];
                    let if_index: u32 = match if_index.parse() {
                        Ok(i) => i,
                        Err(e) => {
                            warn!("parse route table 'if_index' [{}] error: {}", if_index, e);
                            return Ok(None);
                        }
                    };
                    Ok(Some(RouteVia::IfIndex(if_index)))
                } else {
                    Ok(None)
                }
            } else {
                debug!("via string [{}] not match unix_index_re", via_str);
                Ok(None)
            }
        }
    }
}

#[derive(Debug, Clone)]
pub struct RouteInfo {
    pub dev: NetworkInterface,
    pub via: Option<RouteVia>,
}

#[derive(Debug, Clone)]
pub struct RouteTable {
    pub default_route: Option<DefaultRoute>,
    pub default_route6: Option<DefaultRoute>,
    pub routes: HashMap<RouteAddr, RouteInfo>,
}

impl fmt::Display for RouteTable {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        let mut new_routes = HashMap::new();
        for (r, n) in &self.routes {
            let addr = match r {
                RouteAddr::IpAddr(i) => i.to_string(),
                RouteAddr::IpNetwork(i) => i.to_string(),
            };
            let interface_name = n.dev.name.clone();
            new_routes.insert(addr, interface_name);
        }
        let mut output = String::new();
        match &self.default_route {
            Some(r) => {
                output += &format!("ipv4 {}, ", r);
            }
            None => (),
        }
        match &self.default_route6 {
            Some(r) => {
                output += &format!("ipv6 {}, ", r);
            }
            None => (),
        }
        let routes_string = format!("routes: {:?}", new_routes);
        output += &routes_string;
        match output.strip_suffix(", ") {
            Some(o) => write!(f, "{}", o),
            None => write!(f, "{}", output),
        }
    }
}

impl RouteTable {
    fn exec_system_command() -> Result<Vec<String>, PistolError> {
        #[cfg(target_os = "linux")]
        let c = Command::new("sh").args(["-c", "ip -4 route"]).output()?;
        #[cfg(target_os = "linux")]
        let ipv4_output = String::from_utf8_lossy(&c.stdout);
        #[cfg(target_os = "linux")]
        let c = Command::new("sh").args(["-c", "ip -6 route"]).output()?;
        #[cfg(target_os = "linux")]
        let ipv6_output = String::from_utf8_lossy(&c.stdout);
        #[cfg(target_os = "linux")]
        let output = ipv4_output.to_string() + &ipv6_output;

        #[cfg(any(
            target_os = "freebsd",
            target_os = "openbsd",
            target_os = "netbsd",
            target_os = "macos"
        ))]
        let c = Command::new("sh").args(["-c", "netstat -rn"]).output()?;
        #[cfg(any(
            target_os = "freebsd",
            target_os = "openbsd",
            target_os = "netbsd",
            target_os = "macos"
        ))]
        let output = String::from_utf8_lossy(&c.stdout);

        // 17 255.255.255.255/32 0.0.0.0 256 25 ActiveStore
        // 17 fe80::d547:79a9:84eb:767d/128 :: 256 25 ActiveStore
        #[cfg(target_os = "windows")]
        let c = Command::new("powershell").args(["Get-NetRoute"]).output()?;
        #[cfg(target_os = "windows")]
        let output = String::from_utf8_lossy(&c.stdout);

        let system_route_lines: Vec<String> = output
            .lines()
            .map(|x| x.trim().to_string())
            .filter(|v| v.len() > 0)
            .collect();
        Ok(system_route_lines)
    }
    pub fn init() -> Result<RouteTable, PistolError> {
        let system_route_lines = Self::exec_system_command()?;
        let inner_route_table = InnerRouteTable::parser(&system_route_lines)?;
        debug!("inner route table: {}", inner_route_table);
        let default_route = match inner_route_table.default_route {
            Some(inner_default_route) => {
                #[cfg(any(
                    target_os = "linux",
                    target_os = "freebsd",
                    target_os = "openbsd",
                    target_os = "netbsd",
                    target_os = "macos"
                ))]
                let dev_name = inner_default_route.dev;
                #[cfg(any(
                    target_os = "linux",
                    target_os = "freebsd",
                    target_os = "openbsd",
                    target_os = "netbsd",
                    target_os = "macos"
                ))]
                match find_interface_by_name(&dev_name) {
                    Some(dev) => Some(DefaultRoute {
                        via: inner_default_route.via,
                        dev,
                    }),
                    None => {
                        warn!("can not found interface by name [{}]", dev_name);
                        None
                    }
                }
                #[cfg(target_os = "windows")]
                let if_index = inner_default_route.if_index;
                #[cfg(target_os = "windows")]
                match find_interface_by_index(if_index) {
                    Some(dev) => Some(DefaultRoute {
                        via: inner_default_route.via,
                        dev,
                    }),
                    None => {
                        warn!("can not found interface by if_index [{}]", if_index);
                        None
                    }
                }
            }
            None => None,
        };
        let default_route6 = match inner_route_table.default_route6 {
            Some(inner_default_route6) => {
                #[cfg(any(
                    target_os = "linux",
                    target_os = "freebsd",
                    target_os = "openbsd",
                    target_os = "netbsd",
                    target_os = "macos"
                ))]
                let dev_name = inner_default_route6.dev;
                #[cfg(any(
                    target_os = "linux",
                    target_os = "freebsd",
                    target_os = "openbsd",
                    target_os = "netbsd",
                    target_os = "macos"
                ))]
                match find_interface_by_name(&dev_name) {
                    Some(dev) => Some(DefaultRoute {
                        via: inner_default_route6.via,
                        dev,
                    }),
                    None => {
                        warn!("can not found interface by name [{}]", dev_name);
                        None
                    }
                }
                #[cfg(target_os = "windows")]
                let if_index = inner_default_route6.if_index;
                #[cfg(target_os = "windows")]
                match find_interface_by_index(if_index) {
                    Some(dev) => Some(DefaultRoute {
                        via: inner_default_route6.via,
                        dev,
                    }),
                    None => {
                        warn!("can not found interface by if_index [{}]", if_index);
                        None
                    }
                }
            }
            None => None,
        };

        let mut routes = HashMap::new();
        for (r, inner_route_info) in inner_route_table.routes {
            let dev_str = inner_route_info.dev;
            let via_str = inner_route_info.via;

            #[cfg(any(
                target_os = "linux",
                target_os = "freebsd",
                target_os = "openbsd",
                target_os = "netbsd",
                target_os = "macos"
            ))]
            let dev = match find_interface_by_name(&dev_str) {
                Some(dev) => dev,
                None => {
                    warn!("can not found interface by name [{}]", dev_str);
                    continue;
                }
            };

            #[cfg(target_os = "windows")]
            let dev = match find_interface_by_index(dev_str) {
                Some(dev) => dev,
                None => {
                    warn!("can not found interface by if_index [{}]", dev_str);
                    continue;
                }
            };

            match via_str {
                Some(via_str) => match RouteVia::parser(&via_str)? {
                    Some(via) => {
                        let route_info = RouteInfo {
                            dev,
                            via: Some(via),
                        };
                        routes.insert(r, route_info);
                    }
                    None => {
                        warn!("parse route table 'via' [{}] into RouteVia failed", via_str);
                        continue;
                    }
                },
                None => {
                    let route_info = RouteInfo { dev, via: None };
                    routes.insert(r, route_info);
                }
            }
        }

        Ok(RouteTable {
            default_route,
            default_route6,
            routes,
        })
    }
}

#[derive(Debug, Clone)]
pub struct NeighborCache {}

impl NeighborCache {
    #[cfg(target_os = "linux")]
    pub fn init() -> Result<HashMap<IpAddr, MacAddr>, PistolError> {
        // Debian 12:
        // 192.168.72.2 dev ens33 lladdr 00:50:56:fb:1d:74 STALE
        // 192.168.1.107 dev ens36 lladdr 74:05:a5:53:69:bb STALE
        // 192.168.1.1 dev ens36 lladdr 48:5f:08:e0:13:94 STALE
        // 192.168.1.128 dev ens36 lladdr a8:9c:ed:d5:00:4c STALE
        // 192.168.72.1 dev ens33 lladdr 00:50:56:c0:00:08 REACHABLE
        // fe80::4a5f:8ff:fee0:1394 dev ens36 lladdr 48:5f:08:e0:13:94 router STALE
        // fe80::250:56ff:fec0:2222 dev ens33 router FAILED
        // CentOS 7:
        // 192.168.3.456 dev em2 lladdr fc:e3:3c:a6:a9:8c REACHABLE
        let c = Command::new("sh").args(["-c", "ip neigh show"]).output()?;
        let output = String::from_utf8_lossy(&c.stdout);
        let lines: Vec<&str> = output
            .lines()
            .map(|x| x.trim())
            .filter(|v| v.len() > 0)
            .collect();

        // regex
        let neighbor_re =
            Regex::new(r"(?P<addr>[\d\w\.:]+)\s+dev[\w\s]+lladdr\s+(?P<mac>[\d\w:]+).+")?;

        let mut ret = HashMap::new();
        for line in lines {
            match neighbor_re.captures(line) {
                Some(caps) => {
                    let addr = caps.name("addr").map_or("", |m| m.as_str());
                    let addr: IpAddr = match addr.parse() {
                        Ok(a) => a,
                        Err(e) => {
                            warn!("parse neighbor 'addr' error:  {e}");
                            continue;
                        }
                    };
                    let mac = caps.name("mac").map_or("", |m| m.as_str());
                    let mac: MacAddr = match mac.parse() {
                        Ok(m) => m,
                        Err(e) => {
                            warn!("parse neighbor 'mac' error:  {e}");
                            continue;
                        }
                    };
                    if !mac.is_zero() {
                        ret.insert(addr, mac);
                    }
                }
                None => warn!("line: [{}] neighbor_re no match", line),
            }
        }
        Ok(ret)
    }
    #[cfg(any(
        target_os = "freebsd",
        target_os = "openbsd",
        target_os = "netbsd",
        target_os = "macos"
    ))]
    pub fn init() -> Result<HashMap<IpAddr, MacAddr>, PistolError> {
        // Examples:
        // # arp -a
        // ? (192.168.72.1) at 00:50:56:c0:00:08 on em0 expires in 1139 seconds [ethernet]
        // ? (192.168.72.129) at 00:0c:29:88:20:d2 on em0 permanent [ethernet]
        // ? (192.168.72.2) at 00:50:56:fb:1d:74 on em0 expires in 1168 seconds [ethernet]
        // MacOS
        // ? (192.168.50.2) at (incomplete) on en0 ifscope [ethernet]
        // # ndp -a
        // Neighbor                             Linklayer Address  Netif Expire    1s 5s
        // fe80::20c:29ff:fe88:20d2%em0         00:0c:29:88:20:d2    em0 permanent R
        // fe80::20c:29ff:feb8:a41%em0          00:0c:29:b8:0a:41    em0 permanent R
        let c = Command::new("sh").args(["-c", "arp -a"]).output()?;
        let arp_output = String::from_utf8_lossy(&c.stdout);
        let c = Command::new("sh").args(["-c", "ndp -a"]).output()?;
        let ndp_output = String::from_utf8_lossy(&c.stdout);
        let output = arp_output.to_string() + &ndp_output;
        let lines: Vec<&str> = output
            .lines()
            .map(|x| x.trim())
            .filter(|v| v.len() > 0 && !v.contains("Neighbor"))
            .collect();

        // regex
        let neighbor_re = Regex::new(r"\?\s+\((?P<addr>[^\s]+)\)\s+at\s+(?P<mac>[\w\d:]+).+")?;
        let neighbor_re6 = Regex::new(r"(?P<addr>[^\s]+)\s+(?P<mac>[^\s]+).+")?;

        let mut ret = HashMap::new();
        for line in lines {
            match neighbor_re.captures(line) {
                Some(caps) => {
                    let addr_str = caps.name("addr").map_or("", |m| m.as_str());
                    let addr_str = ipv6_addr_bsd_fix(addr_str)?;
                    let addr: IpAddr = match addr_str.parse() {
                        Ok(a) => a,
                        Err(e) => {
                            warn!("parse neighbor 'addr' error:  {e}");
                            continue;
                        }
                    };
                    let mac = caps.name("mac").map_or("", |m| m.as_str());
                    let mac: MacAddr = match mac.parse() {
                        Ok(m) => m,
                        Err(e) => {
                            warn!("parse neighbor 'mac' error:  {e}");
                            continue;
                        }
                    };
                    ret.insert(addr, mac);
                }
                // it maybe the ipv6 addr
                None => match neighbor_re6.captures(line) {
                    Some(caps) => {
                        let addr_str = caps.name("addr").map_or("", |m| m.as_str());
                        let addr_str = ipv6_addr_bsd_fix(addr_str)?;
                        let addr: IpAddr = match addr_str.parse() {
                            Ok(a) => a,
                            Err(e) => {
                                warn!("parse neighbor 'addr' error:  {e}");
                                continue;
                            }
                        };
                        let mac = caps.name("mac").map_or("", |m| m.as_str());
                        let mac: MacAddr = match mac.parse() {
                            Ok(m) => m,
                            Err(e) => {
                                warn!("parse neighbor 'mac' error:  {e}");
                                continue;
                            }
                        };
                        if !mac.is_zero() {
                            ret.insert(addr, mac);
                        }
                    }
                    None => warn!(
                        "line: [{}] neighbor_re and neighbor_re6 both no match",
                        line
                    ),
                },
            }
        }
        Ok(ret)
    }
    #[cfg(target_os = "windows")]
    pub fn init() -> Result<HashMap<IpAddr, MacAddr>, PistolError> {
        // Examples:
        // 58 ff02::1:ff73:3ff4 33-33-FF-73-3F-F4 Permanent ActiveStore
        // 58 ff02::1:2  33-33-00-01-00-02 Permanent ActiveStore
        // 12 ff05::c Permanent ActiveStore
        let c = Command::new("powershell")
            .args(["Get-NetNeighbor"])
            .output()?;
        let output = String::from_utf8_lossy(&c.stdout);
        let lines: Vec<&str> = output
            .lines()
            .map(|x| x.trim())
            .filter(|v| v.len() > 0 && !v.contains("ifIndex") && !v.contains("--"))
            .collect();

        // regex
        let neighbor_re =
            Regex::new(r"^\d+\s+(?P<addr>[\w\d\.:]+)\s+((?P<mac>[\w\d-]+)\s+)?\w+\s+\w+")?;

        let mut ret = HashMap::new();
        for line in lines {
            match neighbor_re.captures(line) {
                Some(caps) => {
                    let addr = caps.name("addr").map_or("", |m| m.as_str());
                    let addr: IpAddr = match addr.parse() {
                        Ok(a) => a,
                        Err(e) => {
                            warn!("parse neighbor 'addr' error:  {e}");
                            continue;
                        }
                    };
                    let mac: Option<String> =
                        caps.name("mac").map_or(None, |m| Some(m.as_str().into()));
                    // 33-33-00-01-00-02 => 33:33:00:01:00:02
                    match mac {
                        Some(mac) => {
                            let mac = mac.replace("-", ":");
                            let mac: MacAddr = match mac.parse() {
                                Ok(m) => m,
                                Err(e) => {
                                    warn!("parse neighbor 'mac' error:  {e}");
                                    continue;
                                }
                            };
                            if !mac.is_zero() {
                                // do not insert 00-00-00-00-00-00
                                ret.insert(addr, mac);
                            }
                        }
                        None => (),
                    }
                }
                None => warn!("line: [{}] neighbor_re no match", line),
            }
        }
        Ok(ret)
    }
}

#[derive(Debug, Clone)]
pub struct SystemNetCache {
    pub default_route: Option<DefaultRoute>,
    pub default_route6: Option<DefaultRoute>,
    pub routes: HashMap<RouteAddr, RouteInfo>,
    pub neighbor: HashMap<IpAddr, MacAddr>,
}

impl SystemNetCache {
    pub fn init() -> Result<SystemNetCache, PistolError> {
        let route_table = RouteTable::init()?;
        debug!("route table: {}", route_table);
        let neighbor_cache = NeighborCache::init()?;
        debug!("neighbor cache: {:?}", neighbor_cache);
        let snc = SystemNetCache {
            default_route: route_table.default_route,
            default_route6: route_table.default_route6,
            routes: route_table.routes,
            neighbor: neighbor_cache,
        };
        Ok(snc)
    }
    pub fn search_mac(&self, ip: IpAddr) -> Option<MacAddr> {
        match self.neighbor.get(&ip) {
            Some(&m) => Some(m),
            None => None,
        }
    }
    pub fn update_neighbor_cache(&mut self, ip: IpAddr, mac: MacAddr) {
        self.neighbor.insert(ip, mac);
        debug!("update the neigh cache done: {:?}", self.neighbor);
    }
    pub fn search_route_table(&self, ip: IpAddr) -> Option<RouteInfo> {
        for (dst, route_info) in &self.routes {
            if !dst.is_unspecified() && dst.contains(ip) {
                debug!(
                    "route table {} contains target ip, route info dev: {}, via: {:?}",
                    dst, route_info.dev.name, route_info.via
                );
                return Some(route_info.clone());
            }
        }
        None
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::PistolLogger;
    use crate::PistolRunner;
    use pnet::datalink::interfaces;
    use std::fs::read_to_string;
    #[test]
    fn test_network_cache() {
        let _pr = PistolRunner::init(
            PistolLogger::Debug,
            None,
            None, // use default value
        )
        .unwrap();

        let snc = SystemNetCache::init().unwrap();
        for (route_addr, route_info) in snc.routes {
            println!(
                "route_addr: {:?}, route_info.dev: {}, route_info.via: {:?}",
                route_addr, route_info.dev.name, route_info.via
            );
        }
    }
    #[test]
    fn test_details() {
        let n = NeighborCache::init().unwrap();
        println!("{:?}", n);

        let r = RouteTable::init().unwrap();
        println!("{:?}", r);
    }
    #[test]
    fn test_mac() {
        let mac = MacAddr::new(0, 0, 0, 0, 0, 0);
        println!("{}", mac);
        assert_eq!(mac.is_zero(), true)
    }
    #[test]
    fn test_windows_interface() {
        println!("TEST!!!!");
        for interface in interfaces() {
            // can not found ipv6 address in windows
            println!("{}", interface);
            println!("{}", interface.index);
        }
    }
    #[test]
    fn test_unix() {
        let input = "fe80::%em0/64";
        let input_split: Vec<&str> = input
            .split("%")
            .map(|x| x.trim())
            .filter(|v| v.len() > 0)
            .collect();
        let _ip: IpAddr = input_split[0].parse().unwrap();
        let ipnetwork = IpNetwork::from_str("fe80::").unwrap();
        let test_ipv6: IpAddr = "fe80::20c:29ff:feb6:8d99".parse().unwrap();
        println!("{}", ipnetwork.contains(test_ipv6));
        let ipnetwork = IpNetwork::from_str("fe80::/64").unwrap();
        let test_ipv6: IpAddr = "fe80::20c:29ff:feb6:8d99".parse().unwrap();
        println!("{}", ipnetwork.contains(test_ipv6));
        let ipnetwork = IpNetwork::from_str("::/96").unwrap();
        let test_ipv6: IpAddr = "fe80::20c:29ff:feb6:8d99".parse().unwrap();
        println!("{}", ipnetwork.contains(test_ipv6));
    }
    #[test]
    fn test_all() {
        let _pr = PistolRunner::init(
            PistolLogger::Debug,
            None,
            None, // use default value
        )
        .unwrap();

        #[cfg(target_os = "linux")]
        let routetable_str = read_to_string("./tests/linux_routetable.txt").unwrap();

        #[cfg(any(
            target_os = "freebsd",
            target_os = "openbsd",
            target_os = "netbsd",
            target_os = "macos"
        ))]
        let routetable_str = read_to_string("./tests/unix_routetable.txt").unwrap();

        #[cfg(target_os = "windows")]
        let routetable_str = read_to_string("./tests/windows_routetable.txt").unwrap();

        let routetable_fix: Vec<String> = routetable_str
            .lines()
            .map(|x| x.trim().to_string())
            .collect();

        let mut routetables = Vec::new();
        let mut tmp = Vec::new();
        for r in &routetable_fix {
            if r != "+++" {
                // split line
                tmp.push(r.clone());
            } else {
                routetables.push(tmp.clone());
                tmp.clear();
            }
        }

        for t in routetables {
            let ret = InnerRouteTable::parser(&t).unwrap();
            println!("{}", ret);
            println!("-------------------------------------------------------------------------");
        }
    }
}