From 099094f719e0308d1447d3fa284f4bb48809f432 Mon Sep 17 00:00:00 2001 From: Jake Barnby Date: Mon, 15 Jan 2024 18:27:48 +1300 Subject: [PATCH] Fix target fetch limits in worker --- src/Appwrite/Platform/Workers/Messaging.php | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/Appwrite/Platform/Workers/Messaging.php b/src/Appwrite/Platform/Workers/Messaging.php index 2d8770e29f..b5ba7142b1 100644 --- a/src/Appwrite/Platform/Workers/Messaging.php +++ b/src/Appwrite/Platform/Workers/Messaging.php @@ -95,7 +95,7 @@ class Messaging extends Action if (\count($topicIds) > 0) { $topics = $dbForProject->find('topics', [ Query::equal('$id', $topicIds), - Query::limit(APP_LIMIT_SUBSCRIBERS_SUBQUERY) + Query::limit($topicIds) ]); foreach ($topics as $topic) { $targets = \array_filter($topic->getAttribute('targets'), fn(Document $target) => @@ -107,7 +107,7 @@ class Messaging extends Action if (\count($userIds) > 0) { $users = $dbForProject->find('users', [ Query::equal('$id', $userIds), - Query::limit(APP_LIMIT_SUBSCRIBERS_SUBQUERY) + Query::limit($userIds) ]); foreach ($users as $user) { $targets = \array_filter($user->getAttribute('targets'), fn(Document $target) => @@ -119,7 +119,7 @@ class Messaging extends Action if (\count($targetIds) > 0) { $targets = $dbForProject->find('targets', [ Query::equal('$id', $targetIds), - Query::limit(APP_LIMIT_SUBSCRIBERS_SUBQUERY) + Query::limit($targetIds) ]); $recipients = \array_merge($recipients, $targets); }