vendor/ibexa/product-catalog/src/lib/Search/Common/EventSubscriber/ProductEventSubscriber.php line 49

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\ProductCatalog\Search\Common\EventSubscriber;
  11. use Ibexa\Contracts\ProductCatalog\Local\Events\CreateProductAvailabilityEvent;
  12. use Ibexa\Contracts\ProductCatalog\Local\Events\DecreaseProductAvailabilityEvent;
  13. use Ibexa\Contracts\ProductCatalog\Local\Events\DeleteProductAvailabilityEvent;
  14. use Ibexa\Contracts\ProductCatalog\Local\Events\IncreaseProductAvailabilityEvent;
  15. use Ibexa\Contracts\ProductCatalog\Local\Events\UpdateProductAvailabilityEvent;
  16. use Ibexa\Contracts\ProductCatalog\Values\ContentAwareProductInterface;
  17. use Ibexa\Contracts\ProductCatalog\Values\ProductInterface;
  18. use Ibexa\Core\Search\Common\EventSubscriber\AbstractSearchEventSubscriber;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. final class ProductEventSubscriber extends AbstractSearchEventSubscriber implements EventSubscriberInterface
  22. {
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             CreateProductAvailabilityEvent::class => 'onCreateAvailability',
  27.             DeleteProductAvailabilityEvent::class => 'onDeleteAvailability',
  28.             UpdateProductAvailabilityEvent::class => 'onUpdateAvailability',
  29.             IncreaseProductAvailabilityEvent::class => 'onIncreaseAvailability',
  30.             DecreaseProductAvailabilityEvent::class => 'onDecreaseAvailability',
  31.         ];
  32.     }
  34.     public function onCreateAvailability(CreateProductAvailabilityEvent $event): void
  35.     {
  36.         $this->indexProduct($event->getCreateStruct()->getProduct());
  37.     }
  39.     public function onDeleteAvailability(DeleteProductAvailabilityEvent $event): void
  40.     {
  41.         $this->indexProduct($event->getProduct());
  42.     }
  44.     public function onUpdateAvailability(UpdateProductAvailabilityEvent $event): void
  45.     {
  46.         $this->indexProduct($event->getUpdateStruct()->getProduct());
  47.     }
  49.     public function onIncreaseAvailability(IncreaseProductAvailabilityEvent $event): void
  50.     {
  51.         $this->indexProduct($event->getProduct());
  52.     }
  54.     public function onDecreaseAvailability(DecreaseProductAvailabilityEvent $event): void
  55.     {
  56.         $this->indexProduct($event->getProduct());
  57.     }
  59.     private function indexProduct(ProductInterface $product): void
  60.     {
  61.         if (!$product instanceof ContentAwareProductInterface) {
  62.             return;
  63.         }
  65.         $content = $product->getContent();
  66.         $contentId = $content->getVersionInfo()->getContentInfo()->id;
  67.         $this->searchHandler->indexContent(
  68.             $this->persistenceHandler->contentHandler()->load(
  69.                 $contentId,
  70.                 $content->getVersionInfo()->versionNo
  71.             )
  72.         );
  74.         $locations = $this->persistenceHandler->locationHandler()->loadLocationsByContent(
  75.             $contentId
  76.         );
  78.         foreach ($locations as $location) {
  79.             $this->searchHandler->indexLocation($location);
  80.         }
  81.     }
  82. }