homeio

1import "server-only";
2
3import { logServerAction } from "@/lib/server/logging/logger";
4import type { ServerHardwareInfo } from "@/lib/shared/contracts/server-info";
5import os from "node:os";
6import si from "systeminformation";
7
8const CACHE_TTL_MS = 5 * 60 * 1_000;
9
10let cache: { value: ServerHardwareInfo; expiresAt: number } | null = null;
11
12function toStr(value: unknown): string | null {
13  if (typeof value !== "string") return null;
14  const s = value.trim();
15  return s.length > 0 && s !== "Default string" && s !== "To Be Filled By O.A.M.E." ? s : null;
16}
17
18function toNum(value: unknown): number | null {
19  if (typeof value !== "number" || !Number.isFinite(value) || value <= 0) return null;
20  return value;
21}
22
23async function probe<T>(action: string, fn: () => Promise<T>, fallback: T): Promise<T> {
24  try {
25    return await fn();
26  } catch (error) {
27    logServerAction({ level: "warn", layer: "service", action, status: "error", error, message: "probe failed" });
28    return fallback;
29  }
30}
31
32async function collect(): Promise<ServerHardwareInfo> {
33  const [cpuData, graphics, memLayout, osInfo, systemInfo, biosInfo, baseboardInfo, batteryData, networkIfaces] =
34    await Promise.all([
35      probe("server-info.cpu", () => si.cpu(), null),
36      probe("server-info.graphics", () => si.graphics(), { controllers: [], displays: [] }),
37      probe("server-info.memLayout", () => si.memLayout(), []),
38      probe("server-info.osInfo", () => si.osInfo(), null),
39      probe("server-info.system", () => si.system(), null),
40      probe("server-info.bios", () => si.bios(), null),
41      probe("server-info.baseboard", () => si.baseboard(), null),
42      probe("server-info.battery", () => si.battery(), null),
43      probe("server-info.networkInterfaces", () => si.networkInterfaces(), []),
44    ]);
45
46  return {
47    fetchedAt: new Date().toISOString(),
48    os: {
49      platform: toStr(osInfo?.platform) ?? os.platform(),
50      distro: toStr(osInfo?.distro),
51      release: toStr(osInfo?.release),
52      kernel: toStr(osInfo?.kernel),
53      arch: toStr(osInfo?.arch) ?? os.arch(),
54      codename: toStr(osInfo?.codename),
55      hostname: os.hostname(),
56    },
57    system: {
58      manufacturer: toStr(systemInfo?.manufacturer),
59      model: toStr(systemInfo?.model),
60      version: toStr(systemInfo?.version),
61      serial: toStr(systemInfo?.serial),
62      uuid: toStr(systemInfo?.uuid),
63      sku: toStr(systemInfo?.sku),
64    },
65    bios: {
66      vendor: toStr(biosInfo?.vendor),
67      version: toStr(biosInfo?.version),
68      releaseDate: toStr(biosInfo?.releaseDate),
69      revision: toStr(biosInfo?.revision),
70    },
71    baseboard: {
72      manufacturer: toStr(baseboardInfo?.manufacturer),
73      model: toStr(baseboardInfo?.model),
74      version: toStr(baseboardInfo?.version),
75    },
76    cpu: {
77      manufacturer: toStr(cpuData?.manufacturer),
78      brand: toStr(cpuData?.brand),
79      speedGhz: toNum(cpuData?.speed),
80      maxSpeedGhz: toNum(cpuData?.speedMax),
81      cores: typeof cpuData?.cores === "number" && cpuData.cores > 0 ? cpuData.cores : os.cpus().length,
82      physicalCores: typeof cpuData?.physicalCores === "number" && cpuData.physicalCores > 0 ? cpuData.physicalCores : null,
83      processors: typeof cpuData?.processors === "number" && cpuData.processors > 0 ? cpuData.processors : null,
84      socket: toStr(cpuData?.socket),
85      governor: toStr(cpuData?.governor),
86    },
87    memory: {
88      totalBytes: os.totalmem(),
89      slots: memLayout.map((slot) => ({
90        bank: toStr(slot.bank),
91        type: toStr(slot.type),
92        formFactor: toStr(slot.formFactor),
93        sizeBytes: typeof slot.size === "number" && slot.size > 0 ? slot.size : null,
94        clockSpeedMhz: typeof slot.clockSpeed === "number" && slot.clockSpeed > 0 ? slot.clockSpeed : null,
95        manufacturer: toStr(slot.manufacturer),
96      })),
97    },
98    gpu: {
99      controllers: graphics.controllers.map((ctrl) => ({
100        vendor: toStr(ctrl.vendor),
101        model: toStr(ctrl.model),
102        bus: toStr(ctrl.bus),
103        vramBytes: typeof ctrl.vram === "number" && ctrl.vram > 0 ? ctrl.vram * 1_048_576 : null,
104        subVendor: toStr(ctrl.subVendor),
105      })),
106    },
107    battery: {
108      hasBattery: Boolean(batteryData?.hasBattery),
109      manufacturer: batteryData?.hasBattery ? toStr(batteryData?.manufacturer) : null,
110      maxCapacityWh: batteryData?.hasBattery && typeof batteryData.maxCapacity === "number" && batteryData.maxCapacity > 0
111        ? Number(batteryData.maxCapacity.toFixed(1)) : null,
112      designedCapacityWh: batteryData?.hasBattery && typeof batteryData.designedCapacity === "number" && batteryData.designedCapacity > 0
113        ? Number(batteryData.designedCapacity.toFixed(1)) : null,
114      cycleCount: batteryData?.hasBattery && typeof batteryData.cycleCount === "number" && batteryData.cycleCount >= 0
115        ? Math.round(batteryData.cycleCount) : null,
116    },
117    network: {
118      interfaces: (Array.isArray(networkIfaces) ? networkIfaces : [])
119        .filter((iface) => !iface.internal && !iface.virtual && iface.iface)
120        .map((iface) => ({
121          iface: iface.iface,
122          type: toStr(iface.type),
123          operstate: iface.operstate === "up" || iface.operstate === "down" ? iface.operstate : null,
124          ip4: toStr(iface.ip4),
125          ip4subnet: toStr(iface.ip4subnet),
126          ip6: toStr(iface.ip6),
127          mac: toStr(iface.mac),
128          speedMbps: typeof iface.speed === "number" && iface.speed > 0 ? iface.speed : null,
129          duplex: toStr(iface.duplex),
130          dhcp: Boolean(iface.dhcp),
131          isDefault: Boolean(iface.default),
132        })),
133    },
134  };
135}
136
137export async function getServerHardwareInfo(): Promise<ServerHardwareInfo> {
138  if (cache && cache.expiresAt > Date.now()) return cache.value;
139
140  const value = await collect();
141  cache = { value, expiresAt: Date.now() + CACHE_TTL_MS };
142  return value;
143}
144