Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-23 00:49:02 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

update: simplify setting events context param.

Browse source
This commit is contained in:
Darshan 2025-05-10 10:34:44 +05:30
parent 5022a052ce
commit fbe2609f7b
9 changed files with 50 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Attributes/Action.php
View file

@ -204,6 +204,14 @@ abstract class Action extends UtopiaAction
: Exception::COLUMN_NOT_AVAILABLE;
}
/**
* Get the correct collections context for Events queue.
*/
final protected function getCollectionsEventsContext(): string
{
return $this->isCollectionsAPI() ? 'collection' : 'table';
}
/**
* Get the proper column/attribute type based on set context.
*/
@ -407,11 +415,11 @@ abstract class Action extends UtopiaAction
$queueForEvents
->setContext('database', $db)
->setParam('databaseId', $databaseId)
->setParam('collectionId', $collection->getId())
->setParam('tableId', $collection->getId())
->setParam('attributeId', $attribute->getId())
->setParam('columnId', $attribute->getId())
->setParam('tableId', $collection->getId())
->setParam('collectionId', $collection->getId())
->setContext($this->isCollectionsAPI() ? 'collection' : 'table', $collection);
->setContext($this->getCollectionsEventsContext(), $collection);
$response->setStatusCode(SwooleResponse::STATUS_CODE_CREATED);
@ -608,11 +616,11 @@ abstract class Action extends UtopiaAction
$queueForEvents
->setContext('database', $db)
->setParam('databaseId', $databaseId)
->setParam('collectionId', $collection->getId())
->setParam('tableId', $collection->getId())
->setParam('attributeId', $attribute->getId())
->setParam('columnId', $attribute->getId())
->setParam('tableId', $collection->getId())
->setParam('collectionId', $collection->getId())
->setContext($this->isCollectionsAPI() ? 'collection' : 'table', $collection);
->setContext($this->getCollectionsEventsContext(), $collection);
return $attribute;
}

9
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Attributes/Delete.php
View file

@ -145,13 +145,12 @@ class Delete extends Action
$queueForEvents
->setContext('database', $db)
->setParam('databaseId', $databaseId)
->setPayload($response->output($attribute, $model))
->setParam('attributeId', $attribute->getId())
->setParam('columnId', $attribute->getId())
->setParam('collectionId', $collection->getId())
->setParam('tableId', $collection->getId())
// set proper context
->setContext($this->isCollectionsAPI() ? 'collection' : 'table', $collection);
->setParam('attributeId', $attribute->getId())
->setParam('columnId', $attribute->getId())
->setPayload($response->output($attribute, $model))
->setContext($this->getCollectionsEventsContext(), $collection);
$response->noContent();
}

8
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Action.php
View file

@ -127,4 +127,12 @@ abstract class Action extends UtopiaAction
? Exception::DOCUMENT_MISSING_PAYLOAD
: Exception::ROW_MISSING_PAYLOAD;
}
/**
* Get the correct collections context for Events queue.
*/
final protected function getCollectionsEventsContext(): string
{
return $this->isCollectionsAPI() ? 'collection' : 'table';
}
}

8
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Create.php
View file

@ -309,11 +309,11 @@ class Create extends Action
$queueForEvents
->setParam('databaseId', $databaseId)
->setContext('database', $database)
->setParam('rowId', $document->getId())
->setParam('documentId', $document->getId())
->setParam('tableId', $collection->getId())
->setParam('collectionId', $collection->getId())
->setParam('tableId', $collection->getId())
->setParam('documentId', $document->getId())
->setParam('rowId', $document->getId())
->setPayload($response->getPayload(), sensitive: $relationships)
->setContext($this->isCollectionsAPI() ? 'collection' : 'table', $collection);
->setContext($this->getCollectionsEventsContext(), $collection);
}
}

8
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Delete.php
View file

@ -164,11 +164,11 @@ class Delete extends Action
$queueForEvents
->setParam('databaseId', $databaseId)
->setContext('database', $database)
->setParam('rowId', $document->getId())
->setParam('documentId', $document->getId())
->setParam('tableId', $collection->getId())
->setParam('collectionId', $collection->getId())
->setContext($this->isCollectionsAPI() ? 'collection' : 'table', $collection)
->setParam('tableId', $collection->getId())
->setParam('documentId', $document->getId())
->setParam('rowId', $document->getId())
->setContext($this->getCollectionsEventsContext(), $collection)
->setPayload($response->output($document, $this->getResponseModel()), sensitive: $relationships);
$response->noContent();

8
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Update.php
View file

@ -297,11 +297,11 @@ class Update extends Action
$queueForEvents
->setParam('databaseId', $databaseId)
->setContext('database', $database)
->setParam('rowId', $document->getId())
->setParam('documentId', $document->getId())
->setParam('tableId', $collection->getId())
->setParam('collectionId', $collection->getId())
->setContext($this->isCollectionsAPI() ? 'collection' : 'table', $collection)
->setParam('tableId', $collection->getId())
->setParam('documentId', $document->getId())
->setParam('rowId', $document->getId())
->setContext($this->getCollectionsEventsContext(), $collection)
->setPayload($response->getPayload(), sensitive: $relationships);
}
}

8
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Indexes/Action.php
View file

@ -152,4 +152,12 @@ abstract class Action extends UtopiaAction
? Exception::ATTRIBUTE_NOT_AVAILABLE
: Exception::COLUMN_NOT_AVAILABLE;
}
/**
* Get the correct collections context for Events queue.
*/
final protected function getCollectionsEventsContext(): string
{
return $this->isCollectionsAPI() ? 'collection' : 'table';
}
}

4
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Indexes/Create.php
View file

@ -221,9 +221,9 @@ class Create extends Action
->setContext('database', $db)
->setParam('databaseId', $databaseId)
->setParam('indexId', $index->getId())
->setParam('tableId', $collection->getId())
->setParam('collectionId', $collection->getId())
->setContext($this->isCollectionsAPI() ? 'collection' : 'table', $collection);
->setParam('tableId', $collection->getId())
->setContext($this->getCollectionsEventsContext(), $collection);
$response
->setStatusCode(SwooleResponse::STATUS_CODE_ACCEPTED)

4
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Indexes/Delete.php
View file

@ -118,8 +118,8 @@ class Delete extends Action
->setParam('indexId', $index->getId())
->setParam('tableId', $collection->getId())
->setParam('collectionId', $collection->getId())
->setPayload($response->output($index, $this->getResponseModel()))
->setContext($this->isCollectionsAPI() ? 'collection' : 'table', $collection);
->setContext($this->getCollectionsEventsContext(), $collection)
->setPayload($response->output($index, $this->getResponseModel()));
$response->noContent();
}