blob: f117e9d2184a8c3b02aa07b458beb45fc7555a36 (
plain)
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
|
/**
* Test that an erroneous Change Stream pipeline responds with an error that includes the
* "NonResumableChangeStreamError" label.
*/
(function() {
"use strict";
load("jstests/libs/collection_drop_recreate.js"); // For assertDropAndRecreateCollection.
// Drop and recreate the collections to be used in this set of tests.
const coll = assertDropAndRecreateCollection(db, "change_stream_error_label");
// Attaching a projection to the Change Stream that filters out the resume token (stored in the
// _id field) guarantees a ChangeStreamFatalError as soon as we get the first change.
const changeStream = coll.watch([{$project: {_id: 0}}], {batchSize: 1});
assert.commandWorked(coll.insert({a: 1}));
const err = assert.throws(function() {
// Call hasNext() until it throws an error or unexpectedly returns true. We need the
// assert.soon() to keep trying here, because the above insert command isn't immediately
// observable to the change stream in sharded configurations.
assert.soon(function() {
return changeStream.hasNext();
}, undefined, undefined, undefined, {runHangAnalyzer: false});
});
// The hasNext() sends a getMore command, which should generate a ChangeStreamFatalError reply
// that includes the NonResumableChangeStreamError errorLabel.
assert.commandFailedWithCode(err, ErrorCodes.ChangeStreamFatalError);
assert("errorLabels" in err, err);
assert.contains("NonResumableChangeStreamError", err.errorLabels, err);
}());
|
