src/Hitso/Bundle/CatalogBundle/EventListener/ProductSubscriber.php line 40

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Hitso\Bundle\CatalogBundle\EventListener;
  7. use Faker\Factory;
  8. use Hitso\Bundle\CatalogBundle\Entity\Product;
  9. use Hitso\Bundle\CommonBundle\Doctrine\Event\EntityEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Hitso\Bundle\SearchBundle\Manager\SearchManager;
  12. use Doctrine\Common\Collections\ArrayCollection;
  14. /**
  15.  * Class ProductSubscriber
  16.  *
  17.  * @package Hitso\Bundle\ContentBundle\EventListener
  18.  */
  19. class ProductSubscriber implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * @var SearchManager
  23.      */
  24.     private $searchManager;
  26.     public function __construct(SearchManager $searchManager)
  27.     {
  28.         $this->searchManager = $searchManager;
  29.     }
  31.     public static function getSubscribedEvents()
  32.     {
  33.         return [
  34.             'product.pre_create'  => 'onPreCreate',
  35.             'product.post_create' => 'onPostCreate',
  36.             'product.post_update' => 'onPostUpdate',
  37.         ];
  38.     }
  40.     public function onPreCreate(EntityEvent $event): void
  41.     {
  42.         $product = $event->getEntity();
  43.         if ($product instanceof Product) {
  44.             if ('' === (string) $product->getSlug()) {
  45.                 $product->setSlug(Factory::create()->uuid);
  46.             }
  47.         }
  48.     }
  50.     public function onPostCreate(EntityEvent $event): void
  51.     {
  52.         $entity = $event->getEntity();
  53.         if ($entity instanceof Product) {
  54.             try {
  55.                 $type = $this->searchManager->getType('product');
  56.                 if ($type) {
  57.                     $documents = new ArrayCollection();
  58.                     $document  = $type->createDocument($entity);
  59.                     $documents->add($document);
  60.                     $this->searchManager->addDocuments($documents, $type->getName());
  61.                 }
  62.             } catch (\Exception $e) {
  63.             }
  64.         }
  65.     }
  67.     public function onPostUpdate(EntityEvent $event): void
  68.     {
  69.         $entity = $event->getEntity();
  70.         if ($entity instanceof Product) {
  71.             try {
  72.                 $type = $this->searchManager->getType('product');
  73.                 if ($type) {
  74.                     $document = $type->createDocument($entity);
  75.                     $this->searchManager->updateDocument($document);
  76.                 }
  77.             } catch (\Exception $e) {
  78.             }
  79.         }
  80.     }
  81. }