Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: Initialize event and payload properties in Event class and optimize bulk document queue triggering

Browse Source
This commit is contained in:
ArnabChatterjee20k
2025-08-05 11:52:58 +05:30
parent 59026a17dc
commit 7334efbf3a
2 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Appwrite/Event/Event.php
+2
View File
@@ -383,6 +383,8 @@ class Event
{
$this->params = [];
$this->sensitive = [];
$this->event = '';
$this->payload = [];
return $this;
}
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Action.php
+9 -7
View File
@@ -295,17 +295,19 @@ abstract class Action extends UtopiaAction
*/
final protected function triggerQueuesForBulkDocuments(string $event, Document $database, Document $collection, array $documents, Event $queueForEvents, Event $queueForRealtime, Event $queueForFunctions, Event $queueForWebhooks)
{
$queueForEvents
->setEvent($event)
->setParam('databaseId', $database->getId())
->setContext('database', $database)
->setParam('collectionId', $collection->getId())
->setParam('tableId', $collection->getId())
->setContext($this->getCollectionsEventsContext(), $collection);
foreach ($documents as $document) {
$queueForEvents
->setEvent($event)
->setParam('databaseId', $database->getId())
->setContext('database', $database)
->setParam('collectionId', $collection->getId())
->setParam('tableId', $collection->getId())
->setParam('documentId', $document->getId())
->setParam('rowId', $document->getId())
->setPayload($document->getArrayCopy())
->setContext($this->getCollectionsEventsContext(), $collection);
->setPayload($document->getArrayCopy());
$queueForRealtime
->from($queueForEvents)