Merge pull request #8931 from nextcloud/fix/chunk-preprocessing-messages

fix(preprocessing): chunk message query
nextcloud · Oct 9, 2023 · 1ec5caa · 1ec5caa
2 parents a3f46be + 62a1c98
commit 1ec5caa
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/lib/Service/PreprocessingService.php b/lib/Service/PreprocessingService.php
@@ -62,8 +62,10 @@ public function process(int $limitTimestamp, Account $account): void {
 			return $mailbox->getId();
 		}, $mailboxes));
 
-
-		$messages = $this->messageMapper->getUnanalyzed($limitTimestamp, $mailboxIds);
+		$messages = [];
+		foreach(array_chunk($mailboxIds, 1000) as $chunk) {
+			$messages = array_merge($messages, $this->messageMapper->getUnanalyzed($limitTimestamp, $chunk));
+		}
 		if ($messages === []) {
 			$this->logger->debug('No structure data to analyse.');
 			return;