homeio

1import "server-only";
2
3import type { UsbSseEvent } from "@/lib/shared/contracts/usb";
4
5type UsbSubscriber = (event: UsbSseEvent) => void;
6
7const subscribers = new Set<UsbSubscriber>();
8
9export function subscribeToUsbEvents(callback: UsbSubscriber): () => void {
10  subscribers.add(callback);
11  return () => subscribers.delete(callback);
12}
13
14export function emitUsbEvent(event: UsbSseEvent) {
15  for (const sub of subscribers) {
16    try {
17      sub(event);
18    } catch {
19      // ignore
20    }
21  }
22}
23