handle relationship changes for queuing

WPP-Public · Oct 12, 2017 · 96b6ae3 · 96b6ae3
1 parent 3fd8d9d
commit 96b6ae3
Showing 1 changed file with 18 additions and 3 deletions.
diff --git a/src/Searchable.php b/src/Searchable.php
@@ -444,23 +444,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();
+        }
     }
 
     /**