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

removed stale

Browse Source
This commit is contained in:
ArnabChatterjee20k
2026-05-14 12:15:15 +05:30
parent 5123956790
commit 2b7ed2aa24
1 changed files with 0 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Appwrite/Platform/Workers/Deletes.php
-22
View File
@@ -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(),
));
}
}
}