Merge pull request #138 from delyriand/feature/add-automatic-reindex-…

…manager

Feature/add automatic reindex manager

src/EventSubscriber/ReindexProductEventSubscriber.php

@@ -18,6 +18,7 @@
 use Doctrine\ORM\Event\PostFlushEventArgs;
 use Doctrine\ORM\Events;
 use Doctrine\ORM\UnitOfWork;
+use MonsieurBiz\SyliusSearchPlugin\Manager\AutomaticReindexManagerInterface;
 use MonsieurBiz\SyliusSearchPlugin\Message\ProductReindexFromIds;
 use MonsieurBiz\SyliusSearchPlugin\Message\ProductReindexFromTaxon;
 use MonsieurBiz\SyliusSearchPlugin\Message\ProductToDeleteFromIds;
@@ -47,30 +48,42 @@ class ReindexProductEventSubscriber implements EventSubscriberInterface, LoggerA
 
     private MessageBusInterface $messageBus;
 
+    private AutomaticReindexManagerInterface $automaticReindexManager;
+
     private bool $dispatched = false;
 
-    public function __construct(MessageBusInterface $messageBus)
+    public function __construct(MessageBusInterface $messageBus, AutomaticReindexManagerInterface $automaticReindexManager)
     {
         $this->messageBus = $messageBus;
+        $this->automaticReindexManager = $automaticReindexManager;
     }
 
     public function getSubscribedEvents()
     {
         return [
             Events::onFlush => 'onFlush',
             Events::postFlush => 'postFlush',
+            Events::onClear => 'onClear',
         ];
     }
 
     public function onFlush(OnFlushEventArgs $eventArgs): void
     {
+        if (!$this->automaticReindexManager->shouldBeAutomaticallyReindex()) {
+            return;
+        }
+
         $eventArgs->getEntityManager()->getEventManager()->removeEventListener(Events::onFlush, $this);
         $unitOfWork = $eventArgs->getEntityManager()->getUnitOfWork();
         $this->manageUnitOfWork($unitOfWork);
     }
 
     public function postFlush(PostFlushEventArgs $args): void
     {
+        if (!$this->automaticReindexManager->shouldBeAutomaticallyReindex()) {
+            return;
+        }
+
         $unitOfWork = $args->getEntityManager()->getUnitOfWork();
         $this->manageUnitOfWork($unitOfWork);
 
@@ -90,6 +103,11 @@ public function postFlush(PostFlushEventArgs $args): void
         }
     }
 
+    public function onClear(): void
+    {
+        $this->dispatched = false;
+    }
+
     private function onFlushEntities(array $entities, string $type = 'insertionsOrUpdate'): void
     {
         foreach ($entities as $entity) {

src/Manager/AutomaticProductReindexManager.php

@@ -0,0 +1,29 @@
+<?php
+
+/*
+ * This file is part of Monsieur Biz' Search plugin for Sylius.
+ *
+ * (c) Monsieur Biz <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE.txt
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace MonsieurBiz\SyliusSearchPlugin\Manager;
+
+class AutomaticProductReindexManager implements AutomaticReindexManagerInterface
+{
+    private bool $shouldAutomaticallyReindex = true;
+
+    public function shouldAutomaticallyReindex(bool $shouldAutomaticallyReindex): void
+    {
+        $this->shouldAutomaticallyReindex = $shouldAutomaticallyReindex;
+    }
+
+    public function shouldBeAutomaticallyReindex(): bool
+    {
+        return $this->shouldAutomaticallyReindex;
+    }
+}

src/Manager/AutomaticReindexManagerInterface.php

@@ -0,0 +1,21 @@
+<?php
+
+/*
+ * This file is part of Monsieur Biz' Search plugin for Sylius.
+ *
+ * (c) Monsieur Biz <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE.txt
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace MonsieurBiz\SyliusSearchPlugin\Manager;
+
+interface AutomaticReindexManagerInterface
+{
+    public function shouldAutomaticallyReindex(bool $shouldAutomaticallyReindex): void;
+
+    public function shouldBeAutomaticallyReindex(): bool;
+}