src/EventSubscriber/SessionReactionSubscriber.php line 26

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\SessionReaction;
  6. use Doctrine\ORM\EntityManagerInterface;
  7. use App\Event\SessionReactionPreRemoveEvent;
  9. use App\Event\SessionReactionPostPersistEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class SessionReactionSubscriber implements EventSubscriberInterface
  13. {
  14.     public function __construct(
  15.         private EntityManagerInterface $_em,
  16.     ) {}
  18.     public static function getSubscribedEvents(): array
  19.     {
  20.         return [
  21.             SessionReactionPostPersistEvent::NAME => 'onPostCreate',
  22.             SessionReactionPreRemoveEvent::NAME => 'onPreRemove',
  23.         ];
  24.     }
  26.     public function onPostCreate(SessionReactionPostPersistEvent $event)
  27.     {
  28.         $this->calculateCount($event, 'add');
  29.     }
  31.     public function onPreRemove(SessionReactionPreRemoveEvent $event)
  32.     {
  33.         $this->calculateCount($event, 'remove');
  34.     }
  36.     private function calculateCount($event, $type)
  37.     {
  38.         $object = $event->getObject();
  39.         $session = $object->getSession();
  41.         $totalReactions = $this->_em->getRepository(SessionReaction::class)
  42.             ->getTotalReactions($session);
  43.         $session->setTotalReactions($type === 'remove' ? ($totalReactions-1) : $totalReactions);
  45.         $totalReactionsByType = $session->getTotalReactionsByType();
  46.         if (empty($totalReactionsByType)) {
  47.             $totalReactionsByType = [
  48.                 SessionReaction::TYPE_THUMBSUP => 0,
  49.                 SessionReaction::TYPE_CLAPS => 0,
  50.                 SessionReaction::TYPE_HEART => 0
  51.             ];
  52.         }
  54.         $totalReactionsByType[$object->getType()] += $type === 'remove' ? -1 : 1;
  55.         $session->setTotalReactionsByType($totalReactionsByType);
  56.         
  57.         $this->_em->persist($session);
  58.         $this->_em->flush();
  59.     }
  60. }