Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

updated clousure scope

Browse Source
This commit is contained in:
ArnabChatterjee20k
2026-05-18 11:48:52 +05:30
parent 9263ea3661
commit ff298cb206
1 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/realtime.php
+11 -8
View File
@@ -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;