vendor/pimcore/data-hub-simple-rest/src/EventSubscriber/ChangedEventSubscriber.php line 54

Open in your IDE?
  1. <?php
  3. /**
  4.  * Pimcore
  5.  *
  6.  * This source file is available under following license:
  7.  * - Pimcore Commercial License (PCL)
  8.  *
  9.  *  @copyright  Copyright (c) Pimcore GmbH (http://www.pimcore.org)
  10.  *  @license    http://www.pimcore.org/license     PCL
  11.  */
  13. namespace Pimcore\Bundle\DataHubSimpleRestBundle\EventSubscriber;
  15. use Pimcore\Bundle\DataHubSimpleRestBundle\Service\IndexService;
  16. use Pimcore\Event\AssetEvents;
  17. use Pimcore\Event\DataObjectEvents;
  18. use Pimcore\Event\Model\ElementEventInterface;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class ChangedEventSubscriber implements EventSubscriberInterface
  22. {
  23.     /**
  24.      * @var IndexService
  25.      */
  26.     protected $indexService;
  28.     /**
  29.      * ChangedEventSubscriber constructor.
  30.      *
  31.      * @param IndexService $indexService
  32.      */
  33.     public function __construct(IndexService $indexService)
  34.     {
  35.         $this->indexService = $indexService;
  36.     }
  38.     /**
  39.      * Returns an array of events this subscriber wants to listen to.
  40.      *
  41.      * @return string[]
  42.      */
  43.     public static function getSubscribedEvents()
  44.     {
  45.         return [
  46.             DataObjectEvents::POST_UPDATE => 'updateElement',
  47.             AssetEvents::POST_UPDATE => 'updateElement',
  48.             AssetEvents::POST_ADD => 'updateElement',
  49.             DataObjectEvents::POST_DELETE => 'deleteElement',
  50.             AssetEvents::POST_DELETE => 'deleteElement'
  51.         ];
  52.     }
  54.     public function updateElement(ElementEventInterface $event)
  55.     {
  56.         $element = $event->getElement();
  57.         $entityType = $this->indexService->getEntityTypeForElement($element);
  58.         $this->indexService->addItemToQueue($element->getId(), $entityType);
  59.         $this->indexService->invalidateIndexByOriginalPath($element->getFullPath(), $entityType);
  60.     }
  62.     public function deleteElement(ElementEventInterface $event)
  63.     {
  64.         $element = $event->getElement();
  65.         $entityType = $this->indexService->getEntityTypeForElement($element);
  66.         $this->indexService->invalidateIndexByOriginalPath($element->getFullPath(), $entityType);
  67.     }
  68. }