From d54058b59ade2721520beda1d8b809d2d36a7a29 Mon Sep 17 00:00:00 2001 From: Jake Barnby Date: Fri, 3 Oct 2025 00:12:19 +1300 Subject: [PATCH] Fix multi API event --- .../Databases/Http/Databases/Transactions/Update.php | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/src/Appwrite/Platform/Modules/Databases/Http/Databases/Transactions/Update.php b/src/Appwrite/Platform/Modules/Databases/Http/Databases/Transactions/Update.php index 2513c09c64..37642a0cca 100644 --- a/src/Appwrite/Platform/Modules/Databases/Http/Databases/Transactions/Update.php +++ b/src/Appwrite/Platform/Modules/Databases/Http/Databases/Transactions/Update.php @@ -266,12 +266,18 @@ class Update extends Action Query::equal('$sequence', [$collectionInternalId]) ]); + $groupId = $this->getGroupId(); + $resourceId = $this->getResourceId(); + $contextKey = $this->getContext(); + $resource = $this->getResource(); + $resourcePlural = $resource . 's'; + $queueForEvents ->setParam('databaseId', $database->getId()) ->setContext('database', $database) ->setParam('collectionId', $collection->getId()) ->setParam('tableId', $collection->getId()) - ->setContext('collection', $collection); + ->setContext($contextKey, $collection); $eventAction = ''; $documents = []; @@ -308,7 +314,7 @@ class Update extends Action $queueForEvents ->setParam('documentId', $docId) ->setParam('rowId', $docId) - ->setEvent('databases.[databaseId].collections.[collectionId].documents.[documentId].' . $eventAction); + ->setEvent("databases.[databaseId].{$contextKey}s.[{$groupId}].{$resourcePlural}.[{$resourceId}]." . $eventAction); $queueForRealtime->from($queueForEvents)->trigger(); $queueForFunctions->from($queueForEvents)->trigger();