src/Subscriber/Content/ContentVideoEncodingSubscriber.php line 68

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Content;
  5. use App\Dictionary\ContentVideoMode;
  6. use App\Event\Content\ContentVideoEncodingFinishedEvent;
  7. use App\Event\Content\ContentVideoEncodingProgressedEvent;
  8. use App\Event\Content\VideoFileUploadedEvent;
  9. use App\Lib\Content\ContentVideoServiceAwareInterface;
  10. use App\Lib\System\Job\VideoEncodingJob;
  11. use App\Service\Content\VideoEncoderService;
  12. use App\Service\Content\VideoService;
  13. use App\Service\System\JobService;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class ContentVideoEncodingSubscriber implements EventSubscriberInterface, ContentVideoServiceAwareInterface
  17. {
  18.     protected VideoService $videoService;
  20.     protected JobService $jobService;
  22.     protected VideoEncoderService $encoderService;
  24.     /**
  25.      * ContentVideoEncodingSubscriber constructor.
  26.      */
  27.     public function __construct(VideoService $videoService, VideoEncoderService $encoderService, JobService $jobService)
  28.     {
  29.         $this->setContentVideoService($videoService);
  30.         $this->jobService = $jobService;
  31.         $this->encoderService = $encoderService;
  32.     }
  34.     public function getContentVideoService(): VideoService
  35.     {
  36.         return $this->videoService;
  37.     }
  39.     /**
  40.      * @return $this|ContentVideoServiceAwareInterface
  41.      */
  42.     public function setContentVideoService(VideoService $service): ContentVideoServiceAwareInterface
  43.     {
  44.         $this->videoService = $service;
  46.         return $this;
  47.     }
  49.     public static function getSubscribedEvents(): array
  50.     {
  51.         return [
  52.             VideoFileUploadedEvent::class => [
  53.                 ['onVideoFileUploadedCreateEncodeJobs', 9996],
  54.             ],
  55.             ContentVideoEncodingProgressedEvent::class => [
  56.                 ['onEncodingProgressedUpdateJob', 0],
  57.             ],
  58.             ContentVideoEncodingFinishedEvent::class => [
  59.                 ['onEncodingFinishedUpdateQualityFlag', 0],
  60.             ],
  61.         ];
  62.     }
  64.     /**
  65.      * @throws \Doctrine\ORM\ORMException
  66.      * @throws \Doctrine\ORM\OptimisticLockException
  67.      */
  68.     public function onVideoFileUploadedCreateEncodeJobs(VideoFileUploadedEvent $event)
  69.     {
  70.         $video = $event->getEntity();
  71.         if (!$meta = $video->getVideoMeta()) {
  72.             return;
  73.         }
  75.         $modes = [
  76.             ContentVideoMode::QUALITY_360P,
  77.             ContentVideoMode::QUALITY_720P,
  78.             ContentVideoMode::QUALITY_1080P,
  79.         ];
  80.         foreach ($modes as $mode) {
  81.             if ($this->encoderService->videoSatisfiesMode($meta, $mode)) {
  82.                 $job = new VideoEncodingJob($video->getId(), $mode);
  83.                 $queue = VideoEncodingJob::queue;
  84.                 $this->jobService->createSaveAndSchedule($job, '', null, $queue);
  85.             }
  86.         }
  87.     }
  89.     /**
  90.      * @throws \Doctrine\ORM\ORMException
  91.      * @throws \Doctrine\ORM\OptimisticLockException
  92.      */
  93.     public function onEncodingProgressedUpdateJob(ContentVideoEncodingProgressedEvent $event)
  94.     {
  95.         $job = $event->getEntity();
  96.         $progress = $event->getProgress();
  97.         $this->jobService->updateJobEntityProgress($job, $progress);
  98.     }
  100.     /**
  101.      * @throws \Doctrine\ORM\ORMException
  102.      * @throws \Doctrine\ORM\OptimisticLockException
  103.      */
  104.     public function onEncodingFinishedUpdateQualityFlag(ContentVideoEncodingFinishedEvent $event)
  105.     {
  106.         $video = $event->getEntity();
  107.         $mode = $event->getVideoMode();
  109.         if (ContentVideoMode::QUALITY_1080P == $mode) {
  110.             $video->setIs1080p(true);
  111.         }
  112.         if (ContentVideoMode::QUALITY_720P == $mode) {
  113.             $video->setIs720p(true);
  114.         }
  115.         if (ContentVideoMode::QUALITY_360P == $mode) {
  116.             $video->setIs360p(true);
  117.         }
  119.         $this->getContentVideoService()->storeContentVideo($video);
  120.     }
  121. }