src/EventListener/SyncDataObjectsWithAlgoliaListener.php line 19

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use Exception;
  6. use Pimcore\Event\Model\DataObjectEvent;
  7. use Pimcore\Event\Model\ElementEventInterface;
  8. use Pimcore\Model\Asset;
  9. use Pimcore\Model\Asset\Image;
  10. use Pimcore\Model\DataObject\Folder;
  11. use Pimcore\Model\DataObject\Product;
  12. use Pimcore\Model\WebsiteSetting;
  14. class SyncDataObjectsWithAlgoliaListener extends BaseAlgoliaListener
  15. {
  16.     /**
  17.      * @throws Exception
  18.      */
  19.     public function onPostUpdate(ElementEventInterface $e)
  20.     {
  21.         // only if algolia is enabled
  22.         if ($this->isAlgoliaEnabled()) {
  23.             if ($e instanceof DataObjectEvent) {
  24.                 $obj = $e->getObject();
  26.                 if ($obj instanceof Product) {
  27.                     // don't allow products starting with specific existing path
  28.                     if ($excludedWs = WebsiteSetting::getByName("excludePathFromAlgoliaIndexing")) {
  29.                         $excludedPath = $excludedWs->getData();
  30.                         if (str_starts_with($obj->getPath(), $excludedPath)) {
  31.                             $folder = Folder::getByPath($excludedPath);
  32.                             if ($folder instanceof Folder) {
  33.                                 // remove from index because it should be excluded
  34.                                 $this->getIndex()->deleteObject($obj->getId());
  35.                                 return;
  36.                             }
  37.                         }
  38.                     }
  40.                     // don't allow product parents
  41.                     if ($obj->hasChildren()) {
  42.                         return;
  43.                     }
  45.                     $images = [];
  46.                     $documents = [];
  48.                     // get product images
  49.                     foreach ($obj->getImages()->getItems() as $item) {
  50.                         if ($image = $item->getImage()) {
  51.                             if ($image instanceof Image) {
  52.                                 // push only active images for algolia indexing
  53.                                 if ($image->getHasMetaData() && $image->getMetadata("indexAlgolia")) {
  54.                                     $images[] = [
  55.                                         "thumbnail" => !is_string($item->getThumbnail()) ? $item->getThumbnail("printdefault")->getPath() : "",
  56.                                         "originalImage" => $image->getFullPath() ?? "",
  57.                                         "fileSize" => $image->getFileSize() ?? ""
  58.                                     ];
  59.                                 }
  60.                             }
  61.                         }
  62.                     }
  64.                     // get product documents
  65.                     foreach ($obj->getDocuments() as $document) {
  66.                         // allow all assets
  67.                         if ($document instanceof Asset) {
  68.                             // push only active images for algolia indexing
  69.                             if ($document->getHasMetaData() && $document->getMetadata("indexAlgolia")) {
  70.                                 $documents[] = [
  71.                                     "document" => $document->getFullPath() ?? "",
  72.                                     "filename" => $document->getFilename() ?? "",
  73.                                     "fileSize" => $document->getFileSize() ?? ""
  74.                                 ];
  75.                             }
  76.                         }
  77.                     }
  79.                     // if no images and documents found; or product is unpublished, remove product from index and cancel further processing
  80.                     if ((sizeof($images) <= 0 && sizeof($documents) <= 0) || !$obj->getPublished()) {
  81.                         $this->getIndex()->deleteObject($obj->getId());
  82.                         return;
  83.                     }
  85.                     $indexableData = [
  86.                         "description" => $obj->getDesignations('de'), // TODO-dkfn20 allgemeine translation statt immer 'de'?
  87.                         "images" => $images,
  88.                         "documents" => $documents,
  89.                         "orderno" => $obj->getOrdernumber(),
  90.                         "longnumber" => $obj->getLongnumber()
  91.                     ];
  93.                     // Has to be assigned separately before saveObject() call to prevent unique objectID error!
  94.                     $indexableData['objectID'] = $obj->getId();
  96.                     $this->getIndex()->saveObject($indexableData);
  97.                 }
  98.             }
  99.         }
  100.     }
  102.     /**
  103.      * @throws Exception
  104.      */
  105.     public function onPostDelete(ElementEventInterface $e)
  106.     {
  107.         if ($e instanceof DataObjectEvent) {
  108.             $obj = $e->getObject();
  109.             if ($obj instanceof Product) {
  110.                 if ($this->getIndex()) {
  111.                     $this->getIndex()->deleteObject($obj->getId());
  112.                 }
  113.             }
  114.         }
  115.     }
  116. }