Function wsOrganizationEvents

apps/api/src/controllers/live.controller.ts:143–181

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

}

export async function wsOrganizationEvents(
  socket: WebSocket,
  req: FastifyRequest<{
    Params: {
      organizationId: 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 getOrganizationAccess({
    userId,
    organizationId: params.organizationId,
  });

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

  const unsubscribe = subscribeToPublishedEvent(
    'organization',
    'subscription_updated',
    (message) => {
      socket.send(setSuperJson(message));
    }
  );

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