From b5379f0f0cf0790ac6105045e412ef14117c21fa Mon Sep 17 00:00:00 2001
From: Damodar Lohani <dlohani48@gmail.com>
Date: Wed, 26 Apr 2023 08:37:38 +0000
Subject: [PATCH] feature to pause events

---
 src/Appwrite/Event/Event.php | 23 +++++++++++++++++++++++
 src/Appwrite/Event/Func.php  |  5 +++++
 2 files changed, 28 insertions(+)

diff --git a/src/Appwrite/Event/Event.php b/src/Appwrite/Event/Event.php
index 0fecbe0304..c4857c801e 100644
--- a/src/Appwrite/Event/Event.php
+++ b/src/Appwrite/Event/Event.php
@@ -46,6 +46,7 @@ class Event
     protected array $context = [];
     protected ?Document $project = null;
     protected ?Document $user = null;
+    protected bool $paused = false;
 
     /**
      * @param string $queue
@@ -263,6 +264,10 @@ class Event
      */
     public function trigger(): string|bool
     {
+        if($this->paused) {
+            return;
+        }
+
         return Resque::enqueue($this->queue, $this->class, [
             'project' => $this->project,
             'user' => $this->user,
@@ -468,4 +473,22 @@ class Event
          */
         return \array_values($events);
     }
+
+    /**
+     * Get the value of paused
+     */
+    public function isPaused(): bool
+    {
+        return $this->paused;
+    }
+
+    /**
+     * Set the value of paused
+     */
+    public function setPaused(bool $paused): self
+    {
+        $this->paused = $paused;
+
+        return $this;
+    }
 }
diff --git a/src/Appwrite/Event/Func.php b/src/Appwrite/Event/Func.php
index 5f8b4c80c6..1b182463c2 100644
--- a/src/Appwrite/Event/Func.php
+++ b/src/Appwrite/Event/Func.php
@@ -142,6 +142,10 @@ class Func extends Event
      */
     public function trigger(): string|bool
     {
+        if($this->paused) {
+            return;
+        }
+
         $client = new Client($this->queue, $this->connection);
 
         $events = $this->getEvent() ? Event::generateEvents($this->getEvent(), $this->getParams()) : null;
@@ -174,6 +178,7 @@ class Func extends Event
         $this->payload = $event->getPayload();
         $this->event = $event->getEvent();
         $this->params = $event->getParams();
+        $this->paused = $event->isPaused();
         return $this;
     }
 }