vendor/ibexa/taxonomy/src/lib/Event/Subscriber/SynchronizeEntryWithContentSubscriber.php line 88

Open in your IDE?
  1. <?php
  3. /**
  4. * @copyright Copyright (C) Ibexa AS. All rights reserved.
  5. * @license For full copyright and license information view LICENSE file distributed with this source code.
  6. */
  7. declare(strict_types=1);
  9. namespace Ibexa\Taxonomy\Event\Subscriber;
  11. use Ibexa\Contracts\Core\Repository\Events\Content\DeleteTranslationEvent;
  12. use Ibexa\Contracts\Core\Repository\Events\Content\PublishVersionEvent;
  13. use Ibexa\Contracts\Core\Repository\Events\Content\UpdateContentMetadataEvent;
  14. use Ibexa\Contracts\Core\Repository\Values\ContentType\ContentType;
  15. use Ibexa\Contracts\Taxonomy\Event\MoveTaxonomyEntryEvent;
  16. use Ibexa\Contracts\Taxonomy\Event\MoveTaxonomyEntryRelativeToSiblingEvent;
  17. use Ibexa\Contracts\Taxonomy\Service\TaxonomyServiceInterface;
  18. use Ibexa\Taxonomy\Exception\TaxonomyEntryNotFoundException;
  19. use Ibexa\Taxonomy\Repository\Content\ContentSynchronizerInterface;
  20. use Ibexa\Taxonomy\Service\TaxonomyConfiguration;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  23. /**
  24. * @internal
  25. */
  26. final class SynchronizeEntryWithContentSubscriber implements EventSubscriberInterface
  27. {
  28. private TaxonomyServiceInterface $taxonomyService;
  30. private TaxonomyConfiguration $taxonomyConfiguration;
  32. private ContentSynchronizerInterface $contentSynchronizer;
  34. public function __construct(
  35. TaxonomyServiceInterface $taxonomyService,
  36. TaxonomyConfiguration $taxonomyConfiguration,
  37. ContentSynchronizerInterface $contentSynchronizer
  38. ) {
  39. $this->taxonomyService = $taxonomyService;
  40. $this->taxonomyConfiguration = $taxonomyConfiguration;
  41. $this->contentSynchronizer = $contentSynchronizer;
  42. }
  44. public static function getSubscribedEvents(): array
  45. {
  46. return [
  47. PublishVersionEvent::class => 'onVersionPublish',
  48. DeleteTranslationEvent::class => 'onTranslationDelete',
  49. UpdateContentMetadataEvent::class => 'onContentMetadataUpdate',
  50. MoveTaxonomyEntryEvent::class => 'onTaxonomyEntryMove',
  51. MoveTaxonomyEntryRelativeToSiblingEvent::class => 'onMoveTaxonomyEntryRelativeToSibling',
  52. ];
  53. }
  55. /**
  56. * @throws \Ibexa\Contracts\Core\Repository\Exceptions\NotFoundException
  57. * @throws \Ibexa\Contracts\Core\Repository\Exceptions\UnauthorizedException
  58. */
  59. public function onVersionPublish(PublishVersionEvent $event): void
  60. {
  61. $content = $event->getContent();
  63. $this->doSynchronizeContent($content->getContentType(), $content->id);
  64. }
  66. /**
  67. * @throws \Ibexa\Contracts\Core\Repository\Exceptions\NotFoundException
  68. * @throws \Ibexa\Contracts\Core\Repository\Exceptions\UnauthorizedException
  69. */
  70. public function onTranslationDelete(DeleteTranslationEvent $event): void
  71. {
  72. $contentInfo = $event->getContentInfo();
  74. $this->doSynchronizeContent($contentInfo->getContentType(), $contentInfo->id);
  75. }
  77. /**
  78. * @throws \Ibexa\Contracts\Core\Repository\Exceptions\NotFoundException
  79. * @throws \Ibexa\Contracts\Core\Repository\Exceptions\UnauthorizedException
  80. */
  81. public function onContentMetadataUpdate(UpdateContentMetadataEvent $event): void
  82. {
  83. $content = $event->getContent();
  85. $this->doSynchronizeContent($content->getContentType(), $content->id);
  86. }
  88. public function onTaxonomyEntryMove(MoveTaxonomyEntryEvent $event): void
  89. {
  90. $content = $event->getTaxonomyEntry()->getContent();
  92. $this->doReverseSynchronizeContent($content->getContentType(), $content->id);
  93. }
  95. public function onMoveTaxonomyEntryRelativeToSibling(MoveTaxonomyEntryRelativeToSiblingEvent $event): void
  96. {
  97. $content = $event->getTaxonomyEntry()->getContent();
  99. $this->doReverseSynchronizeContent($content->getContentType(), $content->id);
  100. }
  102. /**
  103. * @throws \Ibexa\Contracts\Core\Repository\Exceptions\NotFoundException
  104. * @throws \Ibexa\Contracts\Core\Repository\Exceptions\UnauthorizedException
  105. */
  106. private function doSynchronizeContent(ContentType $contentType, int $contentId): void
  107. {
  108. if (!$this->taxonomyConfiguration->isContentTypeAssociatedWithTaxonomy($contentType)) {
  109. return;
  110. }
  112. try {
  113. $taxonomyEntry = $this->taxonomyService->loadEntryByContentId($contentId);
  114. } catch (TaxonomyEntryNotFoundException $e) {
  115. return;
  116. }
  118. $this->contentSynchronizer->synchronize($taxonomyEntry);
  119. }
  121. private function doReverseSynchronizeContent(ContentType $contentType, int $contentId): void
  122. {
  123. if (!$this->taxonomyConfiguration->isContentTypeAssociatedWithTaxonomy($contentType)) {
  124. return;
  125. }
  127. try {
  128. $taxonomyEntry = $this->taxonomyService->loadEntryByContentId($contentId);
  129. } catch (TaxonomyEntryNotFoundException $e) {
  130. return;
  131. }
  133. $this->contentSynchronizer->reverseSynchronize($taxonomyEntry);
  134. }
  135. }