From ff298cb206b968ae331f1d8b7baf2d09a887282b Mon Sep 17 00:00:00 2001
From: ArnabChatterjee20k <arnabchatterjee.ac.2@gmail.com>
Date: Mon, 18 May 2026 11:48:52 +0530
Subject: [PATCH] updated clousure scope

---
 app/realtime.php | 19 +++++++++++--------
 1 file changed, 11 insertions(+), 8 deletions(-)

diff --git a/app/realtime.php b/app/realtime.php
index c8c7908b84..b34dd9f420 100644
--- a/app/realtime.php
+++ b/app/realtime.php
@@ -1282,13 +1282,17 @@ $server->onClose(function (int $connection) use ($realtime, $stats, $register, $
                         /** @var array<string, true> $deletedIds */
                         $deletedIds = [];
                         try {
-                            $deletionCount = $dbForProject->getAuthorization()->skip(fn () => $dbForProject->deleteDocuments(
-                                'presenceLogs',
-                                [Query::equal('$id', $presenceIds)],
-                                onNext: function (Document $deleted) use (&$deletedIds): void {
-                                    $deletedIds[$deleted->getId()] = true;
-                                },
-                            ));
+                            $deletionCount = $dbForProject->getAuthorization()->skip(
+                                function () use ($dbForProject, $presenceIds, &$deletedIds): int {
+                                    return $dbForProject->deleteDocuments(
+                                        'presenceLogs',
+                                        [Query::equal('$id', $presenceIds)],
+                                        onNext: function (Document $deleted) use (&$deletedIds): void {
+                                            $deletedIds[$deleted->getId()] = true;
+                                        },
+                                    );
+                                }
+                            );
                             $presenceState->triggerUsage($publisherForUsage, $project, -$deletionCount);
                         } catch (Throwable $th) {
                             Span::error($th);
@@ -1300,7 +1304,6 @@ $server->onClose(function (int $connection) use ($realtime, $stats, $register, $
 
                         $queueForEvents = getQueueForEvents();
                         $queueForRealtime = getQueueForRealtime();
-
                         foreach ($presences as $presence) {
                             if (!isset($deletedIds[$presence->getId()])) {
                                 continue;