deletes-worker

app/init.php

@@ -41,7 +41,6 @@ use Appwrite\URL\URL as AppwriteURL;
 use Appwrite\Usage\Stats;
 use Utopia\App;
 use Utopia\Queue\Client;
-use Utopia\Queue\Server;
 use Utopia\Validator\Range;
 use Utopia\Validator\WhiteList;
 use Utopia\Database\ID;
@@ -860,6 +859,9 @@ App::setResource('messaging', fn() => new Phone());
 App::setResource('queue', function (Group $pools) {
     return $pools->get('queue')->pop()->getResource();
 }, ['pools']);
+App::setResource('queueForDeletes', function (Connection $queue) {
+    return new Delete($queue);
+}, ['queue']);
 App::setResource('queueForFunctions', function (Connection $queue) {
     return new Func($queue);
 }, ['queue']);

docker-compose.yml

@@ -392,6 +392,7 @@ services:
       - _APP_LOGGING_CONFIG
       - _APP_EXECUTOR_SECRET
       - _APP_EXECUTOR_HOST
+      - _APP_REGION
 
   appwrite-worker-databases:
     entrypoint: worker-databases
@@ -505,6 +506,7 @@ services:
       - _APP_CONNECTIONS_QUEUE
       - _APP_LOGGING_PROVIDER
       - _APP_LOGGING_CONFIG
+      - _APP_REGION
 
   appwrite-worker-functions:
     entrypoint: worker-functions
@@ -637,9 +639,10 @@ services:
       - _APP_REDIS_PORT
       - _APP_REDIS_USER
       - _APP_REDIS_PASS
-      - _APP_CONNECTIONS_DB_CONSOLE
       - _APP_CONNECTIONS_DB_PROJECT
+      - _APP_CONNECTIONS_DB_CONSOLE
       - _APP_CONNECTIONS_CACHE
+      - _APP_CONNECTIONS_QUEUE
       - _APP_MAINTENANCE_INTERVAL
       - _APP_MAINTENANCE_RETENTION_EXECUTION
       - _APP_MAINTENANCE_RETENTION_CACHE

src/Appwrite/Platform/Tasks/EdgeSync.php

@@ -83,7 +83,7 @@ class EdgeSync extends Action
                             ]);
                     }
                 }
-                if (!$found) {
+              if (!$found) {
                     Console::info("[{$time}] No  keys where found for  region {$code}.");
                 }
             }

src/Appwrite/Platform/Tasks/Maintenance.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Appwrite\Platform\Tasks;
 
 use Appwrite\Event\Certificate;
@@ -130,6 +131,7 @@ class Maintenance extends Action
         $auditLogRetention = (int) App::getEnv('_APP_MAINTENANCE_RETENTION_AUDIT', '1209600');
         $abuseLogsRetention = (int) App::getEnv('_APP_MAINTENANCE_RETENTION_ABUSE', '86400');
         $usageStatsRetentionHourly = (int) App::getEnv('_APP_MAINTENANCE_RETENTION_USAGE_HOURLY', '8640000'); //100 days
+
         $cacheRetention = (int) App::getEnv('_APP_MAINTENANCE_RETENTION_CACHE', '2592000'); // 30 days
         $schedulesDeletionRetention = (int) App::getEnv('_APP_MAINTENANCE_RETENTION_SCHEDULES', '86400'); // 1 Day
 
@@ -148,4 +150,4 @@ class Maintenance extends Action
             notifyDeleteSchedules($schedulesDeletionRetention, $queueForDeletes);
         }, $interval);
     }
-}
+}