Merge pull request #460 from patchlevel/optimaize-archive-logic

execute archive logic only once
patchlevel · Jan 9, 2024 · b35940e · b35940e
2 parents baf2ba6 + 4c6e2f7
commit b35940e
Showing 1 changed file with 13 additions and 5 deletions.
diff --git a/src/Repository/DefaultRepository.php b/src/Repository/DefaultRepository.php
@@ -281,17 +281,25 @@ private function archive(Message ...$messages): void
             return;
         }
 
+        $lastMessageWithNewStreamStart = null;
+
         foreach ($messages as $message) {
             if (!$message->newStreamStart()) {
                 continue;
             }
 
-            $this->store->archiveMessages(
-                $message->aggregateClass(),
-                $message->aggregateId(),
-                $message->playhead(),
-            );
+            $lastMessageWithNewStreamStart = $message;
+        }
+
+        if ($lastMessageWithNewStreamStart === null) {
+            return;
         }
+
+        $this->store->archiveMessages(
+            $lastMessageWithNewStreamStart->aggregateClass(),
+            $lastMessageWithNewStreamStart->aggregateId(),
+            $lastMessageWithNewStreamStart->playhead(),
+        );
     }
 
     /** @return Traversable<object> */