Function wsVisitors

apps/api/src/controllers/live.controller.ts:20–54

(
  socket: WebSocket,
  req: FastifyRequest<{
    Params: {
      projectId: string;
    };
  }>
)

}

export function wsVisitors(
  socket: WebSocket,
  req: FastifyRequest<{
    Params: {
      projectId: string;
    };
  }>
) {
  guardSocket(socket, req);
  const { params } = req;
  const sendCount = () => {
    eventBuffer
      .getActiveVisitorCount(params.projectId)
      .then((count) => {
        socket.send(String(count));
      })
      .catch(() => {
        socket.send('0');
      });
  };

  const unsubscribe = subscribeToPublishedEvent(
    'events',
    'batch',
    ({ projectId }) => {
      if (projectId === params.projectId) {
        sendCount();
      }
    }
  );

  socket.on('close', () => {
    unsubscribe();
  });
}

export async function wsProjectEvents(
  socket: WebSocket,