ts_runtime/

status.rs

//! Netmap status aggregation, WhoIs lookups, and a netmap-change watcher.
//!
//! These surface the internal netmap state ([`ts_control::StateUpdate`], consumed by the
//! [`PeerTracker`](crate::peer_tracker::PeerTracker)) to embedders, mirroring tsnet's
//! `LocalClient::Status`, `WhoIs`, and `WatchIPNBus`.
//!
//! ## Capability / user / online surfacing (do not fabricate)
//!
//! tsnet's `Status`/`WhoIs` also carry per-node *online* state, the owning *user* (login/profile),
//! and a *capability map*. Status of each in this fork:
//! - **Capabilities** — surfaced: [`WhoIs::capabilities`] is populated from the domain
//!   [`Node`](ts_control::Node)'s `cap_map` (the control-pushed `CapMap`), which the domain model
//!   retains.
//! - **User (login/profile)** — surfaced when the netmap provided it: [`WhoIs::user_profile`] is
//!   the owning user's whole profile (login name, display name, group membership), resolved by
//!   joining the node's owning user id against the netmap's `UserProfiles` table (accumulated by
//!   the [`PeerTracker`](crate::peer_tracker::PeerTracker) across delta updates). `None` when
//!   control sent no profile for that user. [`WhoIs::user`] flattens it to one display label and
//!   [`WhoIs::user_groups`] reaches the groups an embedder authorises on.
//! - **Online state** — surfaced: [`StatusNode::online`] / [`StatusNode::last_seen`] reflect the
//!   domain [`Node`](ts_control::Node)'s retained `online`/`last_seen`, populated from the netmap
//!   node and its online deltas (`PeerChange`, `MapResponse.online_change`/`peer_seen_change`).
//!   `online` stays tri-state (`None` = unknown), never fabricated to `false`.

use std::{
    collections::BTreeMap,
    net::{IpAddr, SocketAddr},
};

use ts_control::{Node, StableNodeId, UserId, UserProfile};

/// A snapshot of the local netmap: this node plus every known peer.
///
/// Analogous to tsnet's `ipnstate.Status`. Built by [`Runtime::status`](crate::Runtime::status)
/// from the self node held by the control runner and the peers held by the peer tracker.
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct Status {
    /// This node, if a netmap has been received from control yet.
    pub self_node: Option<StatusNode>,
    /// Every peer currently known in the netmap.
    pub peers: Vec<StatusNode>,
    /// The stable id of the exit node traffic is **currently** egressing through, if any (Go's
    /// `Status.ExitNodeStatus.ID`). This is the *resolved + fail-closed* answer from the route
    /// updater — `None` when no exit node is configured, the configured selector matches no peer, or
    /// the matched peer no longer advertises a default route — so it reflects what is actually
    /// engaged, not merely what [`Config::exit_node`](ts_control::Config) requested. Find the peer's
    /// details by matching this id against [`peers`](Status::peers).
    pub active_exit_node: Option<StableNodeId>,
    /// The tailnet's MagicDNS suffix (e.g. `"tail0123.ts.net"`) — Go `ipnstate.Status.MagicDNSSuffix`.
    /// Derived (like Go's `NetworkMap.MagicDNSSuffix`) from the self node's FQDN minus its host label,
    /// **not** from the DNS config and **not** from the tailnet `Domain` name. `None` before the first
    /// netmap, or when the self FQDN has no tailnet component (a bare hostname).
    pub magic_dns_suffix: Option<String>,
}

/// A single node entry in a [`Status`] snapshot.
///
/// Analogous to tsnet's `ipnstate.PeerStatus`.
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct StatusNode {
    /// The node's stable id (stable across re-registration).
    pub stable_id: StableNodeId,
    /// A display name for the node: its fqdn if a tailnet component is known, else its bare
    /// hostname.
    pub display_name: String,
    /// The node's tailnet IPv4 address: the **first** IPv4 prefix control assigned it (the identity
    /// projection the overlay, MagicDNS and exit-node selection reason about). See
    /// [`tailscale_ips`](Self::tailscale_ips) for every address control assigned.
    pub ipv4: IpAddr,
    /// The node's tailnet IPv6 address: the **first** IPv6 prefix control assigned it. See
    /// [`tailscale_ips`](Self::tailscale_ips) for every address control assigned.
    pub ipv6: IpAddr,
    /// Every tailnet address control assigned this node (Go `ipnstate.PeerStatus.TailscaleIPs`), in
    /// wire order.
    ///
    /// Normally the same two addresses as [`ipv4`](Self::ipv4) / [`ipv6`](Self::ipv6), but
    /// `tailcfg.Node.Addresses` is a variable-length list: an IPv6-off tailnet assigns only the v4
    /// prefix, and nothing in the protocol stops control assigning more than one prefix of a family.
    /// Built from the domain [`Node::addresses`](ts_control::Node::addresses), keeping each
    /// single-IP prefix's address exactly as Go's status builder does
    /// (`ipn/ipnlocal/local.go`). This — not the first-of-family pair — is what
    /// [`is_router`](Self::is_router) asks "is this route one of my own addresses?" of.
    pub tailscale_ips: Vec<IpAddr>,
    /// Whether the node is online, if known (`ipnstate.PeerStatus.Online`). Tri-state: `Some(true)`
    /// connected to control, `Some(false)` offline, `None` unknown (control sent no online status or
    /// the local node lacks permission to know). Reflects control's liveness state, retained from the
    /// netmap node + its online deltas — `None` is *unknown*, never fabricated to `false`.
    pub online: Option<bool>,
    /// When control last saw this node online (`ipnstate.PeerStatus.LastSeen`). Per Go, only
    /// meaningful while the node is not currently online. `None` when unknown or never seen.
    pub last_seen: Option<chrono::DateTime<chrono::Utc>>,
    /// The routes this node accepts traffic for (its own `/32` and `/128`, plus any advertised
    /// subnet routes and possibly the exit-node default route).
    pub allowed_routes: Vec<ipnet::IpNet>,
    /// Whether this node advertises a default route (`0.0.0.0/0` or `::/0`), making it eligible to
    /// be selected as an exit node.
    pub is_exit_node: bool,
    /// The current trusted direct UDP endpoint for this peer, if a direct path is confirmed right now
    /// (Go `ipnstate.PeerStatus.CurAddr`). `Some` ⇒ traffic to this peer flows directly to this
    /// address; `None` ⇒ it relays via DERP (see [`relay`](Self::relay)). Mutually exclusive with a
    /// `relay` for a routed peer, mirroring Go's empty-vs-set `CurAddr`/`Relay` strings. A live
    /// snapshot — the direct path can expire/re-confirm between calls. Always `None` for the self node
    /// and a whois lookup (no path to oneself; whois is an ownership query).
    pub cur_addr: Option<SocketAddr>,
    /// The DERP region code this peer relays through when there is **no** direct path (Go
    /// `ipnstate.PeerStatus.Relay`, e.g. `"nyc"`). `Some` ⇔ [`cur_addr`](Self::cur_addr) is `None`
    /// and the peer's home DERP region is known; `None` when a direct path is confirmed, or the
    /// region code is unknown. Carries the region **code**, not its numeric id.
    pub relay: Option<String>,
    /// The node's advertised SSH host public keys in known_hosts format (Go
    /// `ipnstate.PeerStatus.SSH_HostKeys`), used by `tailscale ssh` to pin the peer's host key.
    /// Mirrors the domain [`Node::ssh_host_keys`](ts_control::Node::ssh_host_keys); empty when
    /// control advertised none (never fabricated).
    pub ssh_host_keys: Vec<String>,
    /// Whether this node's key has expired (Go `ipnstate.PeerStatus.Expired`).
    ///
    /// Set either by control on the wire or by this node's own expiry pass
    /// ([`ts_control::ExpiryManager::flag_expired_peer`]) once the node's key expiry has passed —
    /// judged against control's clock, not this host's. An expired peer is deliberately still
    /// listed: it keeps its identity so a watcher can tell "expired" apart from "gone", but it has
    /// no endpoints, no home DERP, and a broken node key, so nothing routes to it and a peerAPI
    /// dial to it is refused ([`ts_control::PEER_KEY_EXPIRED`]).
    pub expired: bool,
}

/// Whether `prefix` covers exactly one address (a `/32` or a `/128`) — Go `netip.Prefix.IsSingleIP`.
fn is_single_ip(prefix: &ipnet::IpNet) -> bool {
    let host_prefix = match prefix {
        ipnet::IpNet::V4(_) => 32,
        ipnet::IpNet::V6(_) => 128,
    };
    prefix.prefix_len() == host_prefix
}

impl StatusNode {
    /// Report whether this node is a **router**: it routes addresses besides its own. An exit
    /// node, a subnet router and an app connector are all routers.
    ///
    /// Mirrors Go's `ipnstate.PeerStatus.IsRouter` (`ipn/ipnstate/ipnstate.go`, added upstream in
    /// `8d830599b` alongside `tailcfg.Node.IsRouter`, which
    /// [`Node::is_router`](ts_control::Node::is_router) mirrors): a route in
    /// [`allowed_routes`](Self::allowed_routes) that is not a single host IP, or that is a host IP
    /// other than one of this node's own [`tailscale_ips`](Self::tailscale_ips), makes the node a
    /// router. Upstream spells both as *methods*, not wire fields — control sends nothing new for
    /// this, so it is a pure projection of the netmap a peer already gave us.
    ///
    /// The comparison is against the **whole** [`tailscale_ips`](Self::tailscale_ips) list, as Go's
    /// `slices.Contains(ps.TailscaleIPs, r.Addr())` is, and not against the first-of-family
    /// [`ipv4`](Self::ipv4)/[`ipv6`](Self::ipv6) pair. A node control handed two prefixes of one
    /// family would otherwise have the second read as a routed address and be misreported as a
    /// router — the same narrowing [`Node::is_router`](ts_control::Node::is_router) had.
    ///
    /// Strictly wider than [`is_exit_node`](Self::is_exit_node), which asks only about the default
    /// route: every exit node is a router, but a subnet router advertising no `/0` is not an exit
    /// node.
    pub fn is_router(&self) -> bool {
        self.allowed_routes.iter().any(|route| {
            // Not a single host IP, or a host IP that is not one of this node's own addresses.
            !is_single_ip(route) || !self.tailscale_ips.contains(&route.addr())
        })
    }

    /// Build a [`StatusNode`] from a domain [`Node`].
    pub fn from_node(node: &Node) -> Self {
        let is_exit_node = node
            .accepted_routes
            .iter()
            .any(|route| route.prefix_len() == 0);

        Self {
            stable_id: node.stable_id.clone(),
            display_name: node
                .fqdn_opt(false)
                .unwrap_or_else(|| node.hostname.clone()),
            ipv4: node.tailnet_address.ipv4.addr().into(),
            ipv6: node.tailnet_address.ipv6.addr().into(),
            // Go's status builder fills `PeerStatus.TailscaleIPs` from the node's whole
            // `Node.Addresses` list, keeping the address of each single-IP prefix
            // (`ipn/ipnlocal/local.go`). Take the same list, not the first-of-family pair above:
            // `is_router` compares against it.
            tailscale_ips: node
                .addresses
                .iter()
                .filter(|prefix| is_single_ip(prefix))
                .map(|prefix| prefix.addr())
                .collect(),
            online: node.online,
            last_seen: node.last_seen,
            allowed_routes: node.accepted_routes.clone(),
            is_exit_node,
            // A bare `Node` carries no live path state, so connectivity is unknown here. The peer
            // tracker overwrites these in `status_peers` by joining against the direct manager; the
            // self node and whois lookups (which also use `from_node`) correctly keep `None`.
            cur_addr: None,
            relay: None,
            ssh_host_keys: node.ssh_host_keys.clone(),
            expired: node.expired,
        }
    }
}

/// The result of a [`Runtime::whois`](crate::Runtime::whois) lookup: the node that owns a tailnet
/// source address, plus its user and capabilities.
///
/// Analogous to tsnet's `apitype.WhoIsResponse`.
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct WhoIs {
    /// The node that owns the queried source IP.
    pub node: Node,
    /// The profile of the user that owns the node — Go `apitype.WhoIsResponse.UserProfile`.
    ///
    /// Resolved by joining the node's owning user id against the netmap's `UserProfiles` table
    /// (accumulated by the [`PeerTracker`](crate::peer_tracker::PeerTracker) across delta updates).
    /// `None` when control sent no profile for that user — a tagged node with no human owner, or a
    /// profile not yet delivered. Carries the whole profile rather than one flattened label so an
    /// embedder can authorise on [`UserProfile::groups`], which is the one owner attribute a node
    /// cannot re-derive locally; [`user`](Self::user) is still there for the display case.
    pub user_profile: Option<UserProfile>,
    /// The node's **node-level** capability map (Go `Node.CapMap` — node attributes like
    /// `can-funnel`), as `(capability, args)` pairs, populated from the domain
    /// [`Node`]'s `cap_map`, sorted by capability name. Distinct from
    /// [`cap_map`](Self::cap_map), which is the flow-scoped *peer-capability* grants.
    pub capabilities: Vec<(String, Vec<String>)>,
    /// The **flow-scoped** peer-capability grants for the queried `src -> dst` flow — Go
    /// `apitype.WhoIsResponse.CapMap` (`tailcfg.PeerCapMap`). The grants control's packet-filter
    /// application rules authorize for traffic from this node to the queried address, keyed by
    /// capability name with raw-JSON values. Empty when no grant matches the flow (or no scoped
    /// query was made). Distinct from the node-level [`capabilities`](Self::capabilities).
    pub cap_map: BTreeMap<String, Vec<String>>,
}

impl WhoIs {
    /// Build a [`WhoIs`] from the owning node and its resolved owner profile (if the netmap's
    /// `UserProfiles` table mapped the node's owning user id to one; `None` when control sent no
    /// profile — e.g. a tagged node with no human owner).
    ///
    /// `capabilities` is the node-level cap map; `cap_map` (the flow-scoped grants) is filled
    /// separately by [`Runtime::whois`](crate::Runtime::whois) and defaults to empty here.
    pub(crate) fn from_node_with_profile(node: Node, user_profile: Option<UserProfile>) -> Self {
        let capabilities = node
            .cap_map
            .iter()
            .map(|(cap, args)| (cap.clone(), args.clone()))
            .collect();
        Self {
            node,
            user_profile,
            capabilities,
            cap_map: BTreeMap::new(),
        }
    }

    /// The best human-facing label for the owning user: the profile's login name when present,
    /// else its display name, else `None` (no profile, or a profile with neither).
    ///
    /// This is the flattened view [`user_profile`](Self::user_profile) replaced; use the profile
    /// itself for anything but display.
    pub fn user(&self) -> Option<String> {
        self.user_profile.as_ref().and_then(UserProfile::best_label)
    }

    /// The groups control reported for the owning user — Go
    /// `apitype.WhoIsResponse.UserProfile.Groups`. SCIM groups (e.g. `engineering@example.com`) or
    /// tailnet-policy group names (e.g. `group:eng`).
    ///
    /// The authorisation shortcut: `whois.user_groups().iter().any(|g| g == "group:eng")`.
    ///
    /// **Empty** both when there is no profile at all and when control reported no groups — which
    /// includes every control server that does not send the field. An empty list is therefore
    /// "control told this node nothing", not a proof of non-membership: fail closed on it (deny),
    /// never treat it as a negative assertion.
    pub fn user_groups(&self) -> &[String] {
        self.user_profile
            .as_ref()
            .map_or(&[], |profile| profile.groups.as_slice())
    }
}

/// Resolve which node owns a tailnet source address, used by WhoIs.
pub(crate) fn whois_addr(addr: SocketAddr) -> IpAddr {
    addr.ip()
}

/// A measured-latency entry for one DERP region in a [`NetcheckReport`].
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct RegionLatency {
    /// The DERP region id (Go `tailcfg.DERPRegionID`).
    pub region_id: u32,
    /// The measured round-trip latency to the region's closest DERP node.
    pub latency: std::time::Duration,
}

/// A snapshot of this node's latest network conditions report — the Rust analog of Go's
/// `netcheck.Report` as `tailscale netcheck` surfaces it.
///
/// ## Surfaced subset (do not fabricate)
/// Go's `netcheck.Report` also carries UDP/IPv4/IPv6 reachability, port-mapping support
/// (UPnP/PMP/PCP), `MappingVariesByDestIP`, global-address discovery, etc. This fork's net-report
/// path measures only **DERP-region latency** (the data that drives home-region selection), so the
/// report carries exactly that — the preferred (lowest-latency) region and the per-region latency
/// map — rather than inventing fields we never probe. Empty before the first measurement.
#[derive(Debug, Clone, PartialEq, Eq, Default, kameo::Reply)]
pub struct NetcheckReport {
    /// The id of the preferred DERP region — the lowest-latency region this node measured, the one it
    /// homes to (Go `Report.PreferredDERP`). `None` before the first measurement / when no region
    /// was reachable.
    pub preferred_derp: Option<u32>,
    /// Per-region measured latencies, sorted by latency ascending (Go `Report.RegionLatency`, here as
    /// an ordered list). The first entry, when present, is the [`preferred_derp`](Self::preferred_derp)
    /// region.
    pub region_latencies: Vec<RegionLatency>,
}

impl NetcheckReport {
    /// Build a report from the latest DERP-region measurements (the `RegionResult` set the latency
    /// measurer produces). `results` is expected sorted by latency ascending (the measurer's
    /// `RegionResult` `Ord` sorts on latency first), so the first entry is the preferred region; we
    /// do not re-sort beyond trusting that contract for `preferred_derp`, but the list is emitted in
    /// the order given. An empty `results` yields the default (no preferred region, empty list).
    pub(crate) fn from_region_results(results: &[ts_netcheck::RegionResult]) -> NetcheckReport {
        let region_latencies: Vec<RegionLatency> = results
            .iter()
            .map(|r| RegionLatency {
                // `ts_derp::RegionId` is a `NonZeroU32` newtype (its `.0` is the public inner).
                region_id: r.id.0.get(),
                latency: r.latency,
            })
            .collect();
        NetcheckReport {
            preferred_derp: region_latencies.first().map(|r| r.region_id),
            region_latencies,
        }
    }
}

/// A tailnet peer this node can send a Taildrop file *to*, plus the peerAPI base URL to reach it.
///
/// Analogous to tsnet's `apitype.FileTarget`. The set is produced by
/// [`Runtime::file_targets`](crate::Runtime::file_targets) (exposed as `Device::file_targets`).
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct FileTarget {
    /// The target peer's node record — pass straight to the Taildrop send path
    /// (`Device::send_file`), which re-derives the same peerAPI address.
    pub node: Node,
    /// The `http://ip:port` base URL of the peer's peerAPI, with no trailing path — the exact shape
    /// of Go's `apitype.FileTarget.PeerAPIURL`. Derived from
    /// [`Node::peerapi_addr`](ts_control::Node::peerapi_addr).
    pub peerapi_url: String,
}

/// Compute the sorted Taildrop send-target list from the peer set, given the local node's owning
/// user id. The pure core of [`Runtime::file_targets`](crate::Runtime::file_targets) — separated out
/// so the eligibility + ordering rules are unit-testable without spinning up the actor graph (the
/// node-level file-sharing gate is applied by the caller before this runs).
///
/// A peer is a target when it advertises a reachable peerAPI (Go `PeerAPIBase(p) != ""`) **and** is
/// either owned by `self_user_id` **or** carries the file-sharing-target capability — Go's two-way
/// OR. Sorted by MagicDNS name (Go sorts by `Node.Name`), falling back to the bare hostname.
pub(crate) fn build_file_targets(peers: Vec<Node>, self_user_id: UserId) -> Vec<FileTarget> {
    let mut targets: Vec<FileTarget> = peers
        .into_iter()
        .filter_map(|peer| {
            // Must advertise a reachable peerAPI (Go `PeerAPIBase(p) != ""`).
            let addr = peer.peerapi_addr()?;
            // Same owner OR explicitly an ACL file-sharing target (Go's two-way OR).
            let eligible = peer.user_id == self_user_id || peer.is_file_sharing_target();
            if !eligible {
                return None;
            }
            Some(FileTarget {
                peerapi_url: format!("http://{addr}"),
                node: peer,
            })
        })
        .collect();
    // Sort by MagicDNS name (Go sorts by `Node.Name`), bare hostname as the fallback key.
    targets.sort_by(|a, b| {
        let name = |t: &FileTarget| {
            t.node
                .fqdn_opt(false)
                .unwrap_or_else(|| t.node.hostname.clone())
        };
        name(a).cmp(&name(b))
    });
    targets
}

#[cfg(test)]
mod tests {
    use ts_control::{Node, StableNodeId, TailnetAddress};

    use super::*;

    fn node(stable: &str, hostname: &str, tailnet: Option<&str>, ipv4: &str) -> Node {
        Node {
            id: 1,
            stable_id: StableNodeId(stable.to_string()),
            hostname: hostname.to_string(),
            user_id: 0,
            tailnet: tailnet.map(str::to_string),
            tags: vec![],
            addresses: vec![
                format!("{ipv4}/32").parse().unwrap(),
                "fd7a::1/128".parse().unwrap(),
            ],
            tailnet_address: TailnetAddress {
                ipv4: format!("{ipv4}/32").parse().unwrap(),
                ipv6: "fd7a::1/128".parse().unwrap(),
            },
            node_key: [0u8; 32].into(),
            node_key_expiry: None,
            expired: false,
            online: None,
            last_seen: None,
            key_signature: vec![],
            machine_key: None,
            disco_key: None,
            accepted_routes: vec![],
            underlay_addresses: vec![],
            derp_region: None,
            cap: Default::default(),
            cap_map: Default::default(),
            peerapi_port: None,
            peerapi_dns_proxy: false,
            is_wireguard_only: false,
            exit_node_dns_resolvers: vec![],
            peer_relay: false,
            ssh_host_keys: vec![],
            service_vips: Default::default(),
            unsigned_peer_api_only: false,
        }
    }

    #[test]
    fn status_node_display_name_prefers_fqdn() {
        let with_tailnet = node("n1", "host", Some("ts.net"), "100.64.0.1");
        assert_eq!(
            StatusNode::from_node(&with_tailnet).display_name,
            "host.ts.net"
        );

        let bare = node("n2", "solo", None, "100.64.0.2");
        assert_eq!(StatusNode::from_node(&bare).display_name, "solo");
    }

    #[test]
    fn status_node_addresses_and_online_surfaced() {
        let n = node("n1", "host", Some("ts.net"), "100.64.0.7");
        let s = StatusNode::from_node(&n);

        assert_eq!(s.ipv4, "100.64.0.7".parse::<IpAddr>().unwrap());
        assert_eq!(s.ipv6, "fd7a::1".parse::<IpAddr>().unwrap());
        // A node with no online data surfaces `None` (unknown) — never a fabricated `false`.
        assert_eq!(s.online, None);
        assert_eq!(s.last_seen, None);

        // A node whose domain online state is known surfaces it through StatusNode (no longer
        // hardwired to None).
        let mut online = node("n2", "up", Some("ts.net"), "100.64.0.8");
        online.online = Some(true);
        assert_eq!(StatusNode::from_node(&online).online, Some(true));

        let mut offline = node("n3", "down", Some("ts.net"), "100.64.0.9");
        offline.online = Some(false);
        assert_eq!(StatusNode::from_node(&offline).online, Some(false));
    }

    #[test]
    fn status_node_carries_ssh_host_keys() {
        // Absent on the domain node → empty on StatusNode (never fabricated).
        let bare = node("n1", "host", Some("ts.net"), "100.64.0.1");
        assert!(StatusNode::from_node(&bare).ssh_host_keys.is_empty());

        // Present → mirrored verbatim (the keys `tailscale ssh` pins).
        let mut with_keys = node("n2", "host", Some("ts.net"), "100.64.0.2");
        with_keys.ssh_host_keys = vec!["ssh-ed25519 AAAAC3Nz host".to_string()];
        assert_eq!(
            StatusNode::from_node(&with_keys).ssh_host_keys,
            vec!["ssh-ed25519 AAAAC3Nz host".to_string()]
        );
    }

    #[test]
    fn status_node_detects_exit_node() {
        let mut not_exit = node("n1", "a", Some("ts.net"), "100.64.0.1");
        not_exit.accepted_routes = vec!["100.64.0.1/32".parse().unwrap()];
        assert!(!StatusNode::from_node(&not_exit).is_exit_node);

        let mut exit = node("n2", "b", Some("ts.net"), "100.64.0.2");
        exit.accepted_routes = vec![
            "100.64.0.2/32".parse().unwrap(),
            "0.0.0.0/0".parse().unwrap(),
        ];
        assert!(StatusNode::from_node(&exit).is_exit_node);

        let mut exit6 = node("n3", "c", Some("ts.net"), "100.64.0.3");
        exit6.accepted_routes = vec!["::/0".parse().unwrap()];
        assert!(StatusNode::from_node(&exit6).is_exit_node);
    }

    /// Ported from upstream's `TestPeerStatusIsRouter` (`ipn/ipnstate/ipnstate_test.go`,
    /// `8d830599b`), and cross-checked against [`ts_control::Node::is_router`] the way upstream's
    /// `TestNodeIsRouter` cross-checks the two definitions: a peer is a router exactly when its
    /// allowed routes reach past its own tailnet addresses. Both the present and the absent case
    /// are pinned — a plain peer must keep answering `false`.
    #[test]
    fn status_node_is_router_reports_routes_beyond_own_addresses() {
        let self4: ipnet::IpNet = "100.64.0.1/32".parse().unwrap();
        let self6: ipnet::IpNet = "fd7a:115c:a1e0::1/128".parse().unwrap();

        let cases: &[(&str, Vec<ipnet::IpNet>, bool)] = &[
            ("empty", vec![], false),
            ("plain-ipv4", vec![self4], false),
            ("plain-ipv6", vec![self6], false),
            ("plain-ipv4-ipv6", vec![self4, self6], false),
            (
                "exit-node-ipv4",
                vec![self4, "0.0.0.0/0".parse().unwrap()],
                true,
            ),
            ("exit-node-ipv6", vec![self6, "::/0".parse().unwrap()], true),
            (
                "subnet-router-ipv4",
                vec![self4, "192.0.2.0/24".parse().unwrap()],
                true,
            ),
            (
                "subnet-router-ipv6",
                vec![self6, "2001:db8::/32".parse().unwrap()],
                true,
            ),
            (
                "subnet-router-ipv4-ipv6",
                vec![
                    self4,
                    self6,
                    "192.0.2.0/24".parse().unwrap(),
                    "2001:db8::/32".parse().unwrap(),
                ],
                true,
            ),
            // No Tailscale-range exception, matching Go: another peer's /32 is a routed address.
            (
                "other-tailnet-host",
                vec![self4, "100.64.5.5/32".parse().unwrap()],
                true,
            ),
        ];

        for (name, allowed, want) in cases {
            let mut n = node("n1", "host", Some("ts.net"), "100.64.0.1");
            n.addresses = vec![self4, self6];
            n.tailnet_address.ipv6 = "fd7a:115c:a1e0::1/128".parse().unwrap();
            n.accepted_routes = allowed.clone();

            let s = StatusNode::from_node(&n);
            assert_eq!(s.is_router(), *want, "{name}");
            // The status projection and the domain node must agree, as upstream asserts of
            // `ipnstate.PeerStatus.IsRouter` against `tailcfg.Node.IsRouter`.
            assert_eq!(
                s.is_router(),
                n.is_router(),
                "{name}: domain/status disagree"
            );
        }
    }

    /// Go's `PeerStatus.IsRouter` tests each allowed prefix against the node's **whole**
    /// `TailscaleIPs` slice, so every address control assigned is "its own". `Node.Addresses` is a
    /// variable-length list, not a v4/v6 pair, so a tailnet may hand a node more than one prefix of
    /// a family; such a node must not be reported as a router on account of the extra one — which
    /// comparing only against the first-of-family `ipv4`/`ipv6` pair does. The sibling
    /// `ts_control::Node::is_router` case is pinned in `ts_control`; this pins the status
    /// projection, which carries the same list one level up.
    #[test]
    fn status_node_is_router_tests_every_assigned_address_not_only_the_first_of_each_family() {
        let first4: ipnet::IpNet = "100.64.0.1/32".parse().unwrap();
        let second4: ipnet::IpNet = "100.64.0.9/32".parse().unwrap();
        let first6: ipnet::IpNet = "fd7a:115c:a1e0::1/128".parse().unwrap();
        let second6: ipnet::IpNet = "fd7a:115c:a1e0::9/128".parse().unwrap();

        let mut n = node("n1", "host", Some("ts.net"), "100.64.0.1");
        n.addresses = vec![first4, second4, first6, second6];
        n.tailnet_address.ipv6 = "fd7a:115c:a1e0::1/128".parse().unwrap();
        // With `AllowedIPs` absent, control's routes for a node are exactly its addresses.
        n.accepted_routes = n.addresses.clone();

        let s = StatusNode::from_node(&n);

        // The identity projection is still the first prefix of each family...
        assert_eq!(s.ipv4, first4.addr());
        assert_eq!(s.ipv6, first6.addr());
        // ...and every assigned address is carried, as Go's `TailscaleIPs` is.
        assert_eq!(
            s.tailscale_ips,
            vec![first4.addr(), second4.addr(), first6.addr(), second6.addr()]
        );
        assert!(
            !s.is_router(),
            "a node whose routes are exactly its own assigned addresses is not a router"
        );
        assert_eq!(s.is_router(), n.is_router(), "domain/status disagree");

        // Either second-of-family address on its own is still not a routed address.
        for extra in [second4, second6] {
            let mut one = n.clone();
            one.accepted_routes = vec![extra];
            let s = StatusNode::from_node(&one);
            assert!(
                !s.is_router(),
                "{extra} is one of this node's own addresses"
            );
            assert_eq!(s.is_router(), one.is_router(), "domain/status disagree");
        }

        // The predicate still fires for a route that does reach past every assigned address.
        let mut router = n.clone();
        router.accepted_routes.push("192.0.2.0/24".parse().unwrap());
        assert!(
            StatusNode::from_node(&router).is_router(),
            "a real subnet route makes it a router"
        );
    }

    /// An IPv6-off tailnet assigns a node only its IPv4 prefix, and the domain model fills the
    /// missing family with an unspecified placeholder. `TailscaleIPs` must carry what control
    /// actually assigned — not the placeholder — and the node must still not read as a router.
    #[test]
    fn status_node_tailscale_ips_omits_the_unassigned_family_placeholder() {
        let only4: ipnet::IpNet = "100.64.0.1/32".parse().unwrap();

        let mut n = node("n1", "host", Some("ts.net"), "100.64.0.1");
        n.addresses = vec![only4];
        n.tailnet_address.ipv6 = "::/128".parse().unwrap();
        n.accepted_routes = vec![only4];

        let s = StatusNode::from_node(&n);
        assert_eq!(s.tailscale_ips, vec![only4.addr()]);
        assert!(!s.is_router(), "its own /32 is not a routed address");
        assert!(
            s.ipv6.is_unspecified(),
            "the unassigned family stays a placeholder on the identity projection"
        );
    }

    /// `from_node` carries NO live connectivity: a bare domain `Node` has no path state, so
    /// `cur_addr`/`relay` default to `None`. `Runtime::status` overwrites `cur_addr` by joining the
    /// direct manager's `best_addrs`; the self node and whois (which also use `from_node`) keep
    /// `None`. This pins the default so the enrichment seam stays the single source of connectivity.
    #[test]
    fn status_node_from_node_has_no_connectivity_by_default() {
        let n = node("n1", "host", Some("ts.net"), "100.64.0.7");
        let s = StatusNode::from_node(&n);
        assert_eq!(s.cur_addr, None, "a bare Node has no direct endpoint");
        assert_eq!(s.relay, None, "a bare Node has no resolved relay");
    }

    #[test]
    fn whois_caps_empty_when_node_has_none() {
        // A node with no cap_map surfaces empty capabilities (not fabricated), and no user unless a
        // profile was joined in.
        let n = node("n1", "host", Some("ts.net"), "100.64.0.9");
        let whois = WhoIs::from_node_with_profile(n.clone(), None);

        assert_eq!(whois.node, n);
        assert_eq!(whois.user_profile, None);
        assert_eq!(whois.user(), None);
        assert!(whois.user_groups().is_empty());
        assert!(whois.capabilities.is_empty());
    }

    #[test]
    fn whois_populates_capabilities_from_cap_map() {
        // WhoIs surfaces the domain Node's cap_map verbatim, sorted by capability name (BTreeMap).
        let mut n = node("n1", "host", Some("ts.net"), "100.64.0.9");
        n.cap_map
            .insert("https://tailscale.com/cap/is-admin".to_string(), vec![]);
        n.cap_map.insert(
            "cap/ssh".to_string(),
            vec!["root".to_string(), "ubuntu".to_string()],
        );
        let whois = WhoIs::from_node_with_profile(n, None);

        // BTreeMap iteration is sorted: "cap/ssh" < "https://…".
        assert_eq!(
            whois.capabilities,
            vec![
                (
                    "cap/ssh".to_string(),
                    vec!["root".to_string(), "ubuntu".to_string()]
                ),
                ("https://tailscale.com/cap/is-admin".to_string(), vec![]),
            ]
        );
    }

    #[test]
    fn whois_from_node_with_profile_sets_profile_and_caps() {
        let mut n = node("n1", "host", Some("ts.net"), "100.64.0.9");
        n.cap_map.insert("cap/x".to_string(), vec!["y".to_string()]);
        let profile = UserProfile {
            id: 42,
            login_name: "alice@example.com".to_string(),
            display_name: Some("Alice Smith".to_string()),
            groups: vec!["group:eng".to_string(), "sre@example.com".to_string()],
        };
        let whois = WhoIs::from_node_with_profile(n, Some(profile.clone()));

        assert_eq!(whois.user_profile, Some(profile));
        // The flattened label the pre-widening `user` field carried is still what `user()` answers.
        assert_eq!(whois.user(), Some("alice@example.com".to_string()));
        assert_eq!(whois.user_groups(), ["group:eng", "sre@example.com"]);
        assert_eq!(
            whois.capabilities,
            vec![("cap/x".to_string(), vec!["y".to_string()])]
        );
    }

    /// A profile control sent with no `Groups` still resolves — the profile is present, the group
    /// list is merely empty. The absent case must never collapse to "no profile", because an
    /// embedder distinguishes "control named this owner but reported no groups" (deny, with a
    /// known owner) from "control named no owner at all".
    #[test]
    fn whois_with_a_groupless_profile_keeps_the_profile_and_reports_no_groups() {
        let n = node("n1", "host", Some("ts.net"), "100.64.0.9");
        let whois = WhoIs::from_node_with_profile(
            n,
            Some(UserProfile {
                id: 42,
                login_name: "alice@example.com".to_string(),
                display_name: None,
                groups: Vec::new(),
            }),
        );

        assert!(whois.user_profile.is_some(), "the profile itself survives");
        assert_eq!(whois.user(), Some("alice@example.com".to_string()));
        assert!(whois.user_groups().is_empty());
    }

    /// Build a peer with a reachable peerAPI on `ipv4`, owned by `user`.
    fn peer_with_peerapi(stable: &str, hostname: &str, ipv4: &str, user: UserId) -> Node {
        let mut n = node(stable, hostname, Some("ts.net"), ipv4);
        n.user_id = user;
        n.peerapi_port = Some(8089);
        n
    }

    #[test]
    fn file_targets_includes_same_owner_peer_with_peerapi() {
        let peer = peer_with_peerapi("p1", "host", "100.64.0.5", 42);
        let targets = build_file_targets(vec![peer], 42);

        assert_eq!(targets.len(), 1);
        assert_eq!(targets[0].peerapi_url, "http://100.64.0.5:8089");
        assert_eq!(targets[0].node.hostname, "host");
    }

    #[test]
    fn file_targets_includes_cross_owner_peer_with_target_cap() {
        // Different owner, but carries the file-sharing-target cap → still a target (Go's OR).
        let mut peer = peer_with_peerapi("p1", "host", "100.64.0.5", 99);
        peer.cap_map
            .insert("tailscale.com/cap/file-sharing-target".to_string(), vec![]);
        let targets = build_file_targets(vec![peer], 42);

        assert_eq!(
            targets.len(),
            1,
            "cross-owner peer with the target cap qualifies"
        );
    }

    #[test]
    fn file_targets_excludes_cross_owner_peer_without_cap() {
        // Different owner and no target cap → excluded.
        let peer = peer_with_peerapi("p1", "host", "100.64.0.5", 99);
        let targets = build_file_targets(vec![peer], 42);

        assert!(
            targets.is_empty(),
            "a different owner without the cap is not a target"
        );
    }

    #[test]
    fn file_targets_excludes_peer_without_peerapi() {
        // Same owner, but advertises no peerAPI (no port) → excluded (Go `PeerAPIBase(p) == ""`).
        let mut peer = peer_with_peerapi("p1", "host", "100.64.0.5", 42);
        peer.peerapi_port = None;
        let targets = build_file_targets(vec![peer], 42);

        assert!(
            targets.is_empty(),
            "a peer with no peerAPI cannot be a Taildrop target"
        );
    }

    #[test]
    fn file_targets_sorted_by_magic_dns_name() {
        // Insert out of order; expect sorted by fqdn ("alpha.ts.net" < "zeta.ts.net").
        let zeta = peer_with_peerapi("p2", "zeta", "100.64.0.6", 42);
        let alpha = peer_with_peerapi("p1", "alpha", "100.64.0.5", 42);
        let targets = build_file_targets(vec![zeta, alpha], 42);

        let names: Vec<_> = targets.iter().map(|t| t.node.hostname.clone()).collect();
        assert_eq!(names, vec!["alpha", "zeta"]);
    }

    fn region_result(id: u32, latency_ms: u64) -> ts_netcheck::RegionResult {
        ts_netcheck::RegionResult {
            latency: std::time::Duration::from_millis(latency_ms),
            id: ts_derp::RegionId(std::num::NonZeroU32::new(id).unwrap()),
            latency_map_key: format!("{id}-v4"),
            connected_remote: "1.2.3.4:443".parse().unwrap(),
        }
    }

    #[test]
    fn netcheck_report_preferred_is_first_region() {
        // The measurer hands results sorted by latency ascending, so the first is the preferred
        // (home) region and every region is surfaced.
        let results = [
            region_result(5, 12),
            region_result(9, 40),
            region_result(2, 88),
        ];
        let report = NetcheckReport::from_region_results(&results);
        assert_eq!(
            report.preferred_derp,
            Some(5),
            "lowest-latency region is preferred"
        );
        assert_eq!(report.region_latencies.len(), 3);
        assert_eq!(report.region_latencies[0].region_id, 5);
        assert_eq!(
            report.region_latencies[0].latency,
            std::time::Duration::from_millis(12)
        );
        // Order is preserved as given (latency-ascending from the measurer).
        let ids: Vec<u32> = report
            .region_latencies
            .iter()
            .map(|r| r.region_id)
            .collect();
        assert_eq!(ids, vec![5, 9, 2]);
    }

    #[test]
    fn netcheck_report_empty_when_no_measurements() {
        // Before any measurement (or when none was reachable): no preferred region, empty list — not
        // a fabricated value.
        let report = NetcheckReport::from_region_results(&[]);
        assert_eq!(report, NetcheckReport::default());
        assert_eq!(report.preferred_derp, None);
        assert!(report.region_latencies.is_empty());
    }
}