use crate::{Gateway, MacAddress, NetNode, RequiredRoute, Route, debounce::BurstGuard};

use default_routes::DefaultRouteMonitor;
use futures::{
    channel::mpsc::{self, UnboundedReceiver},
    future::FutureExt,
    stream::{FusedStream, StreamExt},
};
use ip_map::IpMap;
use ipnetwork::IpNetwork;
use nix::net::if_::if_nametoindex;
use std::{
    collections::{BTreeMap, HashSet},
    net::{IpAddr, SocketAddr},
    pin::Pin,
    sync::Weak,
    time::Duration,
};
use talpid_types::ErrorExt;

use super::RouteManagerCommand;
use data::{Destination, RouteDestination, RouteMessage, RouteSocketMessage};

pub use super::DefaultRouteEvent;
pub use interface::DefaultRoute;

/// PF_ROUTE/[RoutingTable] types
pub mod data;
mod default_routes;
mod interface;
mod ip_map;
mod routing_socket;
mod watch;

pub use watch::RoutingTable;

pub use watch::Error as RouteError;

pub type Result<T> = std::result::Result<T, Error>;

const BURST_BUFFER_PERIOD: Duration = Duration::from_millis(200);
const BURST_LONGEST_BUFFER_PERIOD: Duration = Duration::from_secs(2);

/// Errors that can happen in the macOS routing integration.
#[derive(thiserror::Error, Debug)]
pub enum Error {
    /// Encountered an error when interacting with the routing socket
    #[error("Error occurred when interfacing with the routing table")]
    RoutingTable(#[source] watch::Error),

    /// Failed to remove route
    #[error("Error occurred when deleting a route")]
    DeleteRoute(#[source] watch::Error),

    /// Failed to add route
    #[error("Error occurred when adding a route")]
    AddRoute(#[source] watch::Error),

    /// Failed to fetch link addresses
    #[error("Failed to fetch link addresses")]
    FetchLinkAddresses(#[source] std::io::Error),

    /// Received message isn't valid
    #[error("Invalid data")]
    InvalidData(#[source] data::Error),
}

/// Route manager can be in 1 of 4 states -
///  - waiting for a route to be added or removed from the route table
///  - obtaining default routes
///  - applying changes to the route table
///  - shutting down
///
/// Only the _shutting down_ state can be reached from all other states, but during normal
/// operation, the route manager will add all the required routes during startup and will start
/// waiting for changes to the route table.  If any change is detected, it will stop listening for
/// new changes, obtain new default routes and reapply routes that should be routed through the
/// default nodes. Once the routes are reapplied, the route table changes are monitored again.
pub struct RouteManagerImpl {
    /// Interface to the macOS routing table.
    routing_table: RoutingTable,

    /// Routes that use the default non-tunnel interface.
    non_tunnel_routes: HashSet<IpNetwork>,

    /// The IPv4 and IPv6 routes that we will add that points at the tun interface.
    ///
    /// This is populated by [Self::add_required_routes]
    /// and used by [Self::apply_tunnel_default_routes].
    tunnel_default_routes: IpMap<data::RouteMessage>,

    /// The list of routes we have added to macOSs routing table in [Self::add_route_with_record].
    applied_routes: BTreeMap<RouteDestination, RouteMessage>,

    /// Callback that fires when we receive an event from our route-monitoring socket,
    /// or from [Self::interface_change_rx]. It indicates that *something* has changed with the
    /// routing table or with the network interfaces.
    update_trigger: BurstGuard,

    /// Indicates that `best_default_route` has changed, or that a `/0`-route in the routing table
    /// was changed.
    unhandled_default_route_changes: bool,

    check_default_routes_restored: Pin<Box<dyn FusedStream<Item = ()> + Send>>,

    /// Channel that receives updates to the best [DefaultRoute] for IPv4.
    best_default_route_rx_v4: UnboundedReceiver<Option<DefaultRoute>>,

    /// Channel that receives updates to the best [DefaultRoute] for IPv6.
    best_default_route_rx_v6: UnboundedReceiver<Option<DefaultRoute>>,

    /// The best IPv4 and v6 network routes suggested by macOS.
    ///
    /// Example: Interface "en0" (1) with IP 192.168.1.222, and with router_ip 192.168.1.1.
    best_default_route: IpMap<interface::DefaultRoute>,

    /// Message to notify `default_route_listeners` when `best_default_route` changes.
    best_default_route_update: IpMap<DefaultRouteEvent>,

    default_route_listeners: Vec<mpsc::UnboundedSender<DefaultRouteEvent>>,

    interface_change_listeners: Vec<mpsc::UnboundedSender<super::InterfaceEvent>>,
}

impl RouteManagerImpl {
    /// Create new route manager
    #[allow(clippy::unused_async)]
    pub(crate) async fn new(
        manage_tx: Weak<mpsc::UnboundedSender<RouteManagerCommand>>,
    ) -> Result<Self> {
        let (primary_interface_monitor, interface_change_rx) =
            interface::PrimaryInterfaceMonitor::new();

        let (best_route_rx_v4, best_route_rx_v6) =
            DefaultRouteMonitor::start(primary_interface_monitor, interface_change_rx);

        let routing_table = RoutingTable::new().map_err(Error::RoutingTable)?;

        let update_trigger = BurstGuard::new(
            BURST_BUFFER_PERIOD,
            BURST_LONGEST_BUFFER_PERIOD,
            move || {
                if let Some(manage_tx) = manage_tx.upgrade() {
                    let _ = manage_tx.unbounded_send(RouteManagerCommand::RefreshRoutes);
                }
            },
        );

        Ok(Self {
            routing_table,
            non_tunnel_routes: HashSet::new(),
            tunnel_default_routes: IpMap::new(),
            applied_routes: BTreeMap::new(),
            best_default_route: IpMap::new(),
            best_default_route_update: IpMap::new(),
            default_route_listeners: vec![],
            best_default_route_rx_v4: best_route_rx_v4,
            best_default_route_rx_v6: best_route_rx_v6,
            update_trigger,
            check_default_routes_restored: Box::pin(futures::stream::pending()),
            unhandled_default_route_changes: false,
            interface_change_listeners: vec![],
        })
    }

    pub(crate) async fn run(mut self, manage_rx: mpsc::UnboundedReceiver<RouteManagerCommand>) {
        let mut manage_rx = manage_rx.fuse();

        let mut completion_tx = None;

        loop {
            talpid_types::detect_flood!();

            futures::select_biased! {
                route_message = self.routing_table.next_message().fuse() => {
                    self.handle_route_message(route_message);
                }

                _ = self.check_default_routes_restored.next() => {
                    talpid_types::detect_flood!();

                    if self.check_default_routes_restored.is_terminated() {
                        continue;
                    }

                    if self.try_restore_default_routes().await {
                        log::debug!("Unscoped routes were already restored");
                        self.check_default_routes_restored = Box::pin(futures::stream::pending());
                    }
                }

                new_best_route = self.best_default_route_rx_v4.next() => {
                    let Some(new_best_route)= new_best_route else { continue };
                    self.handle_new_best_default_route(interface::Family::V4, new_best_route);
                }

                new_best_route = self.best_default_route_rx_v6.next() => {
                    let Some(new_best_route)= new_best_route else { continue };
                    self.handle_new_best_default_route(interface::Family::V6, new_best_route);
                }

                command = manage_rx.next() => {
                    match command {
                        Some(RouteManagerCommand::Shutdown(tx)) => {
                            completion_tx = Some(tx);
                            break;
                        },

                        Some(RouteManagerCommand::NewDefaultRouteListener(tx)) => {
                            let (events_tx, events_rx) = mpsc::unbounded();
                            self.default_route_listeners.push(events_tx);
                            let _ = tx.send(events_rx);
                        }
                        Some(RouteManagerCommand::GetDefaultRoutes(tx)) => {
                            let v4_route = self.best_default_route.get(interface::Family::V4).cloned();
                            let v6_route = self.best_default_route.get(interface::Family::V6).cloned();
                            let _ = tx.send((v4_route, v6_route));
                        }
                        Some(RouteManagerCommand::GetDefaultGateway(tx)) => {
                            let mut v4_gateway = None;
                            let mut v6_gateway = None;

                            if let Some(v4_route) = self.best_default_route.get(interface::Family::V4) {
                                v4_gateway = self.get_gateway_link_address(v4_route.router_ip).await;
                            }
                            if let Some(v6_route) = self.best_default_route.get(interface::Family::V6) {
                                v6_gateway = self.get_gateway_link_address(v6_route.router_ip).await;
                            }
                            let _ = tx.send((v4_gateway, v6_gateway));
                        }

                        Some(RouteManagerCommand::AddRoutes(routes, tx)) => {
                            if !self.check_default_routes_restored.is_terminated() {
                                log::debug!("Cancelling restoration of default routes");
                                self.check_default_routes_restored = Box::pin(futures::stream::pending());
                            }
                            log::debug!("Adding routes: {routes:?}");
                            let _ = tx.send(self.add_required_routes(routes).await);
                        }
                        Some(RouteManagerCommand::ClearRoutes) => {
                            if let Err(err) = self.cleanup_routes().await {
                                log::error!("Failed to clean up rotues: {err}");
                            }
                        },

                        Some(RouteManagerCommand::NewInterfaceChangeListener(tx)) => {
                            let (events_tx, events_rx) = mpsc::unbounded();
                            self.interface_change_listeners.push(events_tx);
                            let _ = tx.send(events_rx);
                        }

                        Some(RouteManagerCommand::RefreshRoutes) => {
                            if let Err(error) = self.refresh_routes().await {
                                log::error!("Failed to refresh routes: {error}");
                            }
                        },
                        None => {
                            break;
                        }
                    }
                },
            };
        }

        if let Err(err) = self.cleanup_routes().await {
            log::error!("Failed to clean up routing table when shutting down: {err}");
        }

        self.update_trigger.stop_nonblocking();

        if let Some(tx) = completion_tx {
            let _ = tx.send(());
        }
    }

    async fn get_gateway_link_address(&mut self, gateway_ip: IpAddr) -> Option<Gateway> {
        let gateway_msg = RouteMessage::new_route(Destination::Host(gateway_ip));

        if let Ok(Some(msg)) = self.routing_table.get_route(&gateway_msg).await {
            if let Some(gateway) = msg
                .gateway()
                .and_then(|gateway| gateway.as_link_addr())
                .and_then(|addr| addr.addr())
            {
                let mac_address = MacAddress::from(gateway);
                return Some(Gateway {
                    ip_address: gateway_ip,
                    mac_address,
                });
            }
        }
        None
    }

    async fn add_required_routes(&mut self, required_routes: HashSet<RequiredRoute>) -> Result<()> {
        let mut routes_to_apply = vec![];

        for route in required_routes {
            match route.node {
                NetNode::DefaultNode => {
                    self.non_tunnel_routes.insert(route.prefix);
                }

                NetNode::RealNode(node) => {
                    let mut applied_route = Route::new(node, route.prefix);
                    applied_route.mtu = route.mtu.map(u32::from);
                    routes_to_apply.push(applied_route);
                }
            }
        }

        // Map all interfaces to their link addresses
        let interface_link_addrs =
            interface::get_interface_link_addresses().map_err(Error::FetchLinkAddresses)?;

        // Add routes not using the default interface
        for route in routes_to_apply {
            let mut message = if let Some(device) = route.node.get_device() {
                // Get the link-address of the provided network interface (device).
                // We need the link address to create a route that targets the interface.
                let Some(link_addr) = interface_link_addrs.get(device) else {
                    log::error!("Route with unknown device: {route:?}, {device}");
                    continue;
                };

                // Get the index of the network interface. This is not needed to create the route,
                // but we use it to later validate that the route is correct.
                let Ok(interface_index) = if_nametoindex(device) else {
                    log::error!("Route with unknown device: {route:?}, {device}");
                    continue;
                };

                RouteMessage::new_route(Destination::from(route.prefix))
                    .set_gateway_addr(*link_addr)
                    .set_interface_index(interface_index as u16)
            } else {
                log::error!("Specifying gateway by IP rather than device is unimplemented");
                continue;
            };

            if let Some(mtu) = route.mtu {
                message = message.set_mtu(mtu);
            }

            // Default routes are a special case: We must apply it after replacing the current
            // default route with an ifscope route.
            if route.prefix.prefix() == 0 {
                let family = if route.prefix.is_ipv4() {
                    interface::Family::V4
                } else {
                    interface::Family::V6
                };
                self.tunnel_default_routes.insert(family, message);
                continue;
            }

            self.add_route_with_record(message).await?;
        }

        self.apply_tunnel_default_routes().await?;

        // Add routes that use the default interface
        if let Err(error) = self.apply_non_tunnel_routes().await {
            self.non_tunnel_routes.clear();
            return Err(error);
        }

        Ok(())
    }

    fn handle_route_message(
        &mut self,
        message: std::result::Result<RouteSocketMessage, watch::Error>,
    ) {
        talpid_types::detect_flood!();

        log::trace!("got RouteSocketMessage::{:?}", message.as_ref().unwrap());

        match message {
            Ok(RouteSocketMessage::DeleteRoute(route)) => {
                // Forget about applied route, if relevant
                match RouteDestination::try_from(&route).map_err(Error::InvalidData) {
                    Ok(destination) => {
                        self.applied_routes.remove(&destination);
                    }
                    Err(err) => {
                        log::error!("Failed to process deleted route: {err}");
                    }
                }
                if route.errno() != 0 {
                    return;
                }
                if route.is_default().unwrap_or(true) {
                    self.unhandled_default_route_changes = true;
                }
                self.update_trigger.trigger();
            }
            Ok(RouteSocketMessage::AddRoute(route) | RouteSocketMessage::ChangeRoute(route)) => {
                if route.errno() != 0 {
                    return;
                }
                if route.is_default().unwrap_or(true) {
                    self.unhandled_default_route_changes = true;
                }
                self.update_trigger.trigger();
            }
            Ok(RouteSocketMessage::AddAddress(_) | RouteSocketMessage::DeleteAddress(_)) => {
                self.update_trigger.trigger();
            }
            Ok(RouteSocketMessage::Interface(iface)) => {
                let Ok(mtu) = u16::try_from(iface.mtu()) else {
                    log::warn!("Invalid mtu for interface: {}", iface.index());
                    return;
                };

                self.interface_change_listeners.retain(|tx| {
                    tx.unbounded_send(super::InterfaceEvent {
                        interface_index: iface.index(),
                        mtu,
                    })
                    .is_ok()
                });
            }
            // ignore all other message types
            Ok(_) => {}
            Err(err) => {
                log::error!(
                    "{}",
                    err.display_chain_with_msg(
                        "Failed to receive a message from the routing table"
                    )
                );
            }
        }
    }

    /// Handle changes to the routing table:
    /// * Replace the unscoped default route with a default route for the tunnel interface (i.e.,
    ///   one whose gateway is set to the link address of the tunnel interface).
    /// * At the same time, update the route used by non-tunnel interfaces to reach the relay/VPN
    ///   server. The gateway of the relay route is set to the first interface in the network
    ///   service order that has a working ifscoped default route.
    async fn refresh_routes(&mut self) -> Result<()> {
        talpid_types::detect_flood!();

        for (_, event) in self.best_default_route_update.drain() {
            self.default_route_listeners
                .retain(|tx| tx.unbounded_send(event).is_ok());
        }

        if !self.unhandled_default_route_changes {
            self.ensure_default_tunnel_routes_exist().await?;
            return Ok(());
        }

        log::trace!("Refreshing routes");

        // Remove any existing ifscoped default route that we've added
        self.remove_applied_routes(|route| route.ifscope() && route.is_default().unwrap_or(false))
            .await;

        // Substitute route with a tunnel route
        self.apply_tunnel_default_routes().await?;

        // Update routes using default interface
        self.apply_non_tunnel_routes().await?;

        self.unhandled_default_route_changes = false;

        Ok(())
    }

    /// Handle a new [DefaultRoute] received from [DefaultRouteMonitor].
    fn handle_new_best_default_route(
        &mut self,
        family: interface::Family,
        new_best_route: Option<DefaultRoute>,
    ) {
        log::trace!("Best route ({family:?}): {new_best_route:?}");

        let event = match (family, new_best_route.is_some()) {
            (interface::Family::V4, true) => DefaultRouteEvent::AddedOrChangedV4,
            (interface::Family::V4, false) => DefaultRouteEvent::RemovedV4,
            (interface::Family::V6, true) => DefaultRouteEvent::AddedOrChangedV6,
            (interface::Family::V6, false) => DefaultRouteEvent::RemovedV6,
        };
        self.best_default_route_update.insert(family, event);
        self.best_default_route.set(family, new_best_route);
        self.unhandled_default_route_changes = true;
        self.update_trigger.trigger();
    }

    /// Replace the default routes with an ifscope route, and
    /// add a new default tunnel route.
    async fn apply_tunnel_default_routes(&mut self) -> Result<()> {
        // As long as the relay route has a way of reaching the internet, we'll want to add a tunnel
        // route for both IPv4 and IPv6.
        // NOTE: This is incorrect. We're assuming that any "default destination" is used for
        // tunneling.
        let v4_conn = self.non_tunnel_routes.iter().any(|r| r.is_ipv4());
        let v6_conn = self.non_tunnel_routes.iter().any(|r| r.is_ipv6());

        let relay_route_is_valid = (v4_conn
            && self.best_default_route.get(interface::Family::V4).is_some())
            || (v6_conn && self.best_default_route.get(interface::Family::V6).is_some());

        if !relay_route_is_valid {
            return Ok(());
        }

        for (family, tunnel_route) in self.tunnel_default_routes.clone().iter() {
            // Replace the default route with an ifscope route
            self.replace_with_scoped_route(family).await?;

            // Make sure there is really no other unscoped default route

            let actual_default_route = self.get_actual_default_route(family).await.unwrap_or(None);

            if let Some(actual_default_route) = actual_default_route {
                debug_assert!(tunnel_route.interface_index() != 0);
                if tunnel_route.interface_index() != actual_default_route.interface_index() {
                    log::trace!("Removing existing unscoped default route");

                    let _ = self
                        .routing_table
                        .delete_route(&default_route_msg(family))
                        .await;
                } else if !actual_default_route.ifscope() {
                    continue; // Skipping route
                }
            }

            log::debug!("Adding default route for tunnel ({family:?})");
            self.add_route_with_record(tunnel_route.clone()).await?;
        }

        Ok(())
    }

    /// Update/add routes that use the default non-tunnel interface. If some applied destination is
    /// a default route, this function replaces the non-tunnel default route with an ifscope route.
    async fn apply_non_tunnel_routes(&mut self) -> Result<()> {
        let v4_gateway = self
            .best_default_route
            .get(interface::Family::V4)
            .map(|route| SocketAddr::new(route.router_ip, 0));
        let v6_gateway = self
            .best_default_route
            .get(interface::Family::V6)
            .map(|route| SocketAddr::new(route.router_ip, 0));

        // Reapply routes that use the default (non-tunnel) node
        for dest in self.non_tunnel_routes.clone() {
            let gateway = if dest.is_ipv4() {
                v4_gateway
            } else {
                v6_gateway
            };
            let gateway = match gateway {
                Some(gateway) => gateway,
                None => continue,
            };
            let route =
                RouteMessage::new_route(Destination::Network(dest)).set_gateway_addr(gateway);

            if let Some(dest) = self
                .applied_routes
                .keys()
                .find(|applied_dest| applied_dest.network == dest)
                .cloned()
            {
                let _ = self.routing_table.delete_route(&route).await;
                self.applied_routes.remove(&dest);
            }

            self.add_route_with_record(route).await?;
        }

        Ok(())
    }

    /// Replace a known default route with an ifscope route.
    async fn replace_with_scoped_route(&mut self, family: interface::Family) -> Result<()> {
        let Some(default_route) = self.best_default_route.get(family) else {
            return Ok(());
        };

        let interface_index = default_route.interface_index;
        let default_route = RouteMessage::from(default_route.clone());
        let new_route = default_route
            .set_interface_index(interface_index)
            .set_ifscope();

        log::trace!("Setting ifscope: {new_route:?}");

        self.add_route_with_record(new_route).await
    }

    async fn add_route_with_record(&mut self, route: RouteMessage) -> Result<()> {
        let destination = RouteDestination::try_from(&route).map_err(Error::InvalidData)?;

        let add_result = self
            .routing_table
            .add_route(&route)
            .await
            .map_err(Error::AddRoute)?;

        if add_result == watch::AddResult::Ok {
            self.applied_routes.insert(destination, route);
        }
        Ok(())
    }

    async fn cleanup_routes(&mut self) -> Result<()> {
        self.remove_applied_routes(|_| true).await;

        // We have already removed the applied default routes
        self.tunnel_default_routes.remove(interface::Family::V4);
        self.tunnel_default_routes.remove(interface::Family::V6);

        self.try_restore_default_routes().await;

        self.check_default_routes_restored = Self::create_default_route_check_timer();

        self.non_tunnel_routes.clear();

        Ok(())
    }

    /// Remove all applied routes for which `filter` returns true
    async fn remove_applied_routes(&mut self, filter: impl Fn(&RouteMessage) -> bool) {
        let mut deleted_routes = vec![];

        self.applied_routes.retain(|_dest, route| {
            if filter(route) {
                deleted_routes.push(route.clone());
                return false;
            }
            true
        });

        for route in deleted_routes {
            log::trace!("Removing route: {route:?}");
            match self.routing_table.delete_route(&route).await {
                Ok(_) | Err(watch::Error::RouteNotFound) | Err(watch::Error::Unreachable) => (),
                Err(err) => {
                    log::error!("Failed to remove relay route: {err:?}");
                }
            }
        }
    }

    /// FIXME: Hack. Restoring the default routes during cleanup sometimes fails, so repeatedly try
    /// until we have restored unscoped default routes. This function produces a timer for
    /// exponential backoff.
    fn create_default_route_check_timer() -> Pin<Box<dyn FusedStream<Item = ()> + Send>> {
        const RESTORE_HACK_INITIAL_INTERVAL: Duration = Duration::from_millis(500);
        const RESTORE_HACK_INTERVAL_MULTIPLIER: u32 = 5;
        const RESTORE_HACK_MAX_ATTEMPTS: u32 = 3;

        Box::pin(futures::stream::unfold(0, |attempt| async move {
            if attempt >= RESTORE_HACK_MAX_ATTEMPTS {
                return None;
            }

            let next_interval = RESTORE_HACK_INITIAL_INTERVAL
                * RESTORE_HACK_INTERVAL_MULTIPLIER.saturating_pow(attempt);
            tokio::time::sleep(next_interval).await;

            Some(((), attempt + 1))
        }))
    }

    /// Add back unscoped default routes, if they are still missing. This function returns
    /// true when no routes had to be added.
    async fn try_restore_default_routes(&mut self) -> bool {
        self.restore_default_route(interface::Family::V4).await
            && self.restore_default_route(interface::Family::V6).await
    }

    /// Add back unscoped default route for the given `family`, if it is still missing. This
    /// function returns true when no route had to be added.
    async fn restore_default_route(&mut self, family: interface::Family) -> bool {
        let Some(desired_default_route) = self.best_default_route.get(family).cloned() else {
            return true;
        };
        let desired_default_route = RouteMessage::from(desired_default_route);

        let current_default_route = RouteMessage::new_route(family.default_network().into());

        if let Ok(Some(current_default)) =
            self.routing_table.get_route(&current_default_route).await
        {
            // We're done if the route we're looking for is already here
            if route_matches_interface(&current_default, &desired_default_route) {
                log::trace!("current default route for {family:?} matches the desired");
                return true;
            }

            log::trace!("current default route for {family:?} does NOT match the desired");
            let _ = self
                .routing_table
                .delete_route(&current_default_route)
                .await;
        } else {
            log::trace!("no current default route")
        }

        if let Err(error) = self.routing_table.add_route(&desired_default_route).await {
            log::trace!("Failed to add unscoped default {family} route: {error}");
        }

        self.update_trigger.trigger();

        false
    }

    async fn ensure_default_tunnel_routes_exist(&mut self) -> Result<()> {
        for (family, _) in self.tunnel_default_routes.clone().iter() {
            if !self.default_route_is_tunnel_route(family).await? {
                return self.apply_tunnel_default_routes().await;
            }
        }

        Ok(())
    }

    /// Check if the `0.0.0.0/0`/`::/0`-route goes to our tunnel interface.
    async fn default_route_is_tunnel_route(&mut self, family: interface::Family) -> Result<bool> {
        let actual_default_route = self.get_actual_default_route(family).await?;

        let Some(actual_default_route) = actual_default_route else {
            return Ok(false);
        };

        let Some(tunnel_route) = self.tunnel_default_routes.get(family) else {
            return Ok(false);
        };

        Ok(actual_default_route.interface_index() == tunnel_route.interface_index())
    }

    /// Get the route which goes to `0.0.0.0/0`/`::/0`, if any.
    async fn get_actual_default_route(
        &mut self,
        family: interface::Family,
    ) -> Result<Option<data::RouteMessage>> {
        self.routing_table
            .get_route(&default_route_msg(family))
            .await
            .map_err(Error::RoutingTable)
    }
}

/// Construct a [RouteMessage] that refers to the `0.0.0.0/0` or `::/0` route with the
/// RTF_GATEAWAY-flag set. Used to reference the default route created by macOS.
fn default_route_msg(family: interface::Family) -> RouteMessage {
    let mut msg = RouteMessage::new_route(family.default_network().into());
    msg = msg.append_route_flag(data::RouteFlag::RTF_GATEWAY);
    msg
}

fn route_matches_interface(default_route: &RouteMessage, interface_route: &RouteMessage) -> bool {
    default_route.gateway_ip() == interface_route.gateway_ip()
        && default_route.interface_index() == interface_route.interface_index()
}