Function wsProjectEvents

apps/api/src/controllers/live.controller.ts:56–99

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

}

export async function wsProjectEvents(
  socket: WebSocket,
  req: FastifyRequest<{
    Params: {
      projectId: string;
    };
    Querystring: {
      token?: string;
    };
  }>
) {
  guardSocket(socket, req);
  const { params } = req;

  const userId = req.session?.userId;
  if (!userId) {
    socket.send('No active session');
    socket.close();
    return;
  }

  const access = await getProjectAccess({
    userId,
    projectId: params.projectId,
  });

  if (!access) {
    socket.send('No access');
    socket.close();
    return;
  }

  const unsubscribe = subscribeToPublishedEvent(
    'events',
    'batch',
    ({ projectId, count }) => {
      if (projectId === params.projectId) {
        socket.send(setSuperJson({ count }));
      }
    }
  );

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

export async function wsProjectNotifications(
  socket: WebSocket,