PromucFlow_constructor/app/client/packages/rts/src/sockets/events.ts

import type { Server, Socket } from "socket.io";
import log from "loglevel";
import {
  APP_ROOM_PREFIX,
  RELEASE_VERSION_EVENT_NAME,
  LEAVE_EDIT_EVENT_NAME,
  PAGE_EDIT_NAMESPACE,
  PAGE_ROOM_PREFIX,
  ROOT_NAMESPACE,
  PAGE_VISIBILITY_EVENT_NAME,
} from "@constants/socket";
import { VERSION as buildVersion } from "../version";
import {
  subscribeToEditEvents,
  onAppSocketConnected,
  onPageSocketConnected,
  sendCurrentUsers,
} from "@controllers/socket";

export function watchEvents(io: Server) {
  io.on("connection", (socket: Socket) => {
    socket.emit(RELEASE_VERSION_EVENT_NAME, buildVersion);
    subscribeToEditEvents(socket, APP_ROOM_PREFIX);
    onAppSocketConnected(socket).catch((error) =>
      log.error("Error in socket connected handler", error),
    );
  });
  /** When we get the page visibility event, it means the page/tab
   * is visible on the client after navigating away from it.
   * We will respond back with the current version to
   * so that the client can confirm if they are
   * on the latest version of the client
   */
  io.on(PAGE_VISIBILITY_EVENT_NAME, (socket: Socket) => {
    socket.emit(RELEASE_VERSION_EVENT_NAME, buildVersion);
  });

  io.of(PAGE_EDIT_NAMESPACE).on("connection", (socket: Socket) => {
    subscribeToEditEvents(socket, PAGE_ROOM_PREFIX);
    onPageSocketConnected(socket, io).catch((error) =>
      log.error("Error in socket connected handler", error),
    );
  });

  io.of(ROOT_NAMESPACE).adapter.on("leave-room", (room, id) => {
    if (room.startsWith(APP_ROOM_PREFIX)) {
      log.debug(`ns:${ROOT_NAMESPACE}# socket ${id} left the room ${room}`);
    }

    sendCurrentUsers(io, room, APP_ROOM_PREFIX);
  });

  io.of(ROOT_NAMESPACE).adapter.on("join-room", (room, id) => {
    if (room.startsWith(APP_ROOM_PREFIX)) {
      log.debug(`ns:${ROOT_NAMESPACE}# socket ${id} joined the room ${room}`);
    }

    sendCurrentUsers(io, room, APP_ROOM_PREFIX);
  });

  io.of(PAGE_EDIT_NAMESPACE).adapter.on("leave-room", (room, id) => {
    if (room.startsWith(PAGE_ROOM_PREFIX)) {
      // someone left the page edit, notify others
      log.debug(
        `ns:${PAGE_EDIT_NAMESPACE} # socket ${id} left the room ${room}`,
      );
      io.of(PAGE_EDIT_NAMESPACE).to(room).emit(LEAVE_EDIT_EVENT_NAME, id);
    }

    sendCurrentUsers(io.of(PAGE_EDIT_NAMESPACE), room, PAGE_ROOM_PREFIX);
  });

  io.of(PAGE_EDIT_NAMESPACE).adapter.on("join-room", (room, id) => {
    if (room.startsWith(PAGE_ROOM_PREFIX)) {
      log.debug(
        `ns:${PAGE_EDIT_NAMESPACE}# socket ${id} joined the room ${room}`,
      );
    }

    sendCurrentUsers(io.of(PAGE_EDIT_NAMESPACE), room, PAGE_ROOM_PREFIX);
  });
}