src/ElasticSearch/EventSubscriber/IndexSubscriber.php line 43

Open in your IDE?
  1. <?php
  3. namespace App\ElasticSearch\EventSubscriber;
  5. use App\ElasticSearch\Service\AuctionIndexService;
  6. use App\ElasticSearch\Service\HorseIndexService;
  7. use App\ElasticSearch\Service\MarketplaceIndexService;
  8. use App\ElasticSearch\Service\NewsIndexService;
  9. use App\ElasticSearch\Service\ProfileIndexService;
  10. use App\ElasticSearch\Service\RaceIndexService;
  11. use App\ElasticSearch\Service\TimelinePostIndexService;
  12. use Pimcore\Event\DataObjectEvents;
  13. use Pimcore\Event\Model\DataObjectEvent;
  14. use Pimcore\Model\DataObject\TimelinePost;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\HttpFoundation\RequestStack;
  18. class IndexSubscriber implements EventSubscriberInterface
  19. {
  20.   protected static $dataObjects = ['Auction', 'Horse', 'Race', 'Profile', 'News', 'TimelinePost'];
  22.   public function __construct(
  23.     protected AuctionIndexService $auctionIndexService,
  24.     protected HorseIndexService $horseIndexService,
  25.     protected RaceIndexService $raceIndexService,
  26.     protected ProfileIndexService $profileIndexService,
  27.     protected NewsIndexService $newsIndexService,
  28.     protected TimelinePostIndexService $timelinePostIndexService,
  29.     protected MarketplaceIndexService $marketplaceIndexService,
  30.     protected RequestStack $requestStack
  31.   ) {
  32.   }
  34.   public static function getSubscribedEvents()
  35.   {
  36.     return [
  37.       DataObjectEvents::POST_ADD => 'onDataObjectPostAdd',
  38.       DataObjectEvents::POST_UPDATE => 'onDataObjectPostUpdate',
  39.       DataObjectEvents::POST_DELETE => 'onDataObjectPostDelete',
  40.     ];
  41.   }
  43.   public function onDataObjectPostAdd(DataObjectEvent $event)
  44.   {
  45.     if (!$this->requestStack) {
  46.       return;
  47.     }
  49.     $object = $event->getObject();
  50.     $className = (new \ReflectionClass($object))->getShortName();
  52.     if (!in_array($className, $this::$dataObjects)) {
  53.       return;
  54.     }
  56.     switch ($className) {
  57.       case 'Auction': $this->auctionIndexService->add($object); break;
  58.       case 'Horse': $this->horseIndexService->add($object); break;
  59.       case 'Race': $this->raceIndexService->add($object); break;
  60.       case 'Profile': $this->profileIndexService->add($object); break;
  61.       case 'News': $this->newsIndexService->add($object); break;
  62.       case 'TimelinePost': $this->addTimelinePost($object);
  63.     }
  64.   }
  66.   public function onDataObjectPostUpdate(DataObjectEvent $event)
  67.   {
  68.     if (!$this->requestStack) {
  69.       return;
  70.     }
  72.     $object = $event->getObject();
  73.     $className = (new \ReflectionClass($object))->getShortName();
  75.     if (!in_array($className, $this::$dataObjects)) {
  76.       return;
  77.     }
  79.     switch ($className) {
  80.       case 'Auction': $this->auctionIndexService->update($object); break;
  81.       case 'Horse': $this->horseIndexService->update($object); break;
  82.       case 'Race': $this->raceIndexService->update($object); break;
  83.       case 'Profile': $this->profileIndexService->update($object); break;
  84.       case 'News': $this->newsIndexService->update($object); break;
  85.       case 'TimelinePost': $this->updateTimelinePost($object);
  86.     }
  87.   }
  89.   public function onDataObjectPostDelete(DataObjectEvent $event)
  90.   {
  91.     if (!$this->requestStack) {
  92.       return;
  93.     }
  95.     $object = $event->getObject();
  96.     $className = (new \ReflectionClass($object))->getShortName();
  98.     if (!in_array($className, $this::$dataObjects)) {
  99.       return;
  100.     }
  102.     switch ($className) {
  103.       case 'Auction': $this->auctionIndexService->delete($object); break;
  104.       case 'Horse': $this->horseIndexService->delete($object); break;
  105.       case 'Race': $this->raceIndexService->delete($object); break;
  106.       case 'Profile': $this->profileIndexService->delete($object); break;
  107.       case 'News': $this->newsIndexService->delete($object); break;
  108.       case 'TimelinePost': $this->deleteTimelinePost($object);
  109.     }
  110.   }
  112.   private function addTimelinePost(TimelinePost $post)
  113.   {
  114.     if ($post->getPostType() && $post->getPostType()->getServiceTimelinePost()) {
  115.       $this->marketplaceIndexService->add($post);
  116.     }
  117.     $this->timelinePostIndexService->add($post);
  118.   }
  120.   private function updateTimelinePost(TimelinePost $post)
  121.   {
  122.     if ($post->getPostType() && $post->getPostType()->getServiceTimelinePost()) {
  123.       $this->marketplaceIndexService->update($post);
  124.     }
  125.     $this->timelinePostIndexService->update($post);
  126.   }
  128.   private function deleteTimelinePost(TimelinePost $post)
  129.   {
  130.     if ($post->getPostType() && $post->getPostType()->getServiceTimelinePost()) {
  131.       $this->marketplaceIndexService->delete($post);
  132.     }
  133.     $this->timelinePostIndexService->delete($post);
  134.   }
  135. }