src/Core/Content/Flow/Indexing/FlowIndexer.php line 63

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Flow\Indexing;
  5. use Shopware\Core\Content\Flow\Events\FlowIndexerEvent;
  6. use Shopware\Core\Content\Flow\FlowDefinition;
  7. use Shopware\Core\Framework\App\Event\AppActivatedEvent;
  8. use Shopware\Core\Framework\App\Event\AppDeactivatedEvent;
  9. use Shopware\Core\Framework\App\Event\AppDeletedEvent;
  10. use Shopware\Core\Framework\App\Event\AppInstalledEvent;
  11. use Shopware\Core\Framework\App\Event\AppUpdatedEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Dbal\Common\IteratorFactory;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexer;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexingMessage;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\MessageQueue\IterateEntityIndexerMessage;
  18. use Shopware\Core\Framework\Log\Package;
  19. use Shopware\Core\Framework\Plugin\Event\PluginPostActivateEvent;
  20. use Shopware\Core\Framework\Plugin\Event\PluginPostDeactivateEvent;
  21. use Shopware\Core\Framework\Plugin\Event\PluginPostInstallEvent;
  22. use Shopware\Core\Framework\Plugin\Event\PluginPostUninstallEvent;
  23. use Shopware\Core\Framework\Plugin\Event\PluginPostUpdateEvent;
  24. use Shopware\Core\Framework\Plugin\Exception\DecorationPatternException;
  25. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  26. use Symfony\Component\Messenger\MessageBusInterface;
  27. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  29. /**
  30.  * @internal
  31.  */
  32. #[Package('business-ops')]
  33. class FlowIndexer extends EntityIndexer implements EventSubscriberInterface
  34. {
  35.     /**
  36.      * @internal
  37.      */
  38.     public function __construct(private readonly IteratorFactory $iteratorFactory, private readonly EntityRepository $repository, private readonly FlowPayloadUpdater $payloadUpdater, private readonly EventDispatcherInterface $eventDispatcher, private readonly MessageBusInterface $messageBus)
  39.     {
  40.     }
  42.     public function getName(): string
  43.     {
  44.         return 'flow.indexer';
  45.     }
  47.     public static function getSubscribedEvents(): array
  48.     {
  49.         return [
  50.             PluginPostInstallEvent::class => 'refreshPlugin',
  51.             PluginPostActivateEvent::class => 'refreshPlugin',
  52.             PluginPostUpdateEvent::class => 'refreshPlugin',
  53.             PluginPostDeactivateEvent::class => 'refreshPlugin',
  54.             PluginPostUninstallEvent::class => 'refreshPlugin',
  55.             AppInstalledEvent::class => 'refreshPlugin',
  56.             AppUpdatedEvent::class => 'refreshPlugin',
  57.             AppActivatedEvent::class => 'refreshPlugin',
  58.             AppDeletedEvent::class => 'refreshPlugin',
  59.             AppDeactivatedEvent::class => 'refreshPlugin',
  60.         ];
  61.     }
  63.     public function refreshPlugin(): void
  64.     {
  65.         // Schedule indexer to update flows
  66.         $this->messageBus->dispatch(new IterateEntityIndexerMessage($this->getName(), null));
  67.     }
  69.     public function iterate(?array $offset): ?EntityIndexingMessage
  70.     {
  71.         $iterator = $this->iteratorFactory->createIterator($this->repository->getDefinition(), $offset);
  73.         $ids = $iterator->fetch();
  75.         if (empty($ids)) {
  76.             return null;
  77.         }
  79.         return new FlowIndexingMessage(array_values($ids), $iterator->getOffset());
  80.     }
  82.     public function update(EntityWrittenContainerEvent $event): ?EntityIndexingMessage
  83.     {
  84.         $updates = $event->getPrimaryKeys(FlowDefinition::ENTITY_NAME);
  86.         if (empty($updates)) {
  87.             return null;
  88.         }
  90.         $this->handle(new FlowIndexingMessage(array_values($updates), null, $event->getContext()));
  92.         return null;
  93.     }
  95.     public function handle(EntityIndexingMessage $message): void
  96.     {
  97.         $ids = array_unique(array_filter($message->getData()));
  99.         if (empty($ids)) {
  100.             return;
  101.         }
  103.         $this->payloadUpdater->update($ids);
  105.         $this->eventDispatcher->dispatch(new FlowIndexerEvent($ids, $message->getContext()));
  106.     }
  108.     public function getTotal(): int
  109.     {
  110.         return $this->iteratorFactory->createIterator($this->repository->getDefinition())->fetchCount();
  111.     }
  113.     public function getDecorated(): EntityIndexer
  114.     {
  115.         throw new DecorationPatternException(static::class);
  116.     }
  117. }