fix: events logic 😮‍💨

This commit is contained in:
Darshan
2025-06-17 09:57:35 +05:30
parent 8d74083da3
commit e236aac0ea
@@ -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()