diff options
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.cpp | 24 |
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(); |