vendor/pimcore/pimcore/bundles/CoreBundle/EventListener/SearchBackendListener.php line 72

Open in your IDE?
  1. <?php
  3. /**
  4.  * Pimcore
  5.  *
  6.  * This source file is available under two different licenses:
  7.  * - GNU General Public License version 3 (GPLv3)
  8.  * - Pimcore Commercial License (PCL)
  9.  * Full copyright and license information is available in
  10.  * LICENSE.md which is distributed with this source code.
  11.  *
  12.  *  @copyright  Copyright (c) Pimcore GmbH (http://www.pimcore.org)
  13.  *  @license    http://www.pimcore.org/license     GPLv3 and PCL
  14.  */
  16. namespace Pimcore\Bundle\CoreBundle\EventListener;
  18. use Pimcore\Event\AssetEvents;
  19. use Pimcore\Event\DataObjectEvents;
  20. use Pimcore\Event\DocumentEvents;
  21. use Pimcore\Event\Model\ElementEventInterface;
  22. use Pimcore\Messenger\SearchBackendMessage;
  23. use Pimcore\Model\Element\Service;
  24. use Pimcore\Model\Search\Backend\Data;
  25. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  26. use Symfony\Component\Messenger\MessageBusInterface;
  28. /**
  29.  * @internal
  30.  */
  31. class SearchBackendListener implements EventSubscriberInterface
  32. {
  33.     public function __construct(
  34.         private MessageBusInterface $messengerBusPimcoreCore
  35.     ) {
  36.     }
  38.     /**
  39.      * {@inheritdoc}
  40.      */
  41.     public static function getSubscribedEvents()
  42.     {
  43.         return [
  44.             DataObjectEvents::POST_ADD => 'onPostAddElement',
  45.             DocumentEvents::POST_ADD => 'onPostAddElement',
  46.             AssetEvents::POST_ADD => 'onPostAddElement',
  48.             DataObjectEvents::PRE_DELETE => 'onPreDeleteElement',
  49.             DocumentEvents::PRE_DELETE => 'onPreDeleteElement',
  50.             AssetEvents::PRE_DELETE => 'onPreDeleteElement',
  52.             DataObjectEvents::POST_UPDATE => 'onPostUpdateElement',
  53.             DocumentEvents::POST_UPDATE => 'onPostUpdateElement',
  54.             AssetEvents::POST_UPDATE => 'onPostUpdateElement',
  55.         ];
  56.     }
  58.     /**
  59.      * @param ElementEventInterface $e
  60.      */
  61.     public function onPostAddElement(ElementEventInterface $e)
  62.     {
  63.         $element = $e->getElement();
  64.         $this->messengerBusPimcoreCore->dispatch(
  65.             new SearchBackendMessage(Service::getElementType($element), $element->getId())
  66.         );
  67.     }
  69.     /**
  70.      * @param ElementEventInterface $e
  71.      */
  72.     public function onPreDeleteElement(ElementEventInterface $e)
  73.     {
  74.         $searchEntry = Data::getForElement($e->getElement());
  75.         if ($searchEntry instanceof Data && $searchEntry->getId() instanceof Data\Id) {
  76.             $searchEntry->delete();
  77.         }
  78.     }
  80.     /**
  81.      * @param ElementEventInterface $e
  82.      */
  83.     public function onPostUpdateElement(ElementEventInterface $e)
  84.     {
  85.         $element = $e->getElement();
  86.         $this->messengerBusPimcoreCore->dispatch(
  87.             new SearchBackendMessage(Service::getElementType($element), $element->getId())
  88.         );
  89.     }
  90. }