src/Subscriber/Content/ContentPublishSubscriber.php line 92

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Content;
  5. use App\Dictionary\ContentStatus;
  6. use App\Dictionary\ContentType;
  7. use App\Event\Content\ContentPublishedEvent;
  8. use App\Event\RedisEventManager;
  9. use App\Lib\Content\ContentServiceAwareInterface;
  10. use App\Service\ActivityFeedService;
  11. use App\Service\Content\ContentService;
  12. use App\Service\Content\PreviewService;
  13. use App\Subscriber\AbstractRedisEventManagerSubscriber;
  14. use Frivol\Common\Service\CacheService;
  15. use Frivol\Common\Service\Notification\ContentPublishNotification;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\Routing\RouterInterface;
  19. class ContentPublishSubscriber extends AbstractRedisEventManagerSubscriber implements EventSubscriberInterface, ContentServiceAwareInterface
  20. {
  21.     protected ContentService $service;
  22.     protected PreviewService $previewService;
  23.     protected ActivityFeedService $activityFeedService;
  24.     protected CacheService $cache;
  26.     public function __construct(ContentService $service, PreviewService $previewService, RedisEventManager $redisEventManager,
  27.         ActivityFeedService $activityFeedService, RouterInterface $router, CacheService $cache)
  28.     {
  29.         $this->setContentService($service);
  30.         $this->setPreviewService($previewService);
  31.         $this->setActivityFeedService($activityFeedService);
  32.         $this->cache = $cache;
  34.         parent::__construct($redisEventManager, $router);
  35.     }
  37.     public function getActivityFeedService(): ActivityFeedService
  38.     {
  39.         return $this->activityFeedService;
  40.     }
  42.     /**
  43.      * @return $this
  44.      */
  45.     public function setActivityFeedService(ActivityFeedService $activityFeedService): self
  46.     {
  47.         $this->activityFeedService = $activityFeedService;
  49.         return $this;
  50.     }
  52.     public function setPreviewService(PreviewService $service): self
  53.     {
  54.         $this->previewService = $service;
  56.         return $this;
  57.     }
  59.     public function getPreviewService(): PreviewService
  60.     {
  61.         return $this->previewService;
  62.     }
  64.     public function setContentService(ContentService $service): ContentServiceAwareInterface
  65.     {
  66.         $this->service = $service;
  68.         return $this;
  69.     }
  71.     public function getContentService(): ContentService
  72.     {
  73.         return $this->service;
  74.     }
  76.     public static function getSubscribedEvents(): array
  77.     {
  78.         return [
  79.             ContentPublishedEvent::class => [
  80.                 ['onContentPublishedUpdateStatus', 0],
  81.                 ['onContentPublishedSendNotification', 1],
  82.                 ['onContentPublishedClearCache', 2],
  83.             ],
  84.         ];
  85.     }
  87.     public function onContentPublishedUpdateStatus(ContentPublishedEvent $event)
  88.     {
  89.         $this->getContentService()->changeContentStatus($event->getContent(), ContentStatus::ACTIVE);
  90.     }
  92.     public function onContentPublishedSendNotification(ContentPublishedEvent $event)
  93.     {
  94.         $content = $event->getContent();
  95.         $author = $content->getMember();
  97.         $previewService = $this->getPreviewService();
  98.         $imageIndex = $content->getPreviewImage() ? $content->getPreviewImage() : 1;
  99.         $photo = $previewService->getPreviewPhoto($content->getContent(), $imageIndex, true);
  101.         $filter = ContentType::VIDEO == $content->getType() ? 'preview_big' : 'previmg_big';
  103.         $notification = new ContentPublishNotification();
  104.         $notification->setFromMemberId($author->getId());
  105.         $notification->setFromUsername($author->getUsername());
  106.         $notification->setData([
  107.             'type' => $content->isImageset() ? 'Bilderset' : 'Video',
  108.             'title' => $content->getContent()->getTitle(),
  109.             'slug' => $content->isImageset() ? $content->getImageset()->getSlug() : $content->getVideo()->getSlug(),
  110.             'image' => (false === $content->isImageset() && null !== $photo) ? $previewService->getUrlForPhoto($photo, $filter) : null,
  111.             'username' => $author->getUsername(),
  112.         ]);
  114.         $this->getRedisEventManager()->publishToAll($author, $notification);
  115.     }
  117.     public function onContentPublishedClearCache(ContentPublishedEvent $event): void
  118.     {
  119.         $content = $event->getContent();
  120.         if (!$content->isImageset()) {
  121.             return;
  122.         }
  124.         try {
  125.             $this->cache->invalidateTags([
  126.                 'imagesets',
  127.                 'imageset-slug-'.$content->getSlug(),
  128.                 'imageset-'.$content->getId(),
  129.             ]);
  130.         } catch (\InvalidArgumentException $iae) {
  131.             $this->getPreviewService()->getLogger()->info($iae->getMessage().PHP_EOL.$iae->getTraceAsString());
  132.         }
  133.     }
  134. }