vendor/ibexa/product-catalog/src/bundle/EventSubscriber/PriceSearchEventSubscriber.php line 68

Open in your IDE?
  1. <?php
  3. /**
  4.  * @copyright Copyright (C) Ibexa AS. All rights reserved.
  5.  * @license For full copyright and license information view LICENSE file distributed with this source code.
  6.  */
  7. declare(strict_types=1);
  9. namespace Ibexa\Bundle\ProductCatalog\EventSubscriber;
  11. use Ibexa\Contracts\Core\Persistence\Handler as PersistenceHandler;
  12. use Ibexa\Contracts\Core\Search\Handler as SearchHandler;
  13. use Ibexa\Contracts\ProductCatalog\Events\CreatePriceEvent;
  14. use Ibexa\Contracts\ProductCatalog\Events\DeletePriceEvent;
  15. use Ibexa\Contracts\ProductCatalog\Events\ExecutePriceStructsEvent;
  16. use Ibexa\Contracts\ProductCatalog\Events\UpdatePriceEvent;
  17. use Ibexa\Contracts\ProductCatalog\Values\ContentAwareProductInterface;
  18. use Ibexa\Contracts\ProductCatalog\Values\ProductInterface;
  19. use Ibexa\ProductCatalog\Config\ConfigProviderInterface;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. final class PriceSearchEventSubscriber implements EventSubscriberInterface
  23. {
  24.     private ConfigProviderInterface $configProvider;
  26.     private SearchHandler $searchHandler;
  28.     private PersistenceHandler $persistenceHandler;
  30.     public function __construct(
  31.         ConfigProviderInterface $configProvider,
  32.         SearchHandler $searchHandler,
  33.         PersistenceHandler $persistenceHandler
  34.     ) {
  35.         $this->configProvider = $configProvider;
  36.         $this->searchHandler = $searchHandler;
  37.         $this->persistenceHandler = $persistenceHandler;
  38.     }
  40.     public static function getSubscribedEvents(): array
  41.     {
  42.         return [
  43.             CreatePriceEvent::class => ['onCreatePrice', -10],
  44.             DeletePriceEvent::class => ['onDeletePrice', -10],
  45.             ExecutePriceStructsEvent::class => ['onExecutePriceStructs', -10],
  46.             UpdatePriceEvent::class => ['onUpdatePrice', -10],
  47.         ];
  48.     }
  50.     public function onCreatePrice(CreatePriceEvent $event): void
  51.     {
  52.         if (!$this->isLocalProductCatalog()) {
  53.             return;
  54.         }
  56.         $this->updateIndex($event->getPrice()->getProduct());
  57.     }
  59.     public function onDeletePrice(DeletePriceEvent $event): void
  60.     {
  61.         if (!$this->isLocalProductCatalog()) {
  62.             return;
  63.         }
  65.         $this->updateIndex($event->getDeleteStruct()->getPrice()->getProduct());
  66.     }
  68.     public function onExecutePriceStructs(ExecutePriceStructsEvent $event): void
  69.     {
  70.         if (!$this->isLocalProductCatalog()) {
  71.             return;
  72.         }
  74.         $alreadyUpdatedProducts = [];
  75.         foreach ($event->getPriceStructs() as $struct) {
  76.             $product = $struct->getProduct();
  77.             if (!($product instanceof ContentAwareProductInterface)) {
  78.                 continue;
  79.             }
  81.             if (in_array($product->getCode(), $alreadyUpdatedProducts, true)) {
  82.                 continue;
  83.             }
  85.             $this->updateIndex($product);
  86.             $alreadyUpdatedProducts[] = $product->getCode();
  87.         }
  88.     }
  90.     public function onUpdatePrice(UpdatePriceEvent $event): void
  91.     {
  92.         if (!$this->isLocalProductCatalog()) {
  93.             return;
  94.         }
  96.         $this->updateIndex($event->getPrice()->getProduct());
  97.     }
  99.     private function updateIndex(ProductInterface $product): void
  100.     {
  101.         if (!($product instanceof ContentAwareProductInterface)) {
  102.             return;
  103.         }
  105.         $versionInfo = $product->getContent()->getVersionInfo();
  107.         $contentId = $versionInfo->getContentInfo()->id;
  108.         $versionNo = $versionInfo->versionNo;
  110.         $this->searchHandler->indexContent(
  111.             $this->persistenceHandler->contentHandler()->load($contentId, $versionNo)
  112.         );
  114.         $locations = $this->persistenceHandler->locationHandler()->loadLocationsByContent($contentId);
  115.         foreach ($locations as $location) {
  116.             $this->searchHandler->indexLocation($location);
  117.         }
  118.     }
  120.     private function isLocalProductCatalog(): bool
  121.     {
  122.         return $this->configProvider->getEngineType() === 'local';
  123.     }
  124. }