From 2b7ed2aa242e2f8b26280d2456234ddecad99180 Mon Sep 17 00:00:00 2001 From: ArnabChatterjee20k Date: Thu, 14 May 2026 12:15:15 +0530 Subject: [PATCH] removed stale --- src/Appwrite/Platform/Workers/Deletes.php | 22 ---------------------- 1 file changed, 22 deletions(-) diff --git a/src/Appwrite/Platform/Workers/Deletes.php b/src/Appwrite/Platform/Workers/Deletes.php index 807f5f3623..93b0686f57 100644 --- a/src/Appwrite/Platform/Workers/Deletes.php +++ b/src/Appwrite/Platform/Workers/Deletes.php @@ -220,7 +220,6 @@ class Deletes extends Action $this->deleteExpiredSessions($project, $getProjectDB); $this->deleteExpiredTransactions($project, $getProjectDB); $this->deleteExpiredPresences($project, $getProjectDB, $publisherForUsage); - $this->deleteStalePresences($project, $getProjectDB, $publisherForUsage); $this->deleteOldDeployments($queueForDeletes, $project, $getProjectDB); break; case DELETE_TYPE_REPORT: @@ -1767,25 +1766,4 @@ class Deletes extends Action )); } } - - private function deleteStalePresences(Document $project, callable $getProjectDB, UsagePublisher $publisherForUsage): void - { - $dbForProject = $getProjectDB($project); - - $oldestAllowed = DateTime::format((new \DateTime())->sub(\DateInterval::createFromDateString('30 days'))); - - $deleted = $dbForProject->deleteDocuments('presenceLogs', [ - Query::lessThan('$createdAt', $oldestAllowed), - ], onError: function (Throwable $th) { - // Swallow errors to avoid breaking the cleanup process - }); - - if ($deleted > 0) { - $usage = (new UsageContext())->addMetric(METRIC_USERS_PRESENCE, -$deleted); - $publisherForUsage->enqueue(new Usage( - project: $project, - metrics: $usage->getMetrics(), - )); - } - } }