src/App/Doctrine/Listener/DownloadableContentListener.php line 81

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace App\Doctrine\Listener;
  5. use App\Contract\Content\DownloadableContent;
  6. use App\Entity\Deal;
  7. use App\Entity\Message\MessageReception;
  8. use App\Entity\Project;
  9. use App\Entity\ShopVideo;
  10. use App\RabbitMq\Handler\DownloadableContentHandler;
  11. use App\RabbitMq\TasksPool;
  12. use Doctrine\Common\Util\ClassUtils;
  13. use Doctrine\ORM\Event\PostLoadEventArgs;
  14. use Doctrine\ORM\Event\PostPersistEventArgs;
  15. use Doctrine\ORM\Event\PostUpdateEventArgs;
  16. use Symfony\Component\Console\ConsoleEvents;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\HttpKernel\KernelEvents;
  20. class DownloadableContentListener implements EventSubscriberInterface
  21. {
  23.     private TasksPool $tasksPool;
  25.     private bool $dirty = false;
  27.     public function __construct(TasksPool $tasksPool)
  28.     {
  29.         $this->tasksPool = $tasksPool;
  30.     }
  32.     /**
  33.      * @param Deal|Project|ShopVideo|MessageReception $content
  34.      */
  35.     public function postLoad(DownloadableContent $content, PostLoadEventArgs $args): void
  36.     {
  37.         $content->setWasAccessible($content->isContentAccessible());
  38.     }
  40.     /**
  41.      * @param Deal|Project|ShopVideo|MessageReception $content
  42.      */
  43.     public function postPersist(DownloadableContent $content, PostPersistEventArgs $args): void
  44.     {
  45.         $content->setWasAccessible($content->isContentAccessible());
  46.     }
  48.     /**
  49.      * @param Deal|Project|ShopVideo|MessageReception $content
  50.      */
  51.     public function postUpdate(DownloadableContent $content, PostUpdateEventArgs $args): void
  52.     {
  53.         // do not process new or unchanged content.
  54.         if (null === $content->getId() || $content->wasAccessible() === $content->isContentAccessible()) {
  55.             return;
  56.         }
  58.         $this->dirty = true;
  60.         if (!$content->isContentAccessible()) {
  61.             $this->tasksPool->addTask(
  62.                 DownloadableContentHandler::class,
  63.                 'handle',
  64.                 ClassUtils::getClass($content),
  65.                 $content->getId(),
  66.                 [DownloadableContentHandler::REMOVE]
  67.             );
  69.             return;
  70.         }
  72.         $this->tasksPool->addTask(
  73.             DownloadableContentHandler::class,
  74.             'handle',
  75.             ClassUtils::getClass($content),
  76.             $content->getId(),
  77.             [DownloadableContentHandler::ADD]
  78.         );
  79.     }
  81.     public function sendPool(): void
  82.     {
  83.         if (!$this->dirty) {
  84.             return;
  85.         }
  87.         $this->tasksPool->send();
  88.     }
  90.     /**
  91.      * @return array<string, array<int|string, array<int|string, int|string>|int|string>|string>
  92.      */
  93.     public static function getSubscribedEvents(): array
  94.     {
  95.         $events = [];
  97.         if (class_exists(KernelEvents::class)) {
  98.             $events[KernelEvents::TERMINATE] = 'sendPool';
  99.         }
  101.         if (class_exists(ConsoleEvents::class)) {
  102.             $events[ConsoleEvents::TERMINATE] = 'sendPool';
  103.         }
  105.         return $events;
  106.     }
  108. }