handle relationship changes for queuing

WPP-Public · Oct 12, 2017 · 600dfc2 · 600dfc2
1 parent 70fd92c
commit 600dfc2
Showing 1 changed file with 18 additions and 3 deletions.
diff --git a/src/Searchable.php b/src/Searchable.php
@@ -426,23 +426,38 @@ public function reIndex()
     public function onAfterDelete()
     {
         $this->service->remove($this->owner);
-        $this->updateDependentClasses();
+        if ($this->queued) {
+            $reindex = new ReindexAfterWriteJob($this->owner);
+            singleton('QueuedJobService')->queueJob($reindex);
+        } else {
+            $this->updateDependentClasses();
+        }
     }
 
     /**
      * Update dependent classes after the extended object has been removed from a ManyManyList
      */
     public function onAfterManyManyRelationRemove()
     {
-        $this->updateDependentClasses();
+        if ($this->queued) {
+            $reindex = new ReindexAfterWriteJob($this->owner);
+            singleton('QueuedJobService')->queueJob($reindex);
+        } else {
+            $this->updateDependentClasses();
+        }
     }
 
     /**
      * Update dependent classes after the extended object has been added to a ManyManyList
      */
     public function onAfterManyManyRelationAdd()
     {
-        $this->updateDependentClasses();
+        if ($this->queued) {
+            $reindex = new ReindexAfterWriteJob($this->owner);
+            singleton('QueuedJobService')->queueJob($reindex);
+        } else {
+            $this->updateDependentClasses();
+        }
     }
 
     /**