homeio

1import "server-only";
2
3import { logServerAction } from "@/lib/server/logging/logger";
4import {
5  subscribeToHelperEvents,
6  type NetworkHelperError,
7} from "@/lib/server/modules/network/helper-client";
8import type { NetworkEvent } from "@/lib/shared/contracts/network";
9
10type Subscriber = (event: NetworkEvent) => void;
11
12const subscribers = new Set<Subscriber>();
13let latestNetworkEvent: NetworkEvent | null = null;
14let unsubscribeHelper: (() => void) | null = null;
15let reconnectTimer: NodeJS.Timeout | null = null;
16let bridgeStarted = false;
17
18function emit(event: NetworkEvent) {
19  latestNetworkEvent = event;
20  for (const subscriber of subscribers) {
21    subscriber(event);
22  }
23}
24
25function scheduleReconnect() {
26  if (reconnectTimer) return;
27  reconnectTimer = setTimeout(() => {
28    reconnectTimer = null;
29    connectHelperStream();
30  }, 2_000);
31}
32
33function connectHelperStream() {
34  if (!bridgeStarted) return;
35  if (unsubscribeHelper) return;
36
37  unsubscribeHelper = subscribeToHelperEvents(
38    (event) => {
39      emit(event);
40    },
41    {
42      onError: (error) => {
43        unsubscribeHelper = null;
44
45        const helperError = error as NetworkHelperError | Error;
46        logServerAction({
47          level: "warn",
48          layer: "service",
49          action: "network.events.bridge",
50          status: "error",
51          message: "DBus helper event stream disconnected; retrying",
52          error: helperError,
53        });
54
55        if (subscribers.size > 0) {
56          scheduleReconnect();
57        }
58      },
59    },
60  );
61}
62
63function ensureBridgeStarted() {
64  if (bridgeStarted) return;
65  bridgeStarted = true;
66  connectHelperStream();
67}
68
69function stopBridge() {
70  if (reconnectTimer) {
71    clearTimeout(reconnectTimer);
72    reconnectTimer = null;
73  }
74
75  if (unsubscribeHelper) {
76    unsubscribeHelper();
77    unsubscribeHelper = null;
78  }
79
80  bridgeStarted = false;
81}
82
83export function getLatestNetworkEvent() {
84  return latestNetworkEvent;
85}
86
87export function subscribeToNetworkEvents(subscriber: Subscriber) {
88  subscribers.add(subscriber);
89  ensureBridgeStarted();
90
91  return () => {
92    subscribers.delete(subscriber);
93    if (subscribers.size === 0) {
94      stopBridge();
95    }
96  };
97}
98