homeio

1import { describe, expect, it, vi } from "vitest";
2
3vi.mock("@/lib/server/modules/system/service", () => ({
4  getSystemMetricsSnapshot: vi.fn(),
5}));
6
7import {
8  HISTORY_SAMPLE_MS,
9  createMetricsHistory,
10  toHistoryPoint,
11} from "@/lib/server/modules/system/metrics-history";
12import type { MetricsHistoryPoint, SystemMetricsSnapshot } from "@/lib/shared/contracts/system";
13
14const MINUTE = 60_000;
15const START = Date.UTC(2026, 8, 27, 10, 0, 0);
16
17function point(t: number, cpu: number | null, temperature: number | null = null): MetricsHistoryPoint {
18  return {
19    t,
20    cpuPercent: cpu,
21    memoryPercent: 50,
22    temperatureCelsius: temperature,
23    downloadMbps: 1,
24    uploadMbps: 0.5,
25    diskReadMBps: 2,
26    diskWriteMBps: 1,
27  };
28}
29
30describe("metrics history", () => {
31  it("keeps one hour of 5 s samples and drops older ones", () => {
32    const history = createMetricsHistory();
33    const samples = (2 * 60 * 60 * 1000) / HISTORY_SAMPLE_MS;
34    for (let i = 0; i < samples; i += 1) history.record(point(START + i * HISTORY_SAMPLE_MS, i % 100));
35
36    const now = START + (samples - 1) * HISTORY_SAMPLE_MS;
37    const hour = history.get("1h", now);
38
39    expect(hour.intervalSeconds).toBe(5);
40    expect(hour.points).toHaveLength(720);
41    expect(hour.points[0].t).toBeGreaterThan(now - 60 * MINUTE);
42    expect(hour.points.at(-1)?.t).toBe(now);
43  });
44
45  it("serves the last 15 minutes of the hour at the same 5 s resolution", () => {
46    const history = createMetricsHistory();
47    for (let i = 0; i < 720; i += 1) history.record(point(START + i * HISTORY_SAMPLE_MS, 1));
48
49    const now = START + 719 * HISTORY_SAMPLE_MS;
50    const quarter = history.get("15m", now);
51
52    expect(quarter.intervalSeconds).toBe(5);
53    expect(quarter.points).toHaveLength(180);
54    expect(quarter.points[0].t).toBeGreaterThan(now - 15 * MINUTE);
55  });
56
57  it("averages each minute for the 24 h view and includes the minute in progress", () => {
58    const history = createMetricsHistory();
59    // First minute: 10, 20, 30. Second minute (in progress): 70.
60    history.record(point(START, 10));
61    history.record(point(START + 5_000, 20));
62    history.record(point(START + 10_000, 30));
63    history.record(point(START + MINUTE, 70));
64
65    const day = history.get("24h", START + MINUTE + 1_000);
66
67    expect(day.intervalSeconds).toBe(60);
68    expect(day.points.map((p) => [p.t, p.cpuPercent])).toEqual([
69      [START, 20],
70      [START + MINUTE, 70],
71    ]);
72  });
73
74  it("averages only the readings a host has, and keeps null when it has none", () => {
75    const history = createMetricsHistory();
76    history.record(point(START, null, 40));
77    history.record(point(START + 5_000, 30, null));
78    history.record(point(START + 10_000, 60, 50));
79
80    const [minute] = history.get("24h", START + 20_000).points;
81
82    expect(minute.cpuPercent).toBe(45);
83    expect(minute.temperatureCelsius).toBe(45);
84
85    const noSensor = createMetricsHistory();
86    noSensor.record(point(START, 10, null));
87    expect(noSensor.get("24h", START + 1_000).points[0].temperatureCelsius).toBeNull();
88  });
89
90  it("forgets minutes older than 24 hours", () => {
91    const history = createMetricsHistory();
92    for (let minute = 0; minute < 25 * 60; minute += 1) history.record(point(START + minute * MINUTE, 1));
93
94    const now = START + (25 * 60 - 1) * MINUTE;
95    const points = history.get("24h", now).points;
96
97    expect(points.length).toBeLessThanOrEqual(24 * 60);
98    expect(points[0].t).toBeGreaterThan(now - 24 * 60 * MINUTE);
99  });
100
101  it("maps a metrics snapshot and turns missing or invalid readings into null", () => {
102    const snapshot = {
103      cpu: { normalizedPercent: 12.5 },
104      memory: { usedPercent: 40 },
105      temperature: { mainCelsius: null },
106      wifi: { downloadMbps: Number.NaN, uploadMbps: 2 },
107      diskIo: { readMBps: 12, writeMBps: null },
108    } as unknown as SystemMetricsSnapshot;
109
110    expect(toHistoryPoint(snapshot, START)).toEqual({
111      t: START,
112      cpuPercent: 12.5,
113      memoryPercent: 40,
114      temperatureCelsius: null,
115      downloadMbps: null,
116      uploadMbps: 2,
117      diskReadMBps: 12,
118      diskWriteMBps: null,
119    });
120  });
121});
122