From 0ddcb9b14c9a07a647a5eb3e5bf95f41b3e2b891 Mon Sep 17 00:00:00 2001
From: Chirag Aggarwal <chiragaggarwal5k@gmail.com>
Date: Wed, 26 Feb 2025 16:24:05 +0000
Subject: [PATCH] chore: refactor adapter

---
 src/Appwrite/Event/Realtime.php | 42 ++++++++++++---------------------
 1 file changed, 15 insertions(+), 27 deletions(-)

diff --git a/src/Appwrite/Event/Realtime.php b/src/Appwrite/Event/Realtime.php
index e04bbfffb4..e7a61ea545 100644
--- a/src/Appwrite/Event/Realtime.php
+++ b/src/Appwrite/Event/Realtime.php
@@ -82,33 +82,21 @@ class Realtime extends Event
             bucket: $bucket,
         );
 
-        if (!empty($this->getTargets())) {
-            foreach ($this->getTargets() as $targetProjectId) {
-                RealtimeAdapter::send(
-                    projectId: $targetProjectId,
-                    payload: $this->getRealtimePayload(),
-                    events: $allEvents,
-                    channels: $target['channels'],
-                    roles: $target['roles'],
-                    options: [
-                        'permissionsChanged' => $target['permissionsChanged'],
-                        'userId' => $this->getParam('userId')
-                    ]
-                );
-            }
-        } else {
-            RealtimeAdapter::send(
-                projectId: $target['projectId'] ?? $this->getProject()->getId(),
-                payload: $this->getRealtimePayload(),
-                events: $allEvents,
-                channels: $target['channels'],
-                roles: $target['roles'],
-                options: [
-                    'permissionsChanged' => $target['permissionsChanged'],
-                    'userId' => $this->getParam('userId')
-                ]
-            );
-        }
+        $projectIds = !empty($this->getTargets())
+            ? $this->getTargets()
+            : [$target['projectId'] ?? $this->getProject()->getId()];
+
+        RealtimeAdapter::send(
+            projectId: $projectIds,
+            payload: $this->getRealtimePayload(),
+            events: $allEvents,
+            channels: $target['channels'],
+            roles: $target['roles'],
+            options: [
+                'permissionsChanged' => $target['permissionsChanged'],
+                'userId' => $this->getParam('userId')
+            ]
+        );
 
         return true;
     }