summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_add_fields_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/document_source_add_fields_test.cpp')
-rw-r--r--src/mongo/db/pipeline/document_source_add_fields_test.cpp24
1 files changed, 13 insertions, 11 deletions
diff --git a/src/mongo/db/pipeline/document_source_add_fields_test.cpp b/src/mongo/db/pipeline/document_source_add_fields_test.cpp
index bad10fc0d47..c0b896d973a 100644
--- a/src/mongo/db/pipeline/document_source_add_fields_test.cpp
+++ b/src/mongo/db/pipeline/document_source_add_fields_test.cpp
@@ -59,7 +59,8 @@ using AddFieldsTest = AggregationContextFixture;
TEST_F(AddFieldsTest, ShouldKeepUnspecifiedFieldsReplaceExistingFieldsAndAddNewFields) {
auto addFields =
DocumentSourceAddFields::create(BSON("e" << 2 << "b" << BSON("c" << 3)), getExpCtx());
- auto mock = DocumentSourceMock::create(Document{{"a", 1}, {"b", Document{{"c", 1}}}, {"d", 1}});
+ auto mock =
+ DocumentSourceMock::createForTest(Document{{"a", 1}, {"b", Document{{"c", 1}}}, {"d", 1}});
addFields->setSource(mock.get());
auto next = addFields->getNext();
@@ -94,8 +95,8 @@ TEST_F(AddFieldsTest, ShouldErrorOnNonObjectSpec) {
TEST_F(AddFieldsTest, ShouldBeAbleToProcessMultipleDocuments) {
auto addFields = DocumentSourceAddFields::create(BSON("a" << 10), getExpCtx());
- auto mock =
- DocumentSourceMock::create({Document{{"a", 1}, {"b", 2}}, Document{{"c", 3}, {"d", 4}}});
+ auto mock = DocumentSourceMock::createForTest(
+ {Document{{"a", 1}, {"b", 2}}, Document{{"c", 3}, {"d", 4}}});
addFields->setSource(mock.get());
auto next = addFields->getNext();
@@ -139,10 +140,11 @@ TEST_F(AddFieldsTest, ShouldAddReferencedFieldsToDependencies) {
TEST_F(AddFieldsTest, ShouldPropagatePauses) {
auto addFields = DocumentSourceAddFields::create(BSON("a" << 10), getExpCtx());
- auto mock = DocumentSourceMock::create({Document(),
- DocumentSource::GetNextResult::makePauseExecution(),
- Document(),
- DocumentSource::GetNextResult::makePauseExecution()});
+ auto mock =
+ DocumentSourceMock::createForTest({Document(),
+ DocumentSource::GetNextResult::makePauseExecution(),
+ Document(),
+ DocumentSource::GetNextResult::makePauseExecution()});
addFields->setSource(mock.get());
ASSERT_TRUE(addFields->getNext().isAdvanced());
@@ -159,7 +161,7 @@ TEST_F(AddFieldsTest, AddFieldsWithRemoveSystemVariableDoesNotAddField) {
auto addFields = DocumentSourceAddFields::create(BSON("fieldToAdd"
<< "$$REMOVE"),
getExpCtx());
- auto mock = DocumentSourceMock::create(Document{{"existingField", 1}});
+ auto mock = DocumentSourceMock::createForTest(Document{{"existingField", 1}});
addFields->setSource(mock.get());
auto next = addFields->getNext();
@@ -173,7 +175,7 @@ TEST_F(AddFieldsTest, AddFieldsWithRootSystemVariableAddsRootAsSubDoc) {
auto addFields = DocumentSourceAddFields::create(BSON("b"
<< "$$ROOT"),
getExpCtx());
- auto mock = DocumentSourceMock::create(Document{{"a", 1}});
+ auto mock = DocumentSourceMock::createForTest(Document{{"a", 1}});
addFields->setSource(mock.get());
auto next = addFields->getNext();
@@ -187,7 +189,7 @@ TEST_F(AddFieldsTest, AddFieldsWithCurrentSystemVariableAddsRootAsSubDoc) {
auto addFields = DocumentSourceAddFields::create(BSON("b"
<< "$$CURRENT"),
getExpCtx());
- auto mock = DocumentSourceMock::create(Document{{"a", 1}});
+ auto mock = DocumentSourceMock::createForTest(Document{{"a", 1}});
addFields->setSource(mock.get());
auto next = addFields->getNext();
@@ -214,7 +216,7 @@ BSONObj makeAddFieldsForNestedDocument(size_t depth) {
TEST_F(AddFieldsTest, CanAddNestedDocumentExactlyAtDepthLimit) {
auto addFields = DocumentSourceAddFields::create(
makeAddFieldsForNestedDocument(BSONDepth::getMaxAllowableDepth()), getExpCtx());
- auto mock = DocumentSourceMock::create(Document{{"_id", 1}});
+ auto mock = DocumentSourceMock::createForTest(Document{{"_id", 1}});
addFields->setSource(mock.get());
auto next = addFields->getNext();