homeio

1import "server-only";
2
3import type { NotificationRecord, NotificationSseEvent } from "@/lib/shared/contracts/notifications";
4
5type NotificationSubscriber = (event: NotificationSseEvent) => void;
6
7const subscribers = new Set<NotificationSubscriber>();
8
9export function subscribeToNotifications(callback: NotificationSubscriber): () => void {
10  subscribers.add(callback);
11  return () => {
12    subscribers.delete(callback);
13  };
14}
15
16export function emitNotification(notification: NotificationRecord) {
17  const event: NotificationSseEvent = { type: "notification.created", notification };
18  for (const subscriber of subscribers) {
19    subscriber(event);
20  }
21}
22
23export function emitNotificationReadAll() {
24  const event: NotificationSseEvent = { type: "notification.read-all" };
25  for (const subscriber of subscribers) {
26    subscriber(event);
27  }
28}
29
30export function emitNotificationCleared() {
31  const event: NotificationSseEvent = { type: "notification.cleared" };
32  for (const subscriber of subscribers) {
33    subscriber(event);
34  }
35}
36