src/EventListener/ElasticIndexerSubscriber.php line 51

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use App\Admin\Trait\GeneralTrait;
  6. use App\Entity\Person;
  7. use App\Entity\Place;
  8. use App\Repository\PersonRepository;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use FOS\ElasticaBundle\Event\PreTransformEvent;
  11. use FOS\ElasticaBundle\Event\PostTransformEvent;
  12. use FOS\ElasticaBundle\Event\PostIndexPopulateEvent;
  13. use FOS\ElasticaBundle\Event\PreIndexPopulateEvent;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Elastica\Document;
  16. use Symfony\Component\Security\Http\Event\InteractiveLoginEvent;
  17. use Symfony\Component\Security\Http\SecurityEvents;
  19. class ElasticIndexerSubscriber implements EventSubscriberInterface
  20. {
  21.     use GeneralTrait;
  24.     /**
  25.      * @var PersonRepository|null
  26.      */
  27.     protected ?PersonRepository $personRepository;
  29.     /**
  30.      * @var EntityManagerInterface|null
  31.      */
  32.     private ?EntityManagerInterface $em;
  34.     public function __construct(
  35.         EntityManagerInterface $em,
  36.         PersonRepository $personRepository
  37.     ) {
  38.         $this->em = $em;
  39.         $this->personRepository = $personRepository;
  40.     }
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             PreTransformEvent::class => 'preTransform',
  46.             PostTransformEvent::class => 'postTransform',
  47.             PreIndexPopulateEvent::class => 'preIndex',
  48.         ];
  49.     }
  51.     public function preIndex(PreIndexPopulateEvent $event)
  52.     {
  53.         // dd($event);
  54.     }
  56.     public function preTransform(PreTransformEvent $event)
  57.     {
  58.         // dd($event);
  59.     }
  61.     public function postTransform(PostTransformEvent $event)
  62.     {
  63.         /*
  64.         $document = $event->getDocument();
  65.         if ($document instanceof Document) {
  66.             $reponame = lcfirst($document->getIndex()) . 'Repository';
  67.             $settings = [
  68.                 'id'         => $document->getId(),
  69.                 'index'      => $document->getIndex(),
  70.                 'entity'     => '\\App\Entity\\' . $this->underscoredToUpperCamelCase($document->getIndex()),
  71.                 'repository' => $reponame,
  72.             ];
  73.             $repository = $this->$reponame; // the repository has to be constructed in the calling class
  74.             $instance = $repository->findOneById($settings['id']);
  75.             if ($instance instanceof Person) {
  76.                 $placeofbirth = $instance->getPlaceofbirth();
  77.                 if ($placeofbirth instanceof Place) {
  78.                     $placeofbirth = $this->renderPlace($placeofbirth);
  79.                     // dd($placeofbirth);
  80.                 }
  81.                 $document->set('placeofbirth', $placeofbirth);
  82.             }
  83.         }
  84.         */
  85.     }
  88.     public function renderPlace(Place $place): array
  89.     {
  90.         return [
  91.             'id'   => $place->getId(),
  92.             'iri'  => '/api/places/' . $place->getId(),
  93.             'name' => $place->getName(),
  94.         ];
  95.     }
  96. }