src/Subscriber/Content/VideoSnapshotSubscriber.php line 78

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Content;
  5. use App\Entity\ContentVideo;
  6. use App\Event\Content\ContentVideoDeleteEvent;
  7. use App\Event\Content\SnapshotsCreatedEvent;
  8. use App\Event\Content\VideoFileUploadedEvent;
  9. use App\Lib\System\Job\VideoSnapshotGeneratorJob;
  10. use App\Service\Content\ContentService;
  11. use App\Service\Content\SnapshotService;
  12. use App\Service\Media\StorageLayer;
  13. use App\Service\System\JobService;
  14. use Liip\ImagineBundle\Service\FilterService;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class VideoSnapshotSubscriber implements EventSubscriberInterface
  18. {
  19.     protected SnapshotService $service;
  21.     protected ContentService $contentService;
  23.     protected FilterService $filterService;
  25.     protected JobService $jobService;
  27.     protected StorageLayer $storageLayer;
  29.     /**
  30.      * VideoSnapshotSubscriber constructor.
  31.      */
  32.     public function __construct(SnapshotService $service, ContentService $contentService,
  33.         FilterService $filterService, JobService $jobService,
  34.         StorageLayer $layer)
  35.     {
  36.         $this->service = $service;
  37.         $this->contentService = $contentService;
  38.         $this->filterService = $filterService;
  39.         $this->jobService = $jobService;
  40.         $this->storageLayer = $layer;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             VideoFileUploadedEvent::class => [
  47.                 ['onVideoUploadedCreateSnapshots', 9997],
  48.             ],
  49.             SnapshotsCreatedEvent::class => [
  50.                 ['onSnapshotsCreatedUpdateContent', 0],
  51.             ],
  52.             ContentVideoDeleteEvent::class => [
  53.                 // remove liipimagine cache files first.
  54.                 // later, snapshot originals would not exist anymore.
  55.                 ['onVideoDeleteRemoveSnapshots', 9999],
  56.             ],
  57.         ];
  58.     }
  60.     /**
  61.      * @throws \Doctrine\ORM\ORMException
  62.      * @throws \Doctrine\ORM\OptimisticLockException
  63.      */
  64.     public function onVideoUploadedCreateSnapshots(VideoFileUploadedEvent $event)
  65.     {
  66.         $video = $event->getEntity();
  68.         // reset in DB if they will be re-created
  69.         if ($video->getPreviewsCreatedAt()) {
  70.             $video->setPreviewsCreatedAt(null);
  71.             $this->contentService->storeEntity($video);
  72.         }
  74.         $job = new VideoSnapshotGeneratorJob($video->getId());
  75.         $this->jobService->createSaveAndSchedule($job, '', null, VideoSnapshotGeneratorJob::queue);
  76.     }
  78.     public function onVideoDeleteRemoveSnapshots(ContentVideoDeleteEvent $event)
  79.     {
  80.         /**
  81.          * @var $video ContentVideo
  82.          */
  83.         $video = $event->getEntity();
  85.         foreach ($this->service->getSnapshots($video) as $snapshot) {
  86.             $number = $snapshot->getFilenameNumber();
  87.             $basename = 'snapshot.'.$number.'.png';
  88.             $resolvePath = $this->storageLayer->getContentPublicFilePath($video, $basename);
  90.             foreach (['preview_small', 'preview_big'] as $filter) {
  91.                 $this->filterService->bustCache($resolvePath, $filter);
  92.             }
  93.         }
  95.         if ($content = $video->getContent()) {
  96.             $this->service->deleteSnapshotsForContent($content);
  97.         }
  98.     }
  100.     /**
  101.      * @throws \Doctrine\ORM\ORMException
  102.      * @throws \Doctrine\ORM\OptimisticLockException
  103.      */
  104.     public function onSnapshotsCreatedUpdateContent(SnapshotsCreatedEvent $event)
  105.     {
  106.         $video = $event->getEntity();
  107.         $video->setPreviewsCreatedAt(new \DateTime());
  108.         $this->contentService->storeEntity($video);
  109.     }
  110. }