src/App/RabbitMq/Handler/DownloadableContentHandler.php line 113

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace App\RabbitMq\Handler;
  5. use App\Contract\Content\DownloadableContent;
  6. use App\Contract\Content\DownloadableContentBid;
  7. use App\Entity\Deal;
  8. use App\Entity\DealBid;
  9. use App\Entity\Download;
  10. use App\Entity\Message\MessageBid;
  11. use App\Entity\Message\MessageReception;
  12. use App\Entity\Project;
  13. use App\Entity\ProjectBid;
  14. use App\Entity\ShopVideo;
  15. use App\Entity\ShopVideoBid;
  16. use App\RabbitMq\Processing\PopProcessingEvent;
  17. use App\RabbitMq\Processing\ProcessingEvent;
  18. use App\RabbitMq\Processing\PushProcessingEvent;
  19. use App\Repository\DownloadRepository;
  20. use App\Repository\Filter\DownloadableContentFilter;
  21. use Doctrine\Common\Collections\Collection;
  22. use Doctrine\Persistence\ManagerRegistry;
  23. use InvalidArgumentException;
  24. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  25. use Symfony\Component\Validator\Exception\UnexpectedTypeException;
  26. use Symfony\Component\Validator\Exception\UnexpectedValueException;
  28. class DownloadableContentHandler implements RabbitMqHandlerInterface, EventSubscriberInterface
  29. {
  31.     public const ADD = 'add';
  32.     public const REMOVE = 'remove';
  34.     private ManagerRegistry $doctrine;
  36.     private DownloadRepository $downloadRepository;
  38.     public function __construct(ManagerRegistry $doctrine, DownloadRepository $downloadRepository)
  39.     {
  40.         $this->doctrine = $doctrine;
  41.         $this->downloadRepository = $downloadRepository;
  42.     }
  44.     public function supports(string $service): bool
  45.     {
  46.         return $service === self::class;
  47.     }
  49.     /**
  50.      * @param mixed[] $task
  51.      */
  52.     public function handle(?object $entity, array $task): void
  53.     {
  54.         if (!is_array($task['arguments']) || 1 !== count($task['arguments'])) {
  55.             throw new InvalidArgumentException('Task should contain only one argument.');
  56.         }
  58.         if (!$entity instanceof DownloadableContent) {
  59.             throw new UnexpectedTypeException($entity, DownloadableContent::class);
  60.         }
  62.         if (!$entity instanceof Deal && !$entity instanceof Project && !$entity instanceof ShopVideo && !$entity instanceof MessageReception) {
  63.             throw new UnexpectedTypeException($entity, implode('|', [Deal::class, Project::class, ShopVideo::class, MessageReception::class]));
  64.         }
  66.         if (!is_string($task['arguments'][0])) {
  67.             return;
  68.         }
  70.         $action = $task['arguments'][0];
  72.         if (self::ADD !== $action && self::REMOVE !== $action) {
  73.             throw new UnexpectedValueException($action, '"add"|"remove"');
  74.         }
  76.         if ($action === self::REMOVE) {
  77.             if ($entity->isContentAccessible()) {
  78.                 return;
  79.             }
  81.             $downloads = $this->downloadRepository->filterResults([
  82.                 DownloadableContentFilter::FILTER => $entity,
  83.             ]);
  85.             foreach ($downloads as $download) {
  86.                 $this->doctrine->getManager()->remove($download);
  87.             }
  89.             return;
  90.         }
  92.         if (!$entity->isContentAccessible()) {
  93.             return;
  94.         }
  96.         /** @var Collection<int, DownloadableContentBid<DealBid|ProjectBid|ShopVideoBid|MessageBid>> $bids */
  97.         $bids = $entity->getBids();
  98.         foreach ($bids as $bid) {
  99.             if (!$bid->isStillAccessible()) {
  100.                 continue;
  101.             }
  103.             $download = new Download($bid->getUser(), $entity);
  104.             $this->doctrine->getManager()->persist($download);
  105.         }
  106.     }
  108.     public function onPushProcess(PushProcessingEvent $event): void
  109.     {
  110.         $this->onProcess($event);
  111.     }
  113.     public function onPopProcess(PopProcessingEvent $event): void
  114.     {
  115.         $this->onProcess($event);
  116.     }
  118.     private function onProcess(ProcessingEvent $event): void
  119.     {
  120.         if ($event->getService() !== self::class) {
  121.             return;
  122.         }
  124.         $entity = $event->getEntity();
  125.         if (!$entity instanceof DownloadableContent) {
  126.             return;
  127.         }
  129.         $event->stopPropagation();
  130.     }
  132.     /**
  133.      * @return array<string, array<int|string, array<int|string, int|string>|int|string>|string>
  134.      */
  135.     public static function getSubscribedEvents(): array
  136.     {
  137.         return [
  138.             PushProcessingEvent::class => ['onPushProcess', 1000],
  139.             PopProcessingEvent::class => ['onPopProcess', 1000],
  140.         ];
  141.     }
  143. }