From e236aac0ea4388e61e30e9c65af4a87c6f7b5d07 Mon Sep 17 00:00:00 2001 From: Darshan Date: Tue, 17 Jun 2025 09:57:35 +0530 Subject: [PATCH] =?UTF-8?q?fix:=20events=20logic=20=F0=9F=98=AE=E2=80=8D?= =?UTF-8?q?=F0=9F=92=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Http/Databases/Collections/Documents/Create.php | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Create.php b/src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Create.php index e68a27ba34..6005495a68 100644 --- a/src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Create.php +++ b/src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Create.php @@ -56,7 +56,6 @@ class Create extends Action ->setHttpPath('/v1/databases/:databaseId/collections/:collectionId/documents') ->desc('Create document') ->groups(['api', 'database']) - ->label('event', 'databases.[databaseId].collections.[collectionId].documents.[documentId].create') ->label('scope', 'documents.write') ->label('resourceType', RESOURCE_TYPE_DATABASES) ->label('audits.event', 'document.create') @@ -418,12 +417,6 @@ class Create extends Action $response->setStatusCode(SwooleResponse::STATUS_CODE_CREATED); - // BIG TODO: @itznotabug - need to check what to do for bulk api because there's not just one `[document/rowId]`. - $queueForEvents - ->setParam('documentId', $documents[0]->getId()) - ->setParam('rowId', $documents[0]->getId()) - // TODO: @itznotabug - check if the events mirroring works here! - ->setEvent('databases.[databaseId].collections.[collectionId].documents.[documentId].create'); if ($isBulk) { $response->dynamic(new Document([ @@ -434,6 +427,11 @@ class Create extends Action return; } + $queueForEvents + ->setParam('documentId', $documents[0]->getId()) + ->setParam('rowId', $documents[0]->getId()) + ->setEvent('databases.[databaseId].collections.[collectionId].documents.[documentId].create'); + $response->dynamic( $documents[0], $this->getResponseModel()