src/App/VideoProcessing/Processing/FeedVideoPopProcessing.php line 25

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace App\VideoProcessing\Processing;
  5. use App\Entity\Feed;
  6. use App\Entity\ShopVideoFile;
  7. use App\RabbitMq\Processing\PopProcessingEvent;
  8. use App\VideoProcessing\Ffmpeg\FileInfo\FetcherInterface;
  9. use InvalidArgumentException;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use UploadsBundle\RabbitMq\Handler\FileHandlerFactoryHandler;
  13. class FeedVideoPopProcessing implements EventSubscriberInterface
  14. {
  16.     private FetcherInterface $fetcher;
  18.     private bool $enabled = true;
  20.     public function __construct(FetcherInterface $fetcher)
  21.     {
  22.         $this->fetcher = $fetcher;
  23.     }
  25.     public function onPop(PopProcessingEvent $event): void
  26.     {
  27.         if (!$this->isEnabled()) {
  28.             return;
  29.         }
  31.         if ($event->getService() !== FileHandlerFactoryHandler::HANDLER) {
  32.             return;
  33.         }
  35.         /** @var string[] $arguments */
  36.         $arguments = $event->getArguments();
  38.         if (!isset($arguments[0]) || $arguments[0] !== 'feed_trailer') {
  39.             return;
  40.         }
  42.         if ($event->getMethod() !== 'move' && $event->getMethod() !== 'create') {
  43.             return;
  44.         }
  46.         if (!isset($arguments[1], $arguments[2])) {
  47.             throw new InvalidArgumentException('Can not use class without file paths.');
  48.         }
  50.         /** @var Feed $feed */
  51.         $feed = $event->getEntity();
  53.         $videoFile = new ShopVideoFile();
  54.         $this->fetcher->getFileInfo($videoFile, $arguments[1], $arguments[2]);
  56.         $feed->setVideoWidth($videoFile->getWidth());
  57.         $feed->setVideoHeight($videoFile->getHeight());
  58.         if (null === $runtime = $videoFile->getRunTime()) {
  59.             return;
  60.         }
  62.         $feed->setVideoRunTime($runtime);
  63.     }
  65.     private function isEnabled(): bool
  66.     {
  67.         return $this->enabled;
  68.     }
  70.     public function setEnabled(bool $enabled): void
  71.     {
  72.         $this->enabled = $enabled;
  73.     }
  75.     /**
  76.      * @return array<string, array<int|string, array<int|string, int|string>|int|string>|string>
  77.      */
  78.     public static function getSubscribedEvents(): array
  79.     {
  80.         return [
  81.             PopProcessingEvent::class => 'onPop',
  82.         ];
  83.     }
  85. }