ClientEncryption::rewrapManyDataKey method

Author: jmikola

src/MongoDB/ClientEncryption.c

@@ -393,8 +393,10 @@ static PHP_METHOD(MongoDB_Driver_ClientEncryption, rewrapManyDataKey)
 	zend_bool    free_provider = false;
 	bson_t*      masterkey     = NULL;
 	bson_error_t error         = { 0 };
+	bson_t       reply         = BSON_INITIALIZER;
 
 	mongoc_client_encryption_rewrap_many_datakey_result_t* result = NULL;
+	const bson_t*                                          bulk_write_result;
 
 	PHONGO_PARSE_PARAMETERS_START(1, 2)
 	Z_PARAM_ARRAY_OR_OBJECT(zfilter)
@@ -431,9 +433,15 @@ static PHP_METHOD(MongoDB_Driver_ClientEncryption, rewrapManyDataKey)
 		goto cleanup;
 	}
 
-	RETVAL_NULL();
+	bulk_write_result = mongoc_client_encryption_rewrap_many_datakey_result_get_bulk_write_result(result);
 
-	/* TODO: mongoc_client_encryption_rewrap_many_datakey_result_t return value */
+	if (bson_empty0(bulk_write_result)) {
+		BSON_APPEND_NULL(&reply, "bulkWriteResult");
+	} else {
+		BSON_APPEND_DOCUMENT(&reply, "bulkWriteResult", bulk_write_result);
+	}
+
+	RETVAL_BSON_T(reply);
 
 cleanup:
 	if (free_provider) {

tests/clientEncryption/clientEncryption-rewrapManyDataKey-001.phpt

@@ -0,0 +1,57 @@
+--TEST--
+MongoDB\Driver\ClientEncryption::rewrapManyDataKey()
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
+<?php skip_if_not_libmongocrypt(); ?>
+<?php skip_if_not_live(); ?>
+<?php skip_if_not_clean(CSFLE_KEY_VAULT_DATABASE_NAME, CSFLE_KEY_VAULT_COLLECTION_NAME);
+--FILE--
+<?php
+
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = create_test_manager();
+
+$clientEncryption = $manager->createClientEncryption([
+  'keyVaultNamespace' => CSFLE_KEY_VAULT_NS,
+  'kmsProviders' => ['local' => ['key' => new MongoDB\BSON\Binary(CSFLE_LOCAL_KEY, 0)]],
+]);
+
+$keyId = $clientEncryption->createDataKey('local');
+
+$orignalKey = $clientEncryption->getKey($keyId);
+
+var_dump($clientEncryption->rewrapManyDataKey([], ['provider' => 'local']));
+
+$modifiedKey = $clientEncryption->getKey($keyId);
+
+var_dump($orignalKey->creationDate == $modifiedKey->creationDate);
+var_dump($orignalKey->updateDate < $modifiedKey->updateDate);
+var_dump($orignalKey->keyMaterial != $modifiedKey->keyMaterial);
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECTF--
+object(stdClass)#%d (%d) {
+  ["bulkWriteResult"]=>
+  object(stdClass)#%d (%d) {
+    ["nInserted"]=>
+    int(0)
+    ["nMatched"]=>
+    int(1)
+    ["nModified"]=>
+    int(1)
+    ["nRemoved"]=>
+    int(0)
+    ["nUpserted"]=>
+    int(0)
+    ["writeErrors"]=>
+    array(0) {
+    }
+  }
+}
+bool(true)
+bool(true)
+bool(true)
+===DONE===

tests/clientEncryption/clientEncryption-rewrapManyDataKey-002.phpt

@@ -0,0 +1,43 @@
+--TEST--
+MongoDB\Driver\ClientEncryption::rewrapManyDataKey() when filter matches no keys
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
+<?php skip_if_not_libmongocrypt(); ?>
+<?php skip_if_not_live(); ?>
+<?php skip_if_not_clean(CSFLE_KEY_VAULT_DATABASE_NAME, CSFLE_KEY_VAULT_COLLECTION_NAME);
+--FILE--
+<?php
+
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = create_test_manager();
+
+$clientEncryption = $manager->createClientEncryption([
+  'keyVaultNamespace' => CSFLE_KEY_VAULT_NS,
+  'kmsProviders' => ['local' => ['key' => new MongoDB\BSON\Binary(CSFLE_LOCAL_KEY, 0)]],
+]);
+
+$keyId = $clientEncryption->createDataKey('local');
+
+$orignalKey = $clientEncryption->getKey($keyId);
+
+var_dump($clientEncryption->rewrapManyDataKey(['_id' => 'no-matching-key']));
+
+$modifiedKey = $clientEncryption->getKey($keyId);
+
+var_dump($orignalKey->creationDate == $modifiedKey->creationDate);
+var_dump($orignalKey->updateDate == $modifiedKey->updateDate);
+var_dump($orignalKey->keyMaterial == $modifiedKey->keyMaterial);
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECTF--
+object(stdClass)#%d (%d) {
+  ["bulkWriteResult"]=>
+  NULL
+}
+bool(true)
+bool(true)
+bool(true)
+===DONE===