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

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