From 511cf720134a4f73327ed99e582d7ee82959558a Mon Sep 17 00:00:00 2001
From: Darshan <itznotabug@gmail.com>
Date: Sat, 19 Apr 2025 19:17:25 +0530
Subject: [PATCH] fix: tests as per the latest databases changes.

---
 src/Appwrite/Platform/Workers/Deletes.php | 22 +++++++++++-----------
 1 file changed, 11 insertions(+), 11 deletions(-)

diff --git a/src/Appwrite/Platform/Workers/Deletes.php b/src/Appwrite/Platform/Workers/Deletes.php
index 89e7a61b6c..7e3679f156 100644
--- a/src/Appwrite/Platform/Workers/Deletes.php
+++ b/src/Appwrite/Platform/Workers/Deletes.php
@@ -1202,26 +1202,26 @@ class Deletes extends Action
     ): void {
         $start = \microtime(true);
 
-        /**
-         * deleteDocuments uses a cursor, we need to add a unique order by field or use default
-         */
+        $count = 0;
 
         try {
-            $documents = $database->deleteDocuments($collection, $queries);
+            $database->deleteDocuments(
+                collection: $collection,
+                queries: $queries,
+                onNext: function (Document $document) use (&$count, $callback) {
+                    $count++;
+                    if (\is_callable($callback)) {
+                        $callback($document);
+                    }
+                }
+            );
         } catch (Throwable $th) {
             $tenant = $database->getSharedTables() ? 'Tenant:'.$database->getTenant() : '';
             Console::error("Failed to delete documents for collection:{$database->getNamespace()}_{$collection} {$tenant} :{$th->getMessage()}");
             return;
         }
 
-        if (\is_callable($callback)) {
-            foreach ($documents as $document) {
-                $callback($document);
-            }
-        }
-
         $end = \microtime(true);
-        $count = \count($documents);
 
         Console::info("Deleted {$count} documents by group in " . ($end - $start) . " seconds");
     }