homeio

1"use client";
2
3import { useMemo } from "react";
4import { useCurrentUser } from "@/hooks/useCurrentUser";
5import { useDesktopPreferences } from "@/hooks/useDesktopPreferences";
6import { useInstalledApps } from "@/modules/apps/hooks/useInstalledApps";
7import { useNetworkStatus } from "@/modules/system/hooks/useNetworkStatus";
8import { useSystemUpdateStatus } from "@/modules/system/hooks/useSystemUpdateStatus";
9import { useSystemMetrics } from "@/modules/system/hooks/useSystemMetrics";
10import { formatRelativeTime, safePercent } from "@/modules/system/components/status-bar/utils";
11import { useStatusNotifications } from "@/modules/system/components/status-bar/use-status-notifications";
12import { useNotifications } from "@/modules/system/hooks/useNotifications";
13import type { Notification } from "@/modules/system/components/status-bar/types";
14import type { NotificationRecord } from "@/lib/shared/contracts/notifications";
15
16const MAX_MERGED_NOTIFICATIONS = 20;
17
18/**
19 * Persisted notifications and the client-side status ones are each ordered on
20 * their own. Concatenating them produced two sorted runs end to end — app
21 * events from yesterday sitting above a snapshot from minutes ago — so the
22 * join has to be ordered too, not just the parts.
23 */
24export function mergeNotifications(
25  persistent: NotificationRecord[],
26  ephemeral: Notification[],
27): Notification[] {
28  const persistentIds = new Set(persistent.map((item) => item.id));
29  const persistentMapped = persistent.map((item) => ({
30    id: item.id,
31    title: item.title,
32    message: item.body,
33    time: formatRelativeTime(item.createdAt),
34    createdAt: item.createdAt,
35    read: item.read,
36  }));
37
38  return [...persistentMapped, ...ephemeral.filter((item) => !persistentIds.has(item.id))]
39    .sort((left, right) => Date.parse(right.createdAt) - Date.parse(left.createdAt))
40    .slice(0, MAX_MERGED_NOTIFICATIONS);
41}
42
43export function useStatusBarData() {
44  const { data: metrics, isError: isMetricsError } = useSystemMetrics();
45  const { data: networkStatus, isError: isNetworkError } = useNetworkStatus();
46  const { data: apps } = useInstalledApps();
47  const { data: currentUser } = useCurrentUser();
48  const { notificationPreferences } = useDesktopPreferences();
49  const { data: systemUpdates } = useSystemUpdateStatus();
50
51  const serverName = metrics?.hostname ?? "ServerLab";
52  const cpuPercent = safePercent(metrics?.cpu.normalizedPercent);
53  const memoryPercent = safePercent(metrics?.memory.usedPercent);
54  const diskPercent = safePercent(metrics?.storage?.usedPercent);
55  const stoppedAppsCount = (apps ?? []).filter(
56    (app) => app.status === "stopped" || app.status === "paused",
57  ).length;
58
59  const batteryPercent =
60    typeof metrics?.battery.percent === "number"
61      ? safePercent(metrics.battery.percent)
62      : null;
63  const batteryText = metrics?.battery.hasBattery ? `${batteryPercent ?? "--"}%` : "AC";
64
65  const isWifiConnected = Boolean(
66    networkStatus?.connected ?? metrics?.wifi.connected,
67  );
68  const isEthernet = Boolean(
69    (networkStatus?.connected ?? metrics?.wifi.connected) &&
70      !(networkStatus?.ssid ?? metrics?.wifi.ssid),
71  );
72  const showWifiError = (isMetricsError && isNetworkError) || !isWifiConnected;
73  const wifiIconClassName = showWifiError
74    ? "size-4 text-status-red"
75    : "size-4 text-status-green";
76
77  const { notifications: persistentNotifications, unreadCount: persistentUnreadCount, markAllRead: markPersistentAllRead, clearAll: clearPersistentAll } = useNotifications();
78
79  const { notifications: ephemeralNotifications, unreadCount: ephemeralUnreadCount, markAllRead: markEphemeralAllRead, clearAll: clearEphemeralAll } = useStatusNotifications({
80    metricsTimestamp: metrics?.timestamp ?? null,
81    cpuPercent,
82    memoryPercent,
83    diskPercent,
84    temperatureCelsius:
85      typeof metrics?.temperature.mainCelsius === "number"
86        ? metrics.temperature.mainCelsius
87        : null,
88    hostname: metrics?.hostname ?? "ServerLab",
89    uptimeSeconds: metrics?.uptimeSeconds ?? 0,
90    stoppedAppsCount,
91    username: currentUser?.username,
92    updateAvailable: Boolean(systemUpdates?.updateAvailable),
93    latestVersion: systemUpdates?.latestVersion ?? null,
94    preferences: notificationPreferences,
95  });
96
97  const mergedNotifications = useMemo(
98    () => mergeNotifications(persistentNotifications, ephemeralNotifications),
99    [persistentNotifications, ephemeralNotifications],
100  );
101
102  const mergedUnreadCount = persistentUnreadCount + ephemeralUnreadCount;
103
104  function markAllRead() {
105    markPersistentAllRead();
106    markEphemeralAllRead();
107  }
108
109  function clearAll() {
110    clearPersistentAll();
111    clearEphemeralAll();
112  }
113
114  return useMemo(
115    () => ({
116      metrics,
117      networkStatus,
118      serverName,
119      isDemoMode: currentUser?.isDemoMode ?? false,
120      username: currentUser?.isDemoMode ? "homeio" : (currentUser?.username ?? null),
121      batteryText,
122      isWifiConnected,
123      isEthernet,
124      isMetricsError,
125      wifiIconClassName,
126      notifications: mergedNotifications,
127      unreadCount: mergedUnreadCount,
128      markAllRead,
129      clearNotifications: clearAll,
130    }),
131    // eslint-disable-next-line react-hooks/exhaustive-deps
132    [
133      batteryText,
134      isMetricsError,
135      networkStatus,
136      isWifiConnected,
137      isEthernet,
138      metrics,
139      mergedNotifications,
140      mergedUnreadCount,
141      serverName,
142      currentUser?.username,
143      currentUser?.isDemoMode,
144      wifiIconClassName,
145    ],
146  );
147}
148