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

Check convert

Browse source
This commit is contained in:
Jake Barnby 2025-10-02 22:24:54 +13:00
parent f667149556
commit 473be9284d
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
1 changed files with 12 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -544,9 +544,14 @@ class Update extends Action
array &$state
): void {
$dbForProject->withRequestTimestamp($createdAt, function () use ($dbForProject, $collectionId, $data, &$state) {
// Convert data arrays to Document objects if needed
$documents = \array_map(function ($doc) {
return $doc instanceof Document ? $doc : new Document($doc);
}, $data);
$dbForProject->createDocuments(
$collectionId,
\array_map(fn($doc) => new Document($doc), $data),
$documents,
onNext: function (Document $document) use (&$state, $collectionId) {
$state[$collectionId][$document->getId()] = $document;
}
@ -601,10 +606,15 @@ class Update extends Action
\DateTime $createdAt,
array &$state
): void {
// Convert data arrays to Document objects if needed
$documents = \array_map(function ($doc) {
return $doc instanceof Document ? $doc : new Document($doc);
}, $data);
// Run bulk upsert without timestamp wrapper, checking manually in callback
$dbForProject->upsertDocuments(
$collectionId,
\array_map(fn($doc) => new Document($doc), $data),
$documents,
onNext: function (Document $upserted, ?Document $old) use (&$state, $collectionId, $createdAt) {
if ($old !== null) {
// This is an update - check if document was created/modified in this transaction