Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-24 09:28:40 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Add order on inequality queries

Browse source
This commit is contained in:
Jake Barnby 2025-03-14 15:29:52 +13:00
parent 49d89a4206
commit 246c8ce939
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
1 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/Appwrite/Platform/Workers/Deletes.php
View file

@ -387,6 +387,7 @@ class Deletes extends Action
$query = [ $query = [
Query::lessThan('accessedAt', $datetime), Query::lessThan('accessedAt', $datetime),
Query::orderDesc('accessedAt')
]; ];
$this->deleteByGroup( $this->deleteByGroup(
@ -420,6 +421,7 @@ class Deletes extends Action
// Delete Usage stats from projectDB // Delete Usage stats from projectDB
$this->deleteByGroup('stats', [ $this->deleteByGroup('stats', [
Query::lessThan('time', $hourlyUsageRetentionDatetime), Query::lessThan('time', $hourlyUsageRetentionDatetime),
Query::orderDesc('time'),
Query::equal('period', ['1h']), Query::equal('period', ['1h']),
], $dbForProject); ], $dbForProject);
@ -430,6 +432,7 @@ class Deletes extends Action
// Delete Usage stats from logsDB // Delete Usage stats from logsDB
$this->deleteByGroup('stats', [ $this->deleteByGroup('stats', [
Query::lessThan('time', $hourlyUsageRetentionDatetime), Query::lessThan('time', $hourlyUsageRetentionDatetime),
Query::orderDesc('time'),
Query::equal('period', ['1h']), Query::equal('period', ['1h']),
], $dbForLogs); ], $dbForLogs);
} }
@ -688,9 +691,11 @@ class Deletes extends Action
private function deleteExecutionLogs(Document $project, callable $getProjectDB, string $datetime): void private function deleteExecutionLogs(Document $project, callable $getProjectDB, string $datetime): void
{ {
$dbForProject = $getProjectDB($project); $dbForProject = $getProjectDB($project);
// Delete Executions // Delete Executions
$this->deleteByGroup('executions', [ $this->deleteByGroup('executions', [
Query::lessThan('$createdAt', $datetime) Query::lessThan('$createdAt', $datetime),
Query::orderDesc('$createdAt'),
], $dbForProject); ], $dbForProject);
} }
@ -708,7 +713,8 @@ class Deletes extends Action
// Delete Sessions // Delete Sessions
$this->deleteByGroup('sessions', [ $this->deleteByGroup('sessions', [
Query::lessThan('$createdAt', $expired) Query::lessThan('$createdAt', $expired),
Query::orderDesc('$createdAt'),
], $dbForProject); ], $dbForProject);
} }
@ -722,7 +728,8 @@ class Deletes extends Action
{ {
// Delete Dead Realtime Logs // Delete Dead Realtime Logs
$this->deleteByGroup('realtime', [ $this->deleteByGroup('realtime', [
Query::lessThan('timestamp', $datetime) Query::lessThan('timestamp', $datetime),
Query::orderDesc('timestamp'),
], $dbForPlatform); ], $dbForPlatform);
} }