src/Hitso/Bundle/ContentBundle/EventListener/ContentSubscriber.php line 35

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