deletes-worker

app/cli.php

@@ -3,6 +3,8 @@
 require_once __DIR__ . '/init.php';
 require_once __DIR__ . '/controllers/general.php';
 
+use Appwrite\Event\Certificate;
+use Appwrite\Event\Delete;
 use Appwrite\Event\Func;
 use Appwrite\Platform\Appwrite;
 use Utopia\CLI\CLI;
@@ -144,10 +146,15 @@ CLI::setResource('influxdb', function (Registry $register) {
     return $database;
 }, ['register']);
 
+
 CLI::setResource('queue', function (Group $pools) {
     return $pools->get('queue')->pop()->getResource();
 }, ['pools']);
 
+CLI::setResource('queueForCertificates', function (Connection $queue) {
+    return new Certificate($queue);
+}, ['queue']);
+
 CLI::setResource('queueForDeletes', function (Connection $queue) {
     return new Delete($queue);
 }, ['queue']);

src/Appwrite/Event/Certificate.php

@@ -13,7 +13,7 @@ class Certificate extends Event
 
     public function __construct(protected Connection $connection)
     {
-        parent::__construct(Event::FUNCTIONS_QUEUE_NAME, Event::FUNCTIONS_CLASS_NAME);
+        parent::__construct(Event::CERTIFICATES_QUEUE_NAME, Event::CERTIFICATES_CLASS_NAME);
     }
 
     /**
@@ -71,6 +71,7 @@ class Certificate extends Event
     public function trigger(): string|bool
     {
         $client = new Client($this->queue, $this->connection);
+
         return $client->enqueue([
             'project' => $this->project,
             'domain' => $this->domain,

src/Appwrite/Event/Delete.php

@@ -17,7 +17,7 @@ class Delete extends Event
 
     public function __construct(protected Connection $connection)
     {
-        parent::__construct(Event::DELETE_QUEUE_NAME, Event::DELETE_CLASS_NAME, $connection);
+        parent::__construct(Event::DELETE_QUEUE_NAME, Event::DELETE_CLASS_NAME);
     }
 
     /**
@@ -124,8 +124,6 @@ class Delete extends Event
     {
         $client = new Client($this->queue, $this->connection);
 
-        $events = $this->getEvent() ? Event::generateEvents($this->getEvent(), $this->getParams()) : null;
-
         return $client->enqueue([
             'project' => $this->project,
             'type' => $this->type,