custom/plugins/PixelLexikonSW6/src/Entities/Categories/DataAbstractionLayer/LexikonCategoriesIndexer.php line 84

Open in your IDE?
  1. <?php
  3. namespace Pixel\LexikonSW6\Entities\Categories\DataAbstractionLayer;
  5. use Pixel\LexikonSW6\Entities\Categories\Events\LexikonCategoriesIndexerEvent;
  6. use Pixel\LexikonSW6\Entities\Categories\LexikonCategoriesDefinition;
  7. use Shopware\Core\Framework\Adapter\Cache\CacheClearer;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Dbal\Common\IteratorFactory;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexer;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexingMessage;
  13. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  15. class LexikonCategoriesIndexer extends EntityIndexer
  16. {
  17.     /** @var IteratorFactory */
  18.     private $iteratorFactory;
  20.     /** @var CacheClearer */
  21.     private $cacheClearer;
  23.     /** @var EventDispatcherInterface */
  24.     private $eventDispatcher;
  26.     /**
  27.      * @var EntityRepositoryInterface
  28.      */
  29.     private $repository;
  31.     public function __construct(
  32.         IteratorFactory $iteratorFactory,
  33.         EntityRepositoryInterface $repository,
  34.         CacheClearer $cacheClearer,
  35.         EventDispatcherInterface $eventDispatcher
  36.     ) {
  37.         $this->iteratorFactory = $iteratorFactory;
  38.         $this->repository = $repository;
  39.         $this->cacheClearer = $cacheClearer;
  40.         $this->eventDispatcher = $eventDispatcher;
  41.     }
  43.     public function getName(): string
  44.     {
  45.         return 'lexikon.listing.indexer';
  46.     }
  48.     public function iterate($offset): ?EntityIndexingMessage
  49.     {
  50.         $iterator = $this->iteratorFactory->createIterator($this->repository->getDefinition(), $offset);
  52.         $ids = $iterator->fetch();
  54.         // loop end? return null
  55.         if (empty($ids)) {
  56.             return null;
  57.         }
  59.         return new EntityIndexingMessage(array_values($ids), $iterator->getOffset());
  60.     }
  62.     public function update(EntityWrittenContainerEvent $event): ?EntityIndexingMessage
  63.     {
  64.         $updates = $event->getPrimaryKeys(LexikonCategoriesDefinition::ENTITY_NAME);
  66.         if (empty($updates)) {
  67.             return null;
  68.         }
  71.         return new EntityIndexingMessage(array_values($updates), null, $event->getContext());
  72.     }
  74.     public function handle(EntityIndexingMessage $message): void
  75.     {
  76.         $ids = $message->getData();
  77. // 19.12
  78.         $ids = array_unique(array_filter($ids));
  79.         if (empty($ids)) {
  80.             return;
  81.         }
  83.         // update all required data
  84.         $this->eventDispatcher->dispatch(new LexikonCategoriesIndexerEvent($ids, $message->getContext()));
  86.         //$this->cacheClearer->invalidateIds($ids, LexikonCategoriesDefinition::ENTITY_NAME);
  87.     }
  88. }