vendor/shopware/core/Framework/DataAbstractionLayer/Indexing/IndexerRegistry.php line 77

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\DataAbstractionLayer\Indexing;
  5. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  9. /**
  10.  * @deprecated tag:v6.3.0 - Use \Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexerRegistry instead
  11.  */
  12. class IndexerRegistry implements EventSubscriberInterface, IndexerRegistryInterface
  13. {
  14.     /**
  15.      * 0    => Shopware\Core\Content\ProductStream\DataAbstractionLayer\Indexing\ProductStreamIndexer
  16.      * 0    => Shopware\Core\Content\Rule\DataAbstractionLayer\Indexing\RulePayloadIndexer
  17.      * 200  => Shopware\Core\Framework\Search\DataAbstractionLayer\Indexing\SearchKeywordIndexer
  18.      * 300  => Shopware\Core\Content\Product\DataAbstractionLayer\Indexing\ProductListingPriceIndexer
  19.      * 400  => Shopware\Core\Content\Product\DataAbstractionLayer\Indexing\ProductPropertyIndexer
  20.      * 500  => Shopware\Core\Content\Product\DataAbstractionLayer\Indexing\ProductCategoryTreeIndexer
  21.      * 500  => Shopware\Core\Content\Media\DataAbstractionLayer\Indexing\MediaFolderConfigIndexer
  22.      * 900  => Shopware\Core\Content\Product\DataAbstractionLayer\Indexing\ProductOptionIndexer
  23.      * 1000 => Shopware\Core\Framework\DataAbstractionLayer\Dbal\Indexing\ChildCountIndexer
  24.      * 1000 => Shopware\Core\Framework\DataAbstractionLayer\Dbal\Indexing\TreeIndexer
  25.      * 1500 => Shopware\Core\Framework\DataAbstractionLayer\Dbal\Indexing\InheritanceIndexer
  26.      *
  27.      * @var IndexerInterface[]
  28.      */
  29.     private $indexer;
  31.     /**
  32.      * @var EventDispatcherInterface
  33.      */
  34.     private $eventDispatcher;
  36.     /**
  37.      * Internal working state to prevent endless loop if an indexer fires the EntityWrittenContainerEvent
  38.      *
  39.      * @var bool
  40.      */
  41.     private $working = false;
  43.     public function __construct(iterable $indexer, EventDispatcherInterface $eventDispatcher)
  44.     {
  45.         $this->indexer = $indexer;
  46.         $this->eventDispatcher = $eventDispatcher;
  47.     }
  49.     public static function getSubscribedEvents(): array
  50.     {
  51.         return [
  52.             EntityWrittenContainerEvent::class => [
  53.                 ['refresh', 500],
  54.             ],
  55.         ];
  56.     }
  58.     public function index(\DateTimeInterface $timestamp): void
  59.     {
  60.         if ($this->working) {
  61.             return;
  62.         }
  64.         $preEvent = new IndexerRegistryStartEvent(new \DateTimeImmutable());
  65.         $this->eventDispatcher->dispatch($preEvent);
  67.         $this->working = true;
  68.         foreach ($this->indexer as $indexer) {
  69.             $indexer->index($timestamp);
  70.         }
  71.         $this->working = false;
  73.         $preEvent = new IndexerRegistryEndEvent(new \DateTimeImmutable());
  74.         $this->eventDispatcher->dispatch($preEvent);
  75.     }
  77.     public function refresh(EntityWrittenContainerEvent $event): void
  78.     {
  79.         if ($this->working) {
  80.             return;
  81.         }
  83.         $preEvent = new IndexerRegistryStartEvent(new \DateTimeImmutable(), $event->getContext());
  84.         $this->eventDispatcher->dispatch($preEvent);
  86.         $this->working = true;
  87.         foreach ($this->indexer as $indexer) {
  88.             $indexer->refresh($event);
  89.         }
  90.         $this->working = false;
  92.         $preEvent = new IndexerRegistryEndEvent(new \DateTimeImmutable(), $event->getContext());
  93.         $this->eventDispatcher->dispatch($preEvent);
  94.     }
  96.     public function partial(?string $lastIndexer, ?array $lastId, \DateTimeInterface $timestamp): ?IndexerRegistryPartialResult
  97.     {
  98.         $indexers = $this->getIndexers();
  100.         foreach ($indexers as $index => $indexer) {
  101.             if (!$lastIndexer) {
  102.                 return $this->doPartial($indexer, $lastId, $index, $timestamp);
  103.             }
  105.             if ($lastIndexer === $indexer::getName()) {
  106.                 return $this->doPartial($indexer, $lastId, $index, $timestamp);
  107.             }
  108.         }
  110.         return null;
  111.     }
  113.     private function doPartial(IndexerInterface $indexer, ?array $lastId, $index, \DateTimeInterface $timestamp): ?IndexerRegistryPartialResult
  114.     {
  115.         $nextId = $indexer->partial($lastId, $timestamp);
  117.         $next = $indexer::getName();
  119.         if ($nextId !== null) {
  120.             return new IndexerRegistryPartialResult($next, $nextId);
  121.         }
  122.         ++$index;
  123.         $indexers = $this->getIndexers();
  125.         if (!isset($indexers[$index])) {
  126.             return null;
  127.         }
  129.         return new IndexerRegistryPartialResult($indexers[$index]::getName(), null);
  130.     }
  132.     private function getIndexers()
  133.     {
  134.         if (!is_array($this->indexer)) {
  135.             return array_values(iterator_to_array($this->indexer));
  136.         }
  138.         return array_values($this->indexer);
  139.     }
  140. }