From ff95532ccb7369fc182af8f26c35dcb62906d498 Mon Sep 17 00:00:00 2001
From: loks0n <22452787+loks0n@users.noreply.github.com>
Date: Fri, 1 Nov 2024 16:29:34 +0000
Subject: [PATCH] chore: refactor

---
 app/controllers/shared/api.php | 22 +++++++---------------
 1 file changed, 7 insertions(+), 15 deletions(-)

diff --git a/app/controllers/shared/api.php b/app/controllers/shared/api.php
index 392fc85cf5..043c346587 100644
--- a/app/controllers/shared/api.php
+++ b/app/controllers/shared/api.php
@@ -59,21 +59,15 @@ $parseLabel = function (string $label, array $responsePayload, array $requestPar
 };
 
 $eventDatabaseListener = function (Document $document, Event $queueForEvents, Response $response, Func $queueForFunctions, Document $project) {
-    switch ($document->getCollection()) {
-        case 'users':
-            $queueForEvents
-                ->setEvent('users.[userId].update')
-                ->setParam('userId', $document->getId())
-                ->setPayload($response->output($document, Response::MODEL_USER))
-                ->trigger();
-            break;
-    }
-
-    // FIXME: This is a temporary solution, this should be moved to the shutdown hook
-    if (empty($queueForEvents->getEvent())) {
+    if (!$document->getCollection() === 'users') {
         return;
     }
 
+    $queueForEvents
+        ->setEvent('users.[userId].update')
+        ->setParam('userId', $document->getId())
+        ->setPayload($response->output($document, Response::MODEL_USER));
+
     // Trigger functions
     $queueForFunctions
         ->from($queueForEvents)
@@ -85,9 +79,7 @@ $eventDatabaseListener = function (Document $document, Event $queueForEvents, Re
         ->setQueue(Event::WEBHOOK_QUEUE_NAME)
         ->trigger();
 
-    /**
-     * Trigger realtime.
-     */
+    // Trigger realtime
     if ($project->getId() !== 'console') {
         $allEvents = Event::generateEvents($queueForEvents->getEvent(), $queueForEvents->getParams());
         $payload = new Document($queueForEvents->getPayload());