CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-08-02 20:12:01 +12:00
Code Issues Projects Releases Wiki Activity

Fix target fetch limits in worker

Browse source
This commit is contained in:
Jake Barnby 2024-01-15 18:27:48 +13:00
parent 78fe9ebb37
commit 099094f719
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/Appwrite/Platform/Workers/Messaging.php
View file

@ -95,7 +95,7 @@ class Messaging extends Action
if (\count($topicIds) > 0) { if (\count($topicIds) > 0) {
$topics = $dbForProject->find('topics', [ $topics = $dbForProject->find('topics', [
Query::equal('$id', $topicIds), Query::equal('$id', $topicIds),
Query::limit(APP_LIMIT_SUBSCRIBERS_SUBQUERY) Query::limit($topicIds)
]); ]);
foreach ($topics as $topic) { foreach ($topics as $topic) {
$targets = \array_filter($topic->getAttribute('targets'), fn(Document $target) => $targets = \array_filter($topic->getAttribute('targets'), fn(Document $target) =>
@ -107,7 +107,7 @@ class Messaging extends Action
if (\count($userIds) > 0) { if (\count($userIds) > 0) {
$users = $dbForProject->find('users', [ $users = $dbForProject->find('users', [
Query::equal('$id', $userIds), Query::equal('$id', $userIds),
Query::limit(APP_LIMIT_SUBSCRIBERS_SUBQUERY) Query::limit($userIds)
]); ]);
foreach ($users as $user) { foreach ($users as $user) {
$targets = \array_filter($user->getAttribute('targets'), fn(Document $target) => $targets = \array_filter($user->getAttribute('targets'), fn(Document $target) =>
@ -119,7 +119,7 @@ class Messaging extends Action
if (\count($targetIds) > 0) { if (\count($targetIds) > 0) {
$targets = $dbForProject->find('targets', [ $targets = $dbForProject->find('targets', [
Query::equal('$id', $targetIds), Query::equal('$id', $targetIds),
Query::limit(APP_LIMIT_SUBSCRIBERS_SUBQUERY) Query::limit($targetIds)
]); ]);
$recipients = \array_merge($recipients, $targets); $recipients = \array_merge($recipients, $targets);
} }