From 94de08cb59a54dfccdc14c9f58a77059368d9b1d Mon Sep 17 00:00:00 2001 From: fogelito Date: Mon, 14 Jul 2025 16:06:34 +0300 Subject: [PATCH] Deletes 1d 365 days --- src/Appwrite/Platform/Workers/Deletes.php | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/src/Appwrite/Platform/Workers/Deletes.php b/src/Appwrite/Platform/Workers/Deletes.php index aa511c2209..657c7dbbc5 100644 --- a/src/Appwrite/Platform/Workers/Deletes.php +++ b/src/Appwrite/Platform/Workers/Deletes.php @@ -398,6 +398,8 @@ class Deletes extends Action /** @var Database $dbForProject*/ $dbForProject = $getProjectDB($project); + $retention1d = DateTime::addSeconds(new \DateTime(), -1 * 365 * 24 * 60 * 60); // 1 year + $selects = [...$this->selects, 'time']; // Delete Usage stats from projectDB @@ -409,6 +411,14 @@ class Deletes extends Action Query::orderDesc(), ], $dbForProject); + $this->deleteByGroup('stats', [ + Query::select($selects), + Query::equal('period', ['1d']), + Query::lessThan('time', $retention1d), + Query::orderDesc('time'), + Query::orderDesc(), + ], $dbForProject); + if ($project->getId() !== 'console') { /** @var Database $dbForLogs*/ $dbForLogs = call_user_func($getLogsDB, $project); @@ -421,6 +431,14 @@ class Deletes extends Action Query::orderDesc('time'), Query::orderDesc(), ], $dbForLogs); + + $this->deleteByGroup('stats', [ + Query::select($selects), + Query::equal('period', ['1d']), + Query::lessThan('time', $retention1d), + Query::orderDesc('time'), + Query::orderDesc(), + ], $dbForLogs); } }