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

refactor: Rename triggerQueuesForBulkDocuments to triggerBulk for consistency across document actions

Browse Source
This commit is contained in:
ArnabChatterjee20k
2025-08-05 13:29:38 +05:30
parent a144d41020
commit 5baa2ad113
7 changed files with 21 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Action.php
+10 -2
View File
@@ -293,8 +293,16 @@ abstract class Action extends UtopiaAction
* @param Event $queueForWebhooks
* @return void
*/
final protected function triggerQueuesForBulkDocuments(string $event, Document $database, Document $collection, array $documents, Event $queueForEvents, Event $queueForRealtime, Event $queueForFunctions, Event $queueForWebhooks)
{
protected function triggerBulk(
string $event,
Document $database,
Document $collection,
array $documents,
Event $queueForEvents,
Event $queueForRealtime,
Event $queueForFunctions,
Event $queueForWebhooks
): void {
$queueForEvents
->setEvent($event)
->setParam('databaseId', $database->getId())
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Bulk/Delete.php
+3 -3
View File
@@ -73,15 +73,15 @@ class Delete extends Action
->inject('response')
->inject('dbForProject')
->inject('queueForStatsUsage')
->inject('plan')
->inject('queueForEvents')
->inject('queueForRealtime')
->inject('queueForFunctions')
->inject('queueForWebhooks')
->inject('plan')
->callback($this->action(...));
}
public function action(string $databaseId, string $collectionId, array $queries, UtopiaResponse $response, Database $dbForProject, StatsUsage $queueForStatsUsage, array $plan, Event $queueForEvents, Event $queueForRealtime, Event $queueForFunctions, Event $queueForWebhooks): void
public function action(string $databaseId, string $collectionId, array $queries, UtopiaResponse $response, Database $dbForProject, StatsUsage $queueForStatsUsage, Event $queueForEvents, Event $queueForRealtime, Event $queueForFunctions, Event $queueForWebhooks, array $plan): void
{
$database = $dbForProject->getDocument('databases', $databaseId);
if ($database->isEmpty()) {
@@ -140,7 +140,7 @@ class Delete extends Action
$this->getSdkGroup() => $documents,
]), $this->getResponseModel());
$this->triggerQueuesForBulkDocuments(
$this->triggerBulk(
'databases.[databaseId].collections.[collectionId].documents.[documentId].delete',
$database,
$collection,
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Bulk/Update.php
+3 -3
View File
@@ -77,15 +77,15 @@ class Update extends Action
->inject('response')
->inject('dbForProject')
->inject('queueForStatsUsage')
->inject('plan')
->inject('queueForEvents')
->inject('queueForRealtime')
->inject('queueForFunctions')
->inject('queueForWebhooks')
->inject('plan')
->callback($this->action(...));
}
public function action(string $databaseId, string $collectionId, string|array $data, array $queries, UtopiaResponse $response, Database $dbForProject, StatsUsage $queueForStatsUsage, array $plan, Event $queueForEvents, Event $queueForRealtime, Event $queueForFunctions, Event $queueForWebhooks): void
public function action(string $databaseId, string $collectionId, string|array $data, array $queries, UtopiaResponse $response, Database $dbForProject, StatsUsage $queueForStatsUsage, Event $queueForEvents, Event $queueForRealtime, Event $queueForFunctions, Event $queueForWebhooks, array $plan): void
{
$data = \is_string($data)
? \json_decode($data, true)
@@ -164,7 +164,7 @@ class Update extends Action
$this->getSdkGroup() => $documents
]), $this->getResponseModel());
$this->triggerQueuesForBulkDocuments(
$this->triggerBulk(
'databases.[databaseId].collections.[collectionId].documents.[documentId].update',
$database,
$collection,
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Create.php
+1 -1
View File
@@ -419,7 +419,7 @@ class Create extends Action
$this->getSdkGroup() => $documents
]), $this->getBulkResponseModel());
$this->triggerQueuesForBulkDocuments(
$this->triggerBulk(
'databases.[databaseId].collections.[collectionId].documents.[documentId].create',
$database,
$collection,
src/Appwrite/Platform/Modules/Databases/Http/Grids/Tables/Rows/Bulk/Delete.php
+1 -1
View File
@@ -59,11 +59,11 @@ class Delete extends DocumentsDelete
->inject('response')
->inject('dbForProject')
->inject('queueForStatsUsage')
->inject('plan')
->inject('queueForEvents')
->inject('queueForRealtime')
->inject('queueForFunctions')
->inject('queueForWebhooks')
->inject('plan')
->callback($this->action(...));
}
}
src/Appwrite/Platform/Modules/Databases/Http/Grids/Tables/Rows/Bulk/Update.php
+1 -1
View File
@@ -61,11 +61,11 @@ class Update extends DocumentsUpdate
->inject('response')
->inject('dbForProject')
->inject('queueForStatsUsage')
->inject('plan')
->inject('queueForEvents')
->inject('queueForRealtime')
->inject('queueForFunctions')
->inject('queueForWebhooks')
->inject('plan')
->callback($this->action(...));
}
}
tests/e2e/Scopes/Scope.php
+2 -2
View File
@@ -182,9 +182,9 @@ abstract class Scope extends TestCase
/**
* @return array
*/
public function getUser(bool $override = false): array
public function getUser(bool $fresh = false): array
{
if (!$override && isset(self::$user[$this->getProject()['$id']])) {
if (!$fresh && isset(self::$user[$this->getProject()['$id']])) {
return self::$user[$this->getProject()['$id']];
}