From 0ffe1d5346887e546bf3655fee8f454a1f439b93 Mon Sep 17 00:00:00 2001
From: Jake Barnby <jakeb994@gmail.com>
Date: Wed, 17 Jan 2024 14:54:25 +1300
Subject: [PATCH] Fix limits

---
 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 d0e47d1133..3267a9034e 100644
--- a/src/Appwrite/Platform/Workers/Messaging.php
+++ b/src/Appwrite/Platform/Workers/Messaging.php
@@ -97,7 +97,7 @@ class Messaging extends Action
         if (\count($topicIds) > 0) {
             $topics = $dbForProject->find('topics', [
                 Query::equal('$id', $topicIds),
-                Query::limit($topicIds)
+                Query::limit(\count($topicIds)),
             ]);
             foreach ($topics as $topic) {
                 $targets = \array_filter($topic->getAttribute('targets'), fn(Document $target) =>
@@ -109,7 +109,7 @@ class Messaging extends Action
         if (\count($userIds) > 0) {
             $users = $dbForProject->find('users', [
                 Query::equal('$id', $userIds),
-                Query::limit($userIds)
+                Query::limit(\count($userIds)),
             ]);
             foreach ($users as $user) {
                 $targets = \array_filter($user->getAttribute('targets'), fn(Document $target) =>
@@ -121,7 +121,7 @@ class Messaging extends Action
         if (\count($targetIds) > 0) {
             $targets = $dbForProject->find('targets', [
                 Query::equal('$id', $targetIds),
-                Query::limit($targetIds)
+                Query::limit(\count($targetIds)),
             ]);
             $recipients = \array_merge($recipients, $targets);
         }