event emitter

em.js

import { EventEmitter } from "events";

class NotificationSystem extends EventEmitter {
  constructor() {
    this.#init()
  }

  #init() {
    this.on("follow", async (targetId, metadata) => {
        const notification = await Models.notification.create({
          type: "follow",
          targetId,
          metadata: {
            actorId: metadata.actorId,
          },
        });
        console.log(notification);
      });
  }

  notify(type, targetId, metadata) {
    if (!Models)
      throw new Error(
        "setupNotifications must be called before notifications can be used"
      );
    if (!targetId) throw new Error("Target is required");

    if (type === "follow") {
      console.log("Notification is follow");
      notificationEmitter.emit("follow", targetId, metadata);
    }
  }
}

const notifications = new NotificationSystem();

export const notify = notifications.notify;