vendor/shopware/platform/src/Core/Framework/DataAbstractionLayer/Indexing/Subscriber/RegisteredIndexerSubscriber.php line 40

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\DataAbstractionLayer\Indexing\Subscriber;
  5. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexerRegistry;
  6. use Shopware\Core\Framework\Migration\IndexerQueuer;
  7. use Shopware\Core\Framework\Store\Event\FirstRunWizardFinishedEvent;
  8. use Shopware\Core\Framework\Update\Event\UpdatePreFinishEvent;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class RegisteredIndexerSubscriber implements EventSubscriberInterface
  12. {
  13.     /**
  14.      * @var IndexerQueuer
  15.      */
  16.     private $indexerQueuer;
  18.     /**
  19.      * @var EntityIndexerRegistry
  20.      */
  21.     private $indexerRegistry;
  23.     public function __construct(IndexerQueuer $indexerQueuer, EntityIndexerRegistry $indexerRegistry)
  24.     {
  25.         $this->indexerQueuer = $indexerQueuer;
  26.         $this->indexerRegistry = $indexerRegistry;
  27.     }
  29.     public static function getSubscribedEvents()
  30.     {
  31.         return [
  32.             UpdatePreFinishEvent::class => 'runRegisteredIndexers',
  33.             FirstRunWizardFinishedEvent::class => 'runRegisteredIndexers',
  34.         ];
  35.     }
  37.     /**
  38.      * @internal
  39.      */
  40.     public function runRegisteredIndexers(): void
  41.     {
  42.         $queuedIndexers = $this->indexerQueuer->getIndexers();
  44.         if (empty($queuedIndexers)) {
  45.             return;
  46.         }
  48.         $this->indexerQueuer->finishIndexer($queuedIndexers);
  50.         $indexer = array_filter($queuedIndexers, function ($indexer) {
  51.             return $this->indexerRegistry->has($indexer);
  52.         });
  54.         if (!empty($indexer)) {
  55.             $this->indexerRegistry->sendIndexingMessage($indexer);
  56.         }
  57.     }
  58. }