Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-22 08:28:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix multi API event

Browse source
This commit is contained in:
Jake Barnby 2025-10-03 00:12:19 +13:00
parent 5da2ca292a
commit d54058b59a
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/Appwrite/Platform/Modules/Databases/Http/Databases/Transactions/Update.php
View file

@ -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();