Merge branch '1.6.x' of https://github.com/appwrite/appwrite into feat-custom-cf-hostnames

src/Appwrite/Event/Audit.php

@@ -121,6 +121,10 @@ class Audit extends Event
      */
     public function trigger(): string|bool
     {
+        if ($this->paused) {
+            return false;
+        }
+
         $client = new Client($this->queue, $this->connection);
 
         return $client->enqueue([

src/Appwrite/Event/Build.php

@@ -112,6 +112,10 @@ class Build extends Event
      */
     public function trigger(): string|bool
     {
+        if ($this->paused) {
+            return false;
+        }
+
         $client = new Client($this->queue, $this->connection);
 
         return $client->enqueue([

src/Appwrite/Event/Certificate.php

@@ -74,6 +74,10 @@ class Certificate extends Event
      */
     public function trigger(): string|bool
     {
+        if ($this->paused) {
+            return false;
+        }
+
         $client = new Client($this->queue, $this->connection);
 
         return $client->enqueue([

src/Appwrite/Event/Database.php

@@ -108,6 +108,10 @@ class Database extends Event
      */
     public function trigger(): string|bool
     {
+        if ($this->paused) {
+            return false;
+        }
+
         try {
             $dsn = new DSN($this->getProject()->getAttribute('database'));
         } catch (\InvalidArgumentException) {

src/Appwrite/Event/Delete.php

@@ -140,6 +140,10 @@ class Delete extends Event
      */
     public function trigger(): string|bool
     {
+        if ($this->paused) {
+            return false;
+        }
+
         $client = new Client($this->queue, $this->connection);
 
         return $client->enqueue([

src/Appwrite/Event/Event.php

@@ -65,6 +65,24 @@ class Event
     {
     }
 
+    /**
+     * Set paused state for this event.
+     */
+    public function setPaused(bool $paused): self
+    {
+        $this->paused = $paused;
+
+        return $this;
+    }
+
+    /**
+     * Get paused state for this event.
+     */
+    public function getPaused(): bool
+    {
+        return $this->paused;
+    }
+
     /**
      * Set queue used for this event.
      *
@@ -302,6 +320,10 @@ class Event
      */
     public function trigger(): string|bool
     {
+        if ($this->paused) {
+            return false;
+        }
+
         $client = new Client($this->queue, $this->connection);
 
         return $client->enqueue([

src/Appwrite/Event/Func.php

@@ -213,6 +213,10 @@ class Func extends Event
      */
     public function trigger(): string|bool
     {
+        if ($this->paused) {
+            return false;
+        }
+
         $client = new Client($this->queue, $this->connection);
 
         $events = $this->getEvent() ? Event::generateEvents($this->getEvent(), $this->getParams()) : null;

src/Appwrite/Event/Mail.php

@@ -404,6 +404,10 @@ class Mail extends Event
      */
     public function trigger(): string|bool
     {
+        if ($this->paused) {
+            return false;
+        }
+
         $client = new Client($this->queue, $this->connection);
 
         return $client->enqueue([

src/Appwrite/Event/Messaging.php

@@ -182,6 +182,10 @@ class Messaging extends Event
      */
     public function trigger(): string | bool
     {
+        if ($this->paused) {
+            return false;
+        }
+
         $client = new Client($this->queue, $this->connection);
 
         return $client->enqueue([

src/Appwrite/Event/Migration.php

@@ -75,6 +75,9 @@ class Migration extends Event
      */
     public function trigger(): string|bool
     {
+        if ($this->paused) {
+            return false;
+        }
 
         $client = new Client($this->queue, $this->connection);
 

src/Appwrite/Event/Realtime.php

@@ -32,7 +32,7 @@ class Realtime extends Event
      */
     public function trigger(): string|bool
     {
-        if (empty($this->event)) {
+        if ($this->paused || empty($this->event)) {
             return false;
         }
 

src/Appwrite/Event/Usage.php

@@ -57,6 +57,10 @@ class Usage extends Event
      */
     public function trigger(): string|bool
     {
+        if ($this->paused) {
+            return false;
+        }
+
         $client = new Client($this->queue, $this->connection);
         return $client->enqueue([
             'project' => $this->getProject(),

src/Appwrite/Event/UsageDump.php

@@ -38,6 +38,10 @@ class UsageDump extends Event
      */
     public function trigger(): string|bool
     {
+        if ($this->paused) {
+            return false;
+        }
+
         $client = new Client($this->queue, $this->connection);
 
         return $client->enqueue([