createDataKeys Return the modifiedEncryptedFields instead of modifying the reference

Author: GromNaN

src/Database.php

@@ -324,11 +324,9 @@ public function createEncryptedCollection(string $collectionName, ClientEncrypti
         $server = select_server_for_write($this->manager, $options);
 
         try {
-            $operation->createDataKeys($clientEncryption, $kmsProvider, $masterKey, $encryptedFields);
+            $encryptedFields = $operation->createDataKeys($clientEncryption, $kmsProvider, $masterKey);
             $operation->execute($server);
 
-            assert(is_array($encryptedFields), '$encryptedFields is set');
-
             return $encryptedFields;
         } catch (Throwable $e) {
             throw new CreateEncryptedCollectionException($e, $encryptedFields ?? []);

src/Operation/CreateEncryptedCollection.php

@@ -97,21 +97,21 @@ public function __construct(private string $databaseName, private string $collec
      * "encryptedFields" option and reconstruct the internal CreateCollection
      * operation used for creating the encrypted collection.
      *
-     * The $encryptedFields reference parameter may be used to determine which
-     * data keys have been created.
+     * Returns the data keys that have been created.
      *
      * @see \MongoDB\Database::createEncryptedCollection()
      * @see https://www.php.net/manual/en/mongodb-driver-clientencryption.createdatakey.php
+     * @return array
      * @throws DriverRuntimeException for errors creating a data key
      */
-    public function createDataKeys(ClientEncryption $clientEncryption, string $kmsProvider, ?array $masterKey, ?array &$encryptedFields = null): void
+    public function createDataKeys(ClientEncryption $clientEncryption, string $kmsProvider, ?array $masterKey): array
     {
         /** @psalm-var array{fields: list<array{keyId: ?Binary}|object{keyId: ?Binary}>|Serializable|PackedArray} */
         $encryptedFields = document_to_array($this->options['encryptedFields']);
 
         // NOP if there are no fields to examine
         if (! isset($encryptedFields['fields'])) {
-            return;
+            return $encryptedFields;
         }
 
         // Allow PackedArray or Serializable object for the fields array
@@ -128,7 +128,7 @@ public function createDataKeys(ClientEncryption $clientEncryption, string $kmsPr
 
         // Skip invalid types and defer to the server to raise an error
         if (! is_array($encryptedFields['fields'])) {
-            return;
+            return $encryptedFields;
         }
 
         $createDataKeyArgs = [
@@ -152,6 +152,8 @@ public function createDataKeys(ClientEncryption $clientEncryption, string $kmsPr
 
         $this->options['encryptedFields'] = $encryptedFields;
         $this->createCollection = new CreateCollection($this->databaseName, $this->collectionName, $this->options);
+
+        return $encryptedFields;
     }
 
     /**

tests/Operation/CreateEncryptedCollectionFunctionalTest.php

@@ -63,11 +63,10 @@ public function testCreateDataKeysNopIfFieldsIsMissing($input, array $expectedOu
             ['encryptedFields' => $input],
         );
 
-        $operation->createDataKeys(
+        $encryptedFieldsOutput = $operation->createDataKeys(
             $this->clientEncryption,
             'local',
             null,
-            $encryptedFieldsOutput,
         );
 
         $this->assertSame($expectedOutput, $encryptedFieldsOutput);
@@ -94,11 +93,10 @@ public function testCreateDataKeysNopIfFieldsHasInvalidType($input, array $expec
             ['encryptedFields' => $input],
         );
 
-        $operation->createDataKeys(
+        $encryptedFieldsOutput = $operation->createDataKeys(
             $this->clientEncryption,
             'local',
             null,
-            $encryptedFieldsOutput,
         );
 
         $this->assertSame($expectedOutput, $encryptedFieldsOutput);
@@ -125,11 +123,10 @@ public function testCreateDataKeysSkipsNonDocumentFields($input, array $expected
             ['encryptedFields' => $input],
         );
 
-        $operation->createDataKeys(
+        $encryptedFieldsOutput = $operation->createDataKeys(
             $this->clientEncryption,
             'local',
             null,
-            $encryptedFieldsOutput,
         );
 
         $this->assertSame($expectedOutput, $encryptedFieldsOutput);
@@ -158,11 +155,10 @@ public function testCreateDataKeysDoesNotModifyOriginalEncryptedFieldsOption():
             ['encryptedFields' => $originalEncryptedFields],
         );
 
-        $operation->createDataKeys(
+        $modifiedEncryptedFields = $operation->createDataKeys(
             $this->clientEncryption,
             'local',
             null,
-            $modifiedEncryptedFields,
         );
 
         $this->assertSame($originalField, $originalEncryptedFields->fields[0]);
@@ -180,11 +176,10 @@ public function testEncryptedFieldsDocuments($input): void
             ['encryptedFields' => $input],
         );
 
-        $operation->createDataKeys(
+        $modifiedEncryptedFields = $operation->createDataKeys(
             $this->clientEncryption,
             'local',
             null,
-            $modifiedEncryptedFields,
         );
 
         $this->assertInstanceOf(Binary::class, $modifiedEncryptedFields['fields'][0]['keyId'] ?? null);