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

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. }