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

Fix bulk payloads

Browse source
This commit is contained in:
Jake Barnby 2025-09-04 20:32:37 +12:00
parent 5702def9d2
commit 7eba6582c6
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
1 changed files with 7 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -223,10 +223,9 @@ class Update extends Action
case 'bulkCreate':
$dbForProject->createDocuments(
$collectionId,
array_map(fn ($data) => new Document($data), $data),
$data,
onNext: function (Document $document) use (&$state, $collectionId) {
$state[$collectionId][$document->getId()] = $document;
}
);
break;
@ -234,7 +233,7 @@ class Update extends Action
case 'bulkUpdate':
$dbForProject->updateDocuments(
$collectionId,
$data['data'] ?? null,
new Document($data['data']),
Query::parseQueries($data['queries'] ?? [])
);
break;
@ -242,10 +241,9 @@ class Update extends Action
case 'bulkUpsert':
$dbForProject->createOrUpdateDocuments(
$collectionId,
array_map(fn ($data) => new Document($data), $data),
$data,
onNext: function (Document $document) use (&$state, $collectionId) {
$state[$collectionId][$document->getId()] = $document;
}
);
break;
@ -272,16 +270,16 @@ class Update extends Action
->setType(DELETE_TYPE_DOCUMENT)
->setDocument($transaction);
} catch (NotFoundException) {
} catch (NotFoundException $e) {
$dbForProject->updateDocument('transactions', $transactionId, new Document([
'status' => 'failed',
]));
throw new Exception(Exception::DOCUMENT_NOT_FOUND);
} catch (DuplicateException|ConflictException) {
throw new Exception(Exception::DOCUMENT_NOT_FOUND, previous: $e);
} catch (DuplicateException|ConflictException $e) {
$dbForProject->updateDocument('transactions', $transactionId, new Document([
'status' => 'failed',
]));
throw new Exception(Exception::TRANSACTION_CONFLICT);
throw new Exception(Exception::TRANSACTION_CONFLICT, previous: $e);
} catch (TransactionException $e) {
$dbForProject->updateDocument('transactions', $transactionId, new Document([
'status' => 'failed',