vendor/sulu/sulu/src/Sulu/Bundle/WebsiteBundle/EventSubscriber/DomainEventEventSubscriber.php line 53

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of Sulu.
  5.  *
  6.  * (c) Sulu GmbH
  7.  *
  8.  * This source file is subject to the MIT license that is bundled
  9.  * with this source code in the file LICENSE.
  10.  */
  12. namespace Sulu\Bundle\WebsiteBundle\EventSubscriber;
  14. use Sulu\Bundle\ActivityBundle\Application\Dispatcher\DomainEventDispatcherInterface;
  15. use Sulu\Bundle\WebsiteBundle\Domain\Event\CacheClearedEvent;
  16. use Sulu\Bundle\WebsiteBundle\Event\CacheClearEvent;
  17. use Sulu\Bundle\WebsiteBundle\Events;
  18. use Sulu\Bundle\WebsiteBundle\ReferenceStore\WebspaceReferenceStore;
  19. use Sulu\Component\Webspace\Manager\WebspaceManagerInterface;
  20. use Sulu\Component\Webspace\Webspace;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  23. /**
  24.  * @internal
  25.  */
  26. class DomainEventEventSubscriber implements EventSubscriberInterface
  27. {
  28.     /**
  29.      * @var DomainEventDispatcherInterface
  30.      */
  31.     private $domainEventDispatcher;
  33.     /**
  34.      * @var WebspaceManagerInterface
  35.      */
  36.     private $webspaceManager;
  38.     public function __construct(
  39.         DomainEventDispatcherInterface $domainEventDispatcher,
  40.         WebspaceManagerInterface $webspaceManager
  41.     ) {
  42.         $this->domainEventDispatcher = $domainEventDispatcher;
  43.         $this->webspaceManager = $webspaceManager;
  44.     }
  46.     public static function getSubscribedEvents()
  47.     {
  48.         return [
  49.             Events::CACHE_CLEAR => 'onCacheClear',
  50.         ];
  51.     }
  53.     public function onCacheClear(CacheClearEvent $event): void
  54.     {
  55.         $tags = $event->getTags();
  56.         if (null === $tags || 0 === \count($tags)) {
  57.             /** @var Webspace $webspace */
  58.             foreach ($this->webspaceManager->getWebspaceCollection() as $webspace) {
  59.                 $this->domainEventDispatcher->dispatch(new CacheClearedEvent($webspace->getKey(), null));
  60.             }
  62.             return;
  63.         }
  65.         foreach ($tags as $tag) {
  66.             $webspaceKey = $this->getWebspaceKeyFromTag($tag);
  67.             if ($webspaceKey) {
  68.                 $this->domainEventDispatcher->dispatch(new CacheClearedEvent($webspaceKey, $tags));
  69.             }
  70.         }
  71.     }
  73.     private function getWebspaceKeyFromTag(string $tag): ?string
  74.     {
  75.         $parts = \explode('-', $tag, 2);
  77.         if (!isset($parts[1]) || WebspaceReferenceStore::WEBSPACE_REFERENCE_ALIAS !== $parts[0]) {
  78.             return null;
  79.         }
  81.         return $parts[1];
  82.     }
  83. }