vendor/javra/re-index-on-the-fly-bundle/src/EventListener/IndexOnPostListener.php line 42

Open in your IDE?
  1. <?php
  2. namespace Javra\ReIndexOnTheFlyBundle\EventListener;
  4. use Pimcore\Event\Model\DataObjectEvent;
  5. use Pimcore\Model\Search\Backend\Data;
  6. use Pimcore\Model\Search\Backend\Data\Id;
  7. use Pimcore\Event\Model\AssetEvent;
  9. /**
  10.  * Runs when events are triggered
  11.  */
  12. class IndexOnPostListener
  13. {
  14.     /**
  15.      * AssetonPostAddEdit
  16.      * Runs after asset is created or updated and index the asset
  17.      * @param AssetEvent $e
  18.      * @return void
  19.      */
  20.     public function AssetonPostAddEdit(AssetEvent $e): void
  21.     {
  22.         $this->createUpdateIndexElement($e->getAsset());
  23.     }
  25.     /**
  26.      * AssetonPostDelete
  27.      * Runs after asset is deleted and remove it from the index
  28.      * @param AssetEvent $e
  29.      * @return void
  30.      */
  31.     public function AssetonPostDelete(AssetEvent $e): void
  32.     {
  33.         $this->deleteIndexElement($e->getAsset());
  34.     }
  36.     /**
  37.      * DataObjectOnPostAddEdit
  38.      * Runs after dataObject is created or updated and index the asset
  39.      * @param AssetEvent $e
  40.      * @return void
  41.      */
  42.     public function DataObjectOnPostAddEdit(DataObjectEvent $e): void
  43.     {
  44.         $this->createUpdateIndexElement($e->getObject());
  45.     }
  47.     /**
  48.      * DataObjectOnPostDelete
  49.      * Runs after dataObject is created or updated and index the asset
  50.      * @param AssetEvent $e
  51.      * @return void
  52.      */
  53.     public function DataObjectOnPostDelete(DataObjectEvent $e): void
  54.     {
  55.         $this->deleteIndexElement($e->getObject());
  56.     }
  58.     /**
  59.      * Creates the entry on the index table for the element if not exists otherwise update the entry
  60.      *
  61.      * @param [mixed] $element
  62.      * @return void
  63.      */
  64.     private function createUpdateIndexElement($element): void
  65.     {
  66.         $searchEntry = Data::getForElement($element);
  67.         if ($searchEntry instanceof Data && $searchEntry->getId() instanceof Id) {
  68.             $searchEntry->setDataFromElement($element);
  69.         } else {
  70.             $searchEntry = new Data($element);
  71.         }
  73.         $searchEntry->save();
  74.     }
  76.     /**
  77.      * Removes the element from the index table
  78.      *
  79.      * @param [mixed] $element
  80.      * @return void
  81.      */
  82.     private function deleteIndexElement($element)
  83.     {
  84.         $searchEntry = Data::getForElement($element);
  85.         if ($searchEntry instanceof Data && $searchEntry->getId() instanceof Id) {
  86.             $searchEntry->setDataFromElement($element);
  87.         }
  88.         $searchEntry->delete();
  89.     }
  90. }