Implement ConditionalUpdate interface for selective entity updates

Author: magnetik

src/Doctrine/ConditionalUpdate.php

@@ -0,0 +1,20 @@
+<?php
+
+/*
+ * This file is part of the FOSElasticaBundle package.
+ *
+ * (c) FriendsOfSymfony <https://friendsofsymfony.github.com/>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace FOS\ElasticaBundle\Doctrine;
+
+interface ConditionalUpdate
+{
+    /**
+     * Determines if an entity should be updated in Elasticsearch.
+     */
+    public function shouldBeUpdated(): bool;
+}

src/Doctrine/Listener.php

@@ -12,6 +12,7 @@
 namespace FOS\ElasticaBundle\Doctrine;
 
 use Doctrine\Persistence\Event\LifecycleEventArgs;
+use FOS\ElasticaBundle\Doctrine\ConditionalUpdate;
 use FOS\ElasticaBundle\Persister\ObjectPersister;
 use FOS\ElasticaBundle\Persister\ObjectPersisterInterface;
 use FOS\ElasticaBundle\Provider\IndexableInterface;
@@ -96,7 +97,9 @@ public function postPersist(LifecycleEventArgs $eventArgs)
         $entity = $eventArgs->getObject();
 
         if ($this->objectPersister->handlesObject($entity) && $this->isObjectIndexable($entity)) {
-            $this->scheduledForInsertion[] = $entity;
+            if (!$entity instanceof ConditionalUpdate || $entity->shouldBeUpdated()) {
+                $this->scheduledForInsertion[] = $entity;
+            }
         }
     }
 
@@ -109,7 +112,9 @@ public function postUpdate(LifecycleEventArgs $eventArgs)
 
         if ($this->objectPersister->handlesObject($entity)) {
             if ($this->isObjectIndexable($entity)) {
-                $this->scheduledForUpdate[] = $entity;
+                if (!$entity instanceof ConditionalUpdate || $entity->shouldBeUpdated()) {
+                    $this->scheduledForUpdate[] = $entity;
+                }
             } else {
                 // Delete if no longer indexable
                 $this->scheduleForDeletion($entity);