patch: review comments

app/controllers/api/health.php

@@ -5,6 +5,7 @@ use Utopia\Exception;
 use Appwrite\Storage\Device\Local;
 use Appwrite\Storage\Storage;
 use Appwrite\ClamAV\Network;
+use Appwrite\Event\Event;
 
 App::get('/v1/health')
     ->desc('Get HTTP')
@@ -122,7 +123,7 @@ App::get('/v1/health/queue/webhooks')
     ->action(function ($response) {
         /** @var Appwrite\Utopia\Response $response */
 
-        $response->json(['size' => Resque::size('v1-webhooks')]);
+        $response->json(['size' => Resque::size(Event::WEBHOOK_QUEUE_NAME)]);
     }, ['response']);
 
 App::get('/v1/health/queue/tasks')
@@ -136,7 +137,7 @@ App::get('/v1/health/queue/tasks')
     ->action(function ($response) {
         /** @var Appwrite\Utopia\Response $response */
 
-        $response->json(['size' => Resque::size('v1-tasks')]);
+        $response->json(['size' => Resque::size(Event::TASK_QUEUE_NAME)]);
     }, ['response']);
 
 App::get('/v1/health/queue/logs')
@@ -150,7 +151,7 @@ App::get('/v1/health/queue/logs')
     ->action(function ($response) {
         /** @var Appwrite\Utopia\Response $response */
 
-        $response->json(['size' => Resque::size('v1-audit')]);
+        $response->json(['size' => Resque::size(Event::AUDITS_QUEUE_NAME)]);
     }, ['response']);
 
 App::get('/v1/health/queue/usage')
@@ -178,7 +179,7 @@ App::get('/v1/health/queue/certificates')
     ->action(function ($response) {
         /** @var Appwrite\Utopia\Response $response */
 
-        $response->json(['size' => Resque::size('v1-certificates')]);
+        $response->json(['size' => Resque::size(Event::CERTIFICATES_QUEUE_NAME)]);
     }, ['response']);
 
 App::get('/v1/health/queue/functions')
@@ -192,7 +193,7 @@ App::get('/v1/health/queue/functions')
     ->action(function ($response) {
         /** @var Appwrite\Utopia\Response $response */
 
-        $response->json(['size' => Resque::size('v1-functions')]);
+        $response->json(['size' => Resque::size(Event::FUNCTIONS_QUEUE_NAME)]);
     }, ['response']);
 
 App::get('/v1/health/storage/local')

app/init.php

@@ -55,7 +55,7 @@ const APP_SOCIAL_DEV = 'https://dev.to/appwrite';
 const APP_SOCIAL_STACKSHARE = 'https://stackshare.io/appwrite'; 
 // Deletion Types
 const DELETE_TYPE_DOCUMENT = 'document';
-const DELETE_TYPE_EXECUTION = 'execution';
+const DELETE_TYPE_EXECUTIONS = 'executions';
 const DELETE_TYPE_AUDIT = 'audit';
 const DELETE_TYPE_ABUSE = 'abuse';
 

app/tasks/maintenance.php

@@ -25,7 +25,7 @@ function getConsoleDB() {
 function notifyDeleteExecutionLogs()
 {
     Resque::enqueue(Event::DELETE_QUEUE_NAME, Event::DELETE_CLASS_NAME, [
-        'type' => DELETE_TYPE_EXECUTION
+        'type' => DELETE_TYPE_EXECUTIONS
     ]);
 }
 

app/workers/deletes.php

@@ -58,7 +58,7 @@ class DeletesV1
                 }
                 break;
 
-            case DELETE_TYPE_EXECUTION:
+            case DELETE_TYPE_EXECUTIONS:
                 $this->deleteExecutionLogs();
                 break;
 

src/Appwrite/Event/Event.php

@@ -18,6 +18,19 @@ class Event
 
     const MAILS_QUEUE_NAME = 'v1-mails';
     const MAILS_CLASS_NAME = 'MailsV1';
+
+    const FUNCTIONS_QUEUE_NAME = 'v1-functions';
+    const FUNCTIONS_CLASS_NAME = 'FunctionsV1';
+
+    const WEBHOOK_QUEUE_NAME = 'v1-webhooks';
+    const WEBHOOK_CLASS_NAME = 'WebhooksV1';
+
+    const TASK_QUEUE_NAME = 'v1-tasks';
+    const TASK_CLASS_NAME = 'TasksV1';
+
+    const CERTIFICATES_QUEUE_NAME = 'v1-certificates';
+    const CERTIFICATES_CLASS_NAME = 'CertificatesV1';
+    
     
     /**
      * @var string