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

Update naming

Browse source
This commit is contained in:
Jake Barnby 2025-08-15 00:37:29 +12:00
parent 9838571184
commit dfeadfd50f
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
1 changed files with 17 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
src/Appwrite/Platform/Modules/Databases/Http/Transactions/Update.php
View file

@ -2,6 +2,7 @@
namespace Appwrite\Platform\Modules\Databases\Http\Transactions;
use Appwrite\Event\Delete;
use Appwrite\Extend\Exception;
use Appwrite\Platform\Action;
use Appwrite\SDK\AuthType;
@ -13,6 +14,7 @@ use Utopia\Database\Database;
use Utopia\Database\Document;
use Utopia\Database\Exception\Conflict as ConflictException;
use Utopia\Database\Exception\Duplicate as DuplicateException;
use Utopia\Database\Exception\Transaction as TransactionException;
use Utopia\Database\Helpers\ID;
use Utopia\Database\Query;
use Utopia\Database\Validator\UID;
@ -102,40 +104,37 @@ class Update extends Action
foreach ($operations as $operation) {
$databaseInternalId = $operation['databaseInternalId'];
$collectionInternalId = $operation['collectionInternalId'];
$collectionId = "database_{$databaseInternalId}_collection_{$collectionInternalId}";
$documentId = $operation['documentId'];
$createdAt = new \DateTime($operation['$createdAt']);
$action = $operation['action'];
$data = $operation['data'];
$operationCreatedAt = new \DateTime($operation['$createdAt']);
$collectionName = "database_{$databaseInternalId}_collection_{$collectionInternalId}";
// Wrap each operation with the timestamp from when it was logged
$dbForProject->withRequestTimestamp($operationCreatedAt, function () use ($dbForProject, $action, $collectionName, $documentId, $data) {
$dbForProject->withRequestTimestamp($createdAt, function () use ($dbForProject, $queueForDeletes, $action, $collectionId, $documentId, $data) {
switch ($action) {
case 'create':
$document = new Document([
'$id' => $documentId ?? ID::unique(),
...$data
]);
$dbForProject->createDocument($collectionName, $document);
$document = new Document($data);
$dbForProject->createDocument($collectionId, $document);
break;
case 'update':
$document = new Document($data);
$dbForProject->updateDocument($collectionId, $documentId, $document);
break;
case 'upsert':
$document = new Document([
'$id' => $documentId,
...$data,
]);
$dbForProject->createOrUpdateDocument($collectionName, $document);
$document = new Document($data);
$dbForProject->createOrUpdateDocuments($collectionId, [$document]);
break;
case 'delete':
$dbForProject->deleteDocument($collectionName, $documentId);
$dbForProject->deleteDocument($collectionId, $documentId);
break;
case 'increment':
$dbForProject->increaseDocumentAttribute(
collection: $collectionName,
collection: $collectionId,
id: $documentId,
attribute: $data['attribute'],
value: $data['value'] ?? 1,
@ -145,7 +144,7 @@ class Update extends Action
case 'decrement':
$dbForProject->decreaseDocumentAttribute(
collection: $collectionName,
collection: $collectionId,
id: $documentId,
attribute: $data['attribute'],
value: $data['value'] ?? 1,