vendor/bitbag/elasticsearch-plugin/src/EventListener/ResourceIndexListener.php line 41

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file has been created by developers from BitBag.
  5.  * Feel free to contact us once you face any issues or want to start
  6.  * another great project.
  7.  * You can find more information about us on https://bitbag.io and write us
  8.  * an email on hello@bitbag.io.
  9.  */
  11. declare(strict_types=1);
  13. namespace BitBag\SyliusElasticsearchPlugin\EventListener;
  15. use BitBag\SyliusElasticsearchPlugin\Refresher\ResourceRefresherInterface;
  16. use Sylius\Component\Core\Model\Product;
  17. use Sylius\Component\Product\Model\ProductAttribute;
  18. use Sylius\Component\Resource\Model\ResourceInterface;
  19. use Sylius\Component\Resource\Repository\RepositoryInterface;
  20. use Symfony\Component\EventDispatcher\GenericEvent;
  21. use Webmozart\Assert\Assert;
  23. final class ResourceIndexListener implements ResourceIndexListenerInterface
  24. {
  25.     private ResourceRefresherInterface $resourceRefresher;
  27.     private array $persistersMap;
  29.     private RepositoryInterface $attributeRepository;
  31.     public function __construct(
  32.         ResourceRefresherInterface $resourceRefresher,
  33.         array $persistersMap,
  34.         RepositoryInterface $attributeRepository
  35.     ) {
  36.         $this->resourceRefresher = $resourceRefresher;
  37.         $this->persistersMap = $persistersMap;
  38.         $this->attributeRepository = $attributeRepository;
  39.     }
  41.     public function updateIndex(GenericEvent $event): void
  42.     {
  43.         $resource = $event->getSubject();
  45.         Assert::isInstanceOf($resource, ResourceInterface::class);
  46.         foreach ($this->persistersMap as $config) {
  47.             $method = $config[self::GET_PARENT_METHOD_KEY] ?? null;
  49.             if (null !== $method && method_exists($resource, $method)) {
  50.                 $resource = $resource->$method();
  51.             }
  53.             if ($resource instanceof $config[self::MODEL_KEY]) {
  54.                 $this->resourceRefresher->refresh($resource, $config[self::SERVICE_ID_KEY]);
  55.             }
  57.             if ($resource instanceof Product
  58.                 && ProductAttribute::class === $config[self::MODEL_KEY]
  59.             ) {
  60.                 foreach ($this->attributeRepository->findAll() as $attribute) {
  61.                     $this->resourceRefresher->refresh($attribute, $config[self::SERVICE_ID_KEY]);
  62.                 }
  63.             }
  64.         }
  65.     }
  66. }