Flush only resource that gets persisted

netgen · Oct 31, 2023 · feae8b9 · feae8b9
1 parent 2b38930
commit feae8b9
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/lib/Core/AbstractProvider.php b/lib/Core/AbstractProvider.php
@@ -131,7 +131,7 @@ public function store(RemoteResource $resource): RemoteResource
             $resource->setUpdatedAt($this->dateTimeFactory->createCurrent());
 
             $this->entityManager->persist($resource);
-            $this->entityManager->flush();
+            $this->entityManager->flush($resource);
 
             return $resource;
         }
@@ -140,7 +140,7 @@ public function store(RemoteResource $resource): RemoteResource
 
         if (!$existingResource instanceof RemoteResource) {
             $this->entityManager->persist($resource);
-            $this->entityManager->flush();
+            $this->entityManager->flush($resource);
 
             return $resource;
         }
@@ -149,15 +149,15 @@ public function store(RemoteResource $resource): RemoteResource
         $existingResource->setUpdatedAt($this->dateTimeFactory->createCurrent());
 
         $this->entityManager->persist($existingResource);
-        $this->entityManager->flush();
+        $this->entityManager->flush($existingResource);
 
         return $existingResource;
     }
 
     public function remove(RemoteResource $resource): void
     {
         $this->entityManager->remove($resource);
-        $this->entityManager->flush();
+        $this->entityManager->flush($resource);
 
         if ($this->shouldDeleteFromRemote && $this->supportsDelete()) {
             $this->deleteFromRemote($resource);
@@ -181,15 +181,15 @@ public function loadLocation(int $id): RemoteResourceLocation
     public function storeLocation(RemoteResourceLocation $location): RemoteResourceLocation
     {
         $this->entityManager->persist($location);
-        $this->entityManager->flush();
+        $this->entityManager->flush($location);
 
         return $location;
     }
 
     public function removeLocation(RemoteResourceLocation $resourceLocation): void
     {
         $this->entityManager->remove($resourceLocation);
-        $this->entityManager->flush();
+        $this->entityManager->flush($resourceLocation);
     }
 
     public function loadNamedRemoteResource(string $name): RemoteResource