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

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.         //do not update index when auto save or only saving version
  57.         if (
  58.             ($event->hasArgument('isAutoSave') && $event->getArgument('isAutoSave')) ||
  59.             ($event->hasArgument('saveVersionOnly') && $event->getArgument('saveVersionOnly'))
  60.         ) {
  61.             return;
  62.         }
  64.         $element = $event->getElement();
  65.         $entityType = $this->indexService->getEntityTypeForElement($element);
  66.         $this->indexService->addItemToQueue($element->getId(), $entityType);
  67.         $this->indexService->invalidateIndexByOriginalPath($element->getFullPath(), $entityType);
  68.     }
  70.     public function deleteElement(ElementEventInterface $event)
  71.     {
  72.         $element = $event->getElement();
  73.         $entityType = $this->indexService->getEntityTypeForElement($element);
  74.         $this->indexService->invalidateIndexByOriginalPath($element->getFullPath(), $entityType);
  75.     }
  76. }