summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_change_stream_test.cpp
diff options
context:
space:
mode:
authorMark Benvenuto <mark.benvenuto@mongodb.com>2018-09-14 13:24:39 -0400
committerMark Benvenuto <mark.benvenuto@mongodb.com>2018-09-14 13:24:39 -0400
commit5603a0812eb64c8009a514a3c59182f7f7134b9e (patch)
treec8feed84f4e45486739941763525139a942abee4 /src/mongo/db/pipeline/document_source_change_stream_test.cpp
parent0b5a31fe040168e9cbe3243b80ed2f40e1099e58 (diff)
downloadmongo-5603a0812eb64c8009a514a3c59182f7f7134b9e.tar.gz
SERVER-34882 Support creating instances with all required fields in IDL
Diffstat (limited to 'src/mongo/db/pipeline/document_source_change_stream_test.cpp')
-rw-r--r--src/mongo/db/pipeline/document_source_change_stream_test.cpp36
1 files changed, 18 insertions, 18 deletions
diff --git a/src/mongo/db/pipeline/document_source_change_stream_test.cpp b/src/mongo/db/pipeline/document_source_change_stream_test.cpp
index c8a703726cb..761fdfbd1c3 100644
--- a/src/mongo/db/pipeline/document_source_change_stream_test.cpp
+++ b/src/mongo/db/pipeline/document_source_change_stream_test.cpp
@@ -453,12 +453,12 @@ TEST_F(ChangeStreamStageTest, TransformInsertDocKeyXAndId) {
};
checkTransformation(insert, expectedInsert, {{"x"}, {"_id"}});
bool fromMigrate = false; // also check actual "fromMigrate: false" not filtered
- auto insert2 = makeOplogEntry(insert.getOpType(), // op type
- insert.getNamespace(), // namespace
- insert.getObject(), // o
- insert.getUuid(), // uuid
- fromMigrate, // fromMigrate
- insert.getObject2()); // o2
+ auto insert2 = makeOplogEntry(insert.getOpType(), // op type
+ insert.getNss(), // namespace
+ insert.getObject(), // o
+ insert.getUuid(), // uuid
+ fromMigrate, // fromMigrate
+ insert.getObject2()); // o2
checkTransformation(insert2, expectedInsert, {{"x"}, {"_id"}});
}
@@ -628,12 +628,12 @@ TEST_F(ChangeStreamStageTest, TransformDelete) {
checkTransformation(deleteEntry, expectedDelete);
bool fromMigrate = false; // also check actual "fromMigrate: false" not filtered
- auto deleteEntry2 = makeOplogEntry(deleteEntry.getOpType(), // op type
- deleteEntry.getNamespace(), // namespace
- deleteEntry.getObject(), // o
- deleteEntry.getUuid(), // uuid
- fromMigrate, // fromMigrate
- deleteEntry.getObject2()); // o2
+ auto deleteEntry2 = makeOplogEntry(deleteEntry.getOpType(), // op type
+ deleteEntry.getNss(), // namespace
+ deleteEntry.getObject(), // o
+ deleteEntry.getUuid(), // uuid
+ fromMigrate, // fromMigrate
+ deleteEntry.getObject2()); // o2
checkTransformation(deleteEntry2, expectedDelete);
}
@@ -1400,12 +1400,12 @@ TEST_F(ChangeStreamStageDBTest, TransformDelete) {
checkTransformation(deleteEntry, expectedDelete);
bool fromMigrate = false; // also check actual "fromMigrate: false" not filtered
- auto deleteEntry2 = makeOplogEntry(deleteEntry.getOpType(), // op type
- deleteEntry.getNamespace(), // namespace
- deleteEntry.getObject(), // o
- deleteEntry.getUuid(), // uuid
- fromMigrate, // fromMigrate
- deleteEntry.getObject2()); // o2
+ auto deleteEntry2 = makeOplogEntry(deleteEntry.getOpType(), // op type
+ deleteEntry.getNss(), // namespace
+ deleteEntry.getObject(), // o
+ deleteEntry.getUuid(), // uuid
+ fromMigrate, // fromMigrate
+ deleteEntry.getObject2()); // o2
checkTransformation(deleteEntry2, expectedDelete);
}