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. }