src/App/RabbitMq/Handler/DownloadableContentBidHandler.php line 107

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace App\RabbitMq\Handler;
  5. use App\Contract\Content\DownloadableContentBid;
  6. use App\Entity\Deal;
  7. use App\Entity\Download;
  8. use App\Entity\Message\MessageReception;
  9. use App\Entity\Project;
  10. use App\Entity\ShopVideo;
  11. use App\RabbitMq\Processing\PopProcessingEvent;
  12. use App\RabbitMq\Processing\ProcessingEvent;
  13. use App\RabbitMq\Processing\PushProcessingEvent;
  14. use App\Repository\DownloadRepository;
  15. use App\Repository\Filter\DownloadableContentFilter;
  16. use App\Repository\Filter\UserBids;
  17. use Doctrine\Persistence\ManagerRegistry;
  18. use InvalidArgumentException;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. use Symfony\Component\Validator\Exception\UnexpectedTypeException;
  21. use Symfony\Component\Validator\Exception\UnexpectedValueException;
  23. class DownloadableContentBidHandler implements RabbitMqHandlerInterface, EventSubscriberInterface
  24. {
  26.     public const ADD = 'add';
  27.     public const REMOVE = 'remove';
  29.     private ManagerRegistry $doctrine;
  31.     private DownloadRepository $downloadRepository;
  33.     public function __construct(ManagerRegistry $doctrine, DownloadRepository $downloadRepository)
  34.     {
  35.         $this->doctrine = $doctrine;
  36.         $this->downloadRepository = $downloadRepository;
  37.     }
  39.     public function supports(string $service): bool
  40.     {
  41.         return $service === self::class;
  42.     }
  44.     /**
  45.      * @param mixed[] $task
  46.      */
  47.     public function handle(?object $entity, array $task): void
  48.     {
  49.         if (!is_array($task['arguments']) || 1 !== count($task['arguments'])) {
  50.             throw new InvalidArgumentException('Task should contain only one argument.');
  51.         }
  53.         if (!$entity instanceof DownloadableContentBid) {
  54.             throw new UnexpectedTypeException($entity, DownloadableContentBid::class);
  55.         }
  57.         if (!is_string($task['arguments'][0])) {
  58.             return;
  59.         }
  61.         $action = $task['arguments'][0];
  63.         if (self::ADD !== $action && self::REMOVE !== $action) {
  64.             throw new UnexpectedValueException($action, '"add"|"remove"');
  65.         }
  67.         if (self::ADD === $action && (!$entity->isStillAccessible() || !$entity->getContent()->isContentAccessible())) {
  68.             return;
  69.         }
  71.         if (self::REMOVE === $action && $entity->isStillAccessible()) {
  72.             return;
  73.         }
  75.         $downloadableContent = $entity->getContent();
  76.         if (!$downloadableContent instanceof Deal && !$downloadableContent instanceof Project && !$downloadableContent instanceof ShopVideo && !$downloadableContent instanceof MessageReception) {
  77.             throw new UnexpectedTypeException($downloadableContent, implode('|', [Deal::class, Project::class, ShopVideo::class, MessageReception::class]));
  78.         }
  80.         $downloads = $this->downloadRepository->filterResults([
  81.             DownloadableContentFilter::FILTER => $downloadableContent,
  82.             UserBids::FILTER => $entity->getUser(),
  83.         ]);
  85.         if (self::ADD === $action) {
  86.             if (1 === count($downloads)) {
  87.                 // already has it
  88.                 return;
  89.             }
  91.             if (0 === count($downloads)) {
  92.                 $download = new Download($entity->getUser(), $downloadableContent);
  93.                 $this->doctrine->getManager()->persist($download);
  95.                 return;
  96.             }
  98.             // slip to remove, but leave one entry
  99.             array_shift($downloads);
  100.         }
  102.         foreach ($downloads as $download) {
  103.             $this->doctrine->getManager()->remove($download);
  104.         }
  105.     }
  107.     public function onPushProcess(PushProcessingEvent $event): void
  108.     {
  109.         $this->onProcess($event);
  110.     }
  112.     public function onPopProcess(PopProcessingEvent $event): void
  113.     {
  114.         $this->onProcess($event);
  115.     }
  117.     private function onProcess(ProcessingEvent $event): void
  118.     {
  119.         if ($event->getService() !== self::class) {
  120.             return;
  121.         }
  123.         $entity = $event->getEntity();
  124.         if (!$entity instanceof DownloadableContentBid) {
  125.             return;
  126.         }
  128.         $event->stopPropagation();
  129.     }
  131.     /**
  132.      * @return array<string, array<int|string, array<int|string, int|string>|int|string>|string>
  133.      */
  134.     public static function getSubscribedEvents(): array
  135.     {
  136.         return [
  137.             PushProcessingEvent::class => ['onPushProcess', 1000],
  138.             PopProcessingEvent::class => ['onPopProcess', 1000],
  139.         ];
  140.     }
  142. }