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

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