homeio

1import "server-only";
2
3import { readFile } from "node:fs/promises";
4import si from "systeminformation";
5import { isContainerRuntime } from "@/lib/server/modules/system/update-service";
6import type {
7  NetworkInterfaceKind,
8  NetworkInterfaceOverview,
9  NetworkOverview,
10} from "@/lib/shared/contracts/network";
11
12const CACHE_MS = 2_000;
13
14// Docker, bridges and VM plumbing: one per container, and none of them is a
15// way in or out of the machine.
16const PLUMBING_INTERFACE = /^(veth|br-|docker|virbr|vnet|lxc|cni|flannel)/;
17const VPN_INTERFACE = /^(tailscale|wg|tun|tap|utun|zt)/;
18
19// systemd-resolved lists the upstream servers here; /etc/resolv.conf then
20// only says 127.0.0.53.
21const RESOLV_CONF_PATHS = ["/run/systemd/resolve/resolv.conf", "/etc/resolv.conf"];
22
23function textOrNull(value: unknown) {
24  return typeof value === "string" && value.trim().length > 0 ? value.trim() : null;
25}
26
27function countOrNull(value: unknown) {
28  return typeof value === "number" && Number.isFinite(value) && value >= 0 ? value : null;
29}
30
31function bytesPerSecondToMbps(value: unknown) {
32  const perSecond = countOrNull(value);
33  return perSecond === null ? null : (perSecond * 8) / 1_000_000;
34}
35
36function kindOf(name: string, type: unknown): NetworkInterfaceKind {
37  if (VPN_INTERFACE.test(name)) return "vpn";
38  if (type === "wireless") return "wireless";
39  if (type === "wired") return "wired";
40  return "other";
41}
42
43export function parseNameservers(resolvConf: string) {
44  const servers: string[] = [];
45  for (const line of resolvConf.split("\n")) {
46    const match = /^\s*nameserver\s+(\S+)/.exec(line);
47    if (match && !servers.includes(match[1])) servers.push(match[1]);
48  }
49  return servers;
50}
51
52async function readDnsServers() {
53  for (const filePath of RESOLV_CONF_PATHS) {
54    try {
55      const servers = parseNameservers(await readFile(filePath, "utf8"));
56      if (servers.length > 0) return servers;
57    } catch {
58      // Not on this host; try the next file.
59    }
60  }
61  return [];
62}
63
64async function collect(): Promise<NetworkOverview> {
65  const [interfaces, stats, gateway, dnsServers] = await Promise.all([
66    si.networkInterfaces().catch(() => []),
67    si.networkStats("*").catch(() => []),
68    si.networkGatewayDefault().catch(() => ""),
69    readDnsServers(),
70  ]);
71
72  const statsByName = new Map(
73    (Array.isArray(stats) ? stats : []).map((entry) => [entry.iface, entry]),
74  );
75
76  const list: NetworkInterfaceOverview[] = (Array.isArray(interfaces) ? interfaces : [interfaces])
77    .filter((iface) => iface.iface && !iface.internal && !PLUMBING_INTERFACE.test(iface.iface))
78    .map((iface) => {
79      const traffic = statsByName.get(iface.iface);
80      return {
81        iface: iface.iface,
82        kind: kindOf(iface.iface, iface.type),
83        up: iface.operstate === "up" ? true : iface.operstate === "down" ? false : null,
84        isDefault: Boolean(iface.default),
85        ip4: textOrNull(iface.ip4),
86        ip4Subnet: textOrNull(iface.ip4subnet),
87        ip6: textOrNull(iface.ip6),
88        mac: textOrNull(iface.mac),
89        speedMbps: typeof iface.speed === "number" && iface.speed > 0 ? iface.speed : null,
90        duplex: textOrNull(iface.duplex),
91        dhcp: Boolean(iface.dhcp),
92        rxBytes: countOrNull(traffic?.rx_bytes),
93        txBytes: countOrNull(traffic?.tx_bytes),
94        downloadMbps: bytesPerSecondToMbps(traffic?.rx_sec),
95        uploadMbps: bytesPerSecondToMbps(traffic?.tx_sec),
96        rxErrors: countOrNull(traffic?.rx_errors),
97        txErrors: countOrNull(traffic?.tx_errors),
98        rxDropped: countOrNull(traffic?.rx_dropped),
99        txDropped: countOrNull(traffic?.tx_dropped),
100      };
101    })
102    // Default first, then interfaces that are up, then by name.
103    .sort(
104      (a, b) =>
105        Number(b.isDefault) - Number(a.isDefault) ||
106        Number(b.up === true) - Number(a.up === true) ||
107        a.iface.localeCompare(b.iface),
108    );
109
110  return {
111    inContainer: isContainerRuntime(),
112    interfaces: list,
113    gateway: textOrNull(gateway),
114    dnsServers,
115    checkedAt: new Date().toISOString(),
116  };
117}
118
119let cached: { value: NetworkOverview; expiresAt: number } | null = null;
120let inFlight: Promise<NetworkOverview> | null = null;
121
122/** Cached for 2 s so several open Monitors share one round of probes. */
123export async function getNetworkOverview(): Promise<NetworkOverview> {
124  if (cached && cached.expiresAt > Date.now()) return cached.value;
125  inFlight ??= collect().finally(() => {
126    inFlight = null;
127  });
128  const value = await inFlight;
129  cached = { value, expiresAt: Date.now() + CACHE_MS };
130  return value;
131}
132