File tree Expand file tree Collapse file tree 1 file changed +7
-6
lines changed Expand file tree Collapse file tree 1 file changed +7
-6
lines changed Original file line number Diff line number Diff line change @@ -1282,15 +1282,16 @@ document::value operation_runner::_run_create_collection(document::view operatio
1282
1282
auto arguments = operation[" arguments" ].get_document ().value ;
1283
1283
auto collection_name = arguments[" collection" ].get_string ().value ;
1284
1284
auto session = _lookup_session (arguments);
1285
+ bsoncxx::builder::basic::document opts;
1286
+
1287
+ if (arguments[" encryptedFields" ]) {
1288
+ opts.append (kvp (" encryptedFields" , arguments[" encryptedFields" ].get_document ().value ));
1289
+ }
1285
1290
1286
1291
if (session) {
1287
- _db->create_collection (*session, collection_name);
1288
- } else if (arguments.find (" encryptedFields" ) != arguments.end ()) {
1289
- auto encrypted_fields = arguments[" encryptedFields" ].get_document ().value ;
1290
- auto encrypted_fields_map = make_document (kvp (" encryptedFields" , encrypted_fields));
1291
- _db->create_collection (collection_name, std::move (encrypted_fields_map));
1292
+ _db->create_collection (*session, collection_name, opts.extract ());
1292
1293
} else {
1293
- _db->create_collection (collection_name);
1294
+ _db->create_collection (collection_name, opts. extract () );
1294
1295
}
1295
1296
return empty_document;
1296
1297
}
You can’t perform that action at this time.
0 commit comments