1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
/*
* FLE-supported commands that contain an invalid 'jsonSchema' field should return to the user a
* more specific error message for diagnostic purposes.
*
* @tags: [requires_non_retryable_writes]
*/
(function() {
'use strict';
const coll = db.command_json_schema_field;
coll.drop();
assert.commandWorked(coll.insert({a: 1}));
assert.commandWorked(coll.insert({a: 2}));
function assertCommandFailsWithCorrectError(command, code) {
let res = db.runCommand(command);
assert.commandFailedWithCode(res, code);
assert(res.errmsg.includes("This command may be meant for a mongocryptd process"));
}
// Aggregate
assertCommandFailsWithCorrectError(
{aggregate: coll.getName(), pipeline: [], cursor: {}, jsonSchema: {}},
[ErrorCodes.FailedToParse, 4662500]);
// Find
assertCommandFailsWithCorrectError({find: coll.getName(), jsonSchema: {}},
[ErrorCodes.FailedToParse, 4662500]);
// FindAndModify
assertCommandFailsWithCorrectError(
{findAndModify: coll.getName(), query: {_id: 0}, remove: true, jsonSchema: {}},
[ErrorCodes.FailedToParse, 4662500]);
// Count
assertCommandFailsWithCorrectError({count: coll.getName(), jsonSchema: {}}, 4662500);
// Distinct
assertCommandFailsWithCorrectError({distinct: coll.getName(), key: "a", jsonSchema: {}}, 4662500);
// Write Commands
assertCommandFailsWithCorrectError({insert: coll.getName(), documents: [{}], jsonSchema: {}},
4662500);
assertCommandFailsWithCorrectError(
{update: coll.getName(), updates: [{q: {}, u: {$inc: {a: 1}}}], jsonSchema: {}}, 4662500);
assertCommandFailsWithCorrectError(
{delete: coll.getName(), deletes: [{q: {}, limit: 0}], jsonSchema: {}}, 4662500);
// Explain
assertCommandFailsWithCorrectError({explain: {count: coll.getName()}, jsonSchema: {}},
[ErrorCodes.FailedToParse, 40415, 4662500]);
}());
|
