homeio

1import "server-only";
2
3import type {
4  SystemPowerAction,
5  SystemPowerActionEvent,
6} from "@/lib/shared/contracts/system";
7
8type PowerActionSubscriber = (event: SystemPowerActionEvent) => void;
9
10declare global {
11  var __homeioPowerActionSubscribers: Set<PowerActionSubscriber> | undefined;
12}
13
14// The routes that start an action and the stream route can each get their own
15// copy of this module, so the subscribers live on globalThis.
16const subscribers = (globalThis.__homeioPowerActionSubscribers ??= new Set());
17
18export function subscribeToPowerActions(callback: PowerActionSubscriber): () => void {
19  subscribers.add(callback);
20  return () => {
21    subscribers.delete(callback);
22  };
23}
24
25// Called once the action is scheduled. Every script waits a couple of seconds
26// before it stops Homeio, which leaves time for this to reach open streams.
27export function emitPowerAction(action: SystemPowerAction) {
28  const event: SystemPowerActionEvent = { action, startedAt: new Date().toISOString() };
29  for (const subscriber of subscribers) {
30    subscriber(event);
31  }
32}
33