fix(preprocessing): chunk message query

Signed-off-by: Anna Larch <[email protected]>
nextcloud · Oct 5, 2023 · 62a1c98 · 62a1c98
1 parent 89d5ccc
commit 62a1c98
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;