added transaction

ivanomatteo · May 24, 2022 · a5363a8 · a5363a8
1 parent acb514d
commit a5363a8
Showing 1 changed file with 28 additions and 3 deletions.
diff --git a/src/Scout/ScoutEngine.php b/src/Scout/ScoutEngine.php
@@ -28,7 +28,19 @@ public function __construct()
      */
     public function update($models)
     {
-        $models->each(fn ($m) => $this->ftindexer->addModelToIndex($m));
+        $count = $models->count();
+        if ($count === 0) {
+            return;
+        }
+        $connection = $models->first()->getConnection();
+
+        if ($count > 1 && $connection->transactionLevel() === 0) {
+            $connection->transaction(
+                fn () => $models->each(fn ($m) => $this->ftindexer->addModelToIndex($m))
+            );
+        } else {
+            $models->each(fn ($m) => $this->ftindexer->addModelToIndex($m));
+        }
     }
 
     /**
@@ -39,7 +51,20 @@ public function update($models)
      */
     public function delete($models)
     {
-        $models->each(fn ($m) => $this->ftindexer->removeModelFromIndex($m));
+        $count = $models->count();
+
+        if ($count === 0) {
+            return;
+        }
+        $connection = $models->first()->getConnection();
+
+        if ($count > 1 && $connection->transactionLevel() === 0) {
+            $connection->transaction(
+                fn () => $models->each(fn ($m) => $this->ftindexer->removeModelFromIndex($m))
+            );
+        } else {
+            $models->each(fn ($m) => $this->ftindexer->removeModelFromIndex($m));
+        }
     }
 
     /**
@@ -191,6 +216,6 @@ public function deleteIndex($name)
 
     private static function usesSoftDelete($class)
     {
-        return ! empty(class_uses_recursive($class)[SoftDeletes::class]);
+        return !empty(class_uses_recursive($class)[SoftDeletes::class]);
     }
 }