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
|
// Tests that the $changeStream stage can only be present as the first stage in the pipeline.
(function() {
"use strict";
load("jstests/aggregation/extras/utils.js"); // For assertErrorCode.
load("jstests/libs/collection_drop_recreate.js"); // For assert[Drop|Create]Collection.
const coll = assertDropAndRecreateCollection(db, "change_stream_required_as_first_stage");
assertErrorCode(coll, [{$indexStats: {}}, {$changeStream: {}}], 40602);
assertErrorCode(
coll,
[{$indexStats: {}}, {$changeStream: {}}, {$match: {test: "this is an extra stage"}}],
40602);
// Test that a $changeStream stage is not allowed within a $facet stage.
assertErrorCode(coll, [{$facet: {testPipe: [{$changeStream: {}}]}}], 40600);
assertErrorCode(coll,
[{
$facet: {
testPipe: [
{$indexStats: {}},
{$changeStream: {}},
{$match: {test: "this is an extra stage"}}
]
}
}],
40600);
}());
|
