src/EventSubscriber/SearchIndexSubscriber.php line 32

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Message\SearchIndexUpdateMessage;
  6. use Doctrine\Common\EventSubscriber;
  7. use Doctrine\ORM\Event\PostPersistEventArgs;
  8. use Doctrine\ORM\Event\PostUpdateEventArgs;
  9. use Doctrine\ORM\Event\PostRemoveEventArgs;
  10. use Doctrine\ORM\Events;
  11. use Symfony\Component\Messenger\MessageBusInterface;
  13. class SearchIndexSubscriber implements EventSubscriber
  14. {
  15.     /** @var MessageBusInterface */
  16.     private $bus;
  18.     public function __construct(MessageBusInterface $bus)
  19.     {
  20.         $this->bus = $bus;
  21.     }
  23.     public function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             Events::postPersist,
  27.             Events::postUpdate,
  28.             Events::postRemove,
  29.         ];
  30.     }
  32.     public function postPersist(PostPersistEventArgs $args): void
  33.     {
  34.         $this->dispatch($args->getObject(), SearchIndexUpdateMessage::ACTION_UPSERT);
  35.     }
  37.     public function postUpdate(PostUpdateEventArgs $args): void
  38.     {
  39.         $this->dispatch($args->getObject(), SearchIndexUpdateMessage::ACTION_UPDATE);
  40.     }
  42.     public function postRemove(PostRemoveEventArgs $args): void
  43.     {
  44.         $this->dispatch($args->getObject(), SearchIndexUpdateMessage::ACTION_REMOVE);
  45.     }
  47.     private function dispatch(object $entity, string $action): void
  48.     {
  49.         $id = method_exists($entity, 'getId') ? $entity->getId() : null;
  51.         if ($id) {
  52.             $this->bus->dispatch(new SearchIndexUpdateMessage(get_class($entity), $id, $action));
  53.         }
  54.     }
  55. }