updated createdocuments

Author: ArnabChatterjee20k

src/Database/Database.php

@@ -3986,6 +3986,10 @@ public function createDocuments(
             return 0;
         }
 
+        $clonedDocuments = array_map(function (Document $document) {
+            return clone $document;
+        }, $documents);
+
         $batchSize = \min(Database::INSERT_BATCH_SIZE, \max(1, $batchSize));
         $collection = $this->silent(fn () => $this->getCollection($collection));
         if ($collection->getId() !== self::METADATA) {
@@ -3997,8 +4001,9 @@ public function createDocuments(
 
         $time = DateTime::now();
         $modified = 0;
+        $index = 0;
 
-        foreach ($documents as $document) {
+        foreach ($clonedDocuments as &$document) {
             $createdAt = $document->getCreatedAt();
             $updatedAt = $document->getUpdatedAt();
 
@@ -4042,7 +4047,7 @@ public function createDocuments(
             $document = $this->adapter->castingBefore($collection, $document);
         }
 
-        foreach (\array_chunk($documents, $batchSize) as $chunk) {
+        foreach (\array_chunk($clonedDocuments, $batchSize) as $chunk) {
             $batch = $this->withTransaction(function () use ($collection, $chunk) {
                 return $this->adapter->createDocuments($collection, $chunk);
             });
@@ -4063,8 +4068,16 @@ public function createDocuments(
                 } catch (\Throwable $e) {
                     $onError ? $onError($e) : throw $e;
                 }
-
+                $clonedDocuments[$index] = $doc;
                 $modified++;
+                $index++;
+            }
+        }
+
+        foreach ($clonedDocuments as $index => $clonedDocument) {
+            foreach ($clonedDocument->getArrayCopy() as $attribute => $value) {
+                var_dump($value);
+                $documents[$index]->setAttribute($attribute, $value);
             }
         }
 

tests/e2e/Adapter/Scopes/SchemalessTests.php

@@ -1027,25 +1027,31 @@ public function testSchemalessDates(): void
         $updatedAt3 = '2002-03-05T05:06:08.000+00:00';
         $curDate3   = '2002-03-06T07:08:09.000+00:00';
 
-        $countCreated = $database->withPreserveDates(function () use ($database, $col, $permissions, $createdAt2, $updatedAt2, $curDate2, $createdAt3, $updatedAt3, $curDate3) {
-            return $database->createDocuments($col, [
-                new Document([
-                    '$id' => 'd2',
-                    '$permissions' => $permissions,
-                    '$createdAt' => $createdAt2,
-                    '$updatedAt' => $updatedAt2,
-                    'curDate' => $curDate2,
-                ]),
-                new Document([
-                    '$id' => 'd3',
-                    '$permissions' => $permissions,
-                    '$createdAt' => $createdAt3,
-                    '$updatedAt' => $updatedAt3,
-                    'curDate' => $curDate3,
-                ]),
-            ]);
+        $docs = [
+            new Document([
+                '$id' => 'd2',
+                '$permissions' => $permissions,
+                '$createdAt' => $createdAt2,
+                '$updatedAt' => $updatedAt2,
+                'curDate' => $curDate2,
+            ]),
+            new Document([
+                '$id' => 'd3',
+                '$permissions' => $permissions,
+                '$createdAt' => $createdAt3,
+                '$updatedAt' => $updatedAt3,
+                'curDate' => $curDate3,
+            ]),
+        ];
+        $countCreated = $database->withPreserveDates(function () use ($database, $col, $docs) {
+            return $database->createDocuments($col, $docs);
         });
+
+        $this->assertEquals($createdAt2, $docs[0]->getAttribute('$createdAt'));
+        $this->assertEquals($updatedAt2, $docs[0]->getAttribute('$updatedAt'));
         $this->assertEquals(2, $countCreated);
+        $this->assertEquals($createdAt3, $docs[1]->getAttribute('$createdAt'));
+        $this->assertEquals($updatedAt3, $docs[1]->getAttribute('$updatedAt'));
 
         $fetched2 = $database->getDocument($col, 'd2');
         $this->assertEquals($curDate2, $fetched2->getAttribute('curDate'));