summaryrefslogtreecommitdiff
path: root/jstests/change_streams
diff options
context:
space:
mode:
authorDenis Grebennicov <denis.grebennicov@mongodb.com>2021-11-10 10:37:00 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-11-10 11:05:06 +0000
commit7b080dde19c982aee81f2a338295119e2e751a96 (patch)
treee0a48482517257ff0e386657fb45135afbc95feb /jstests/change_streams
parentbdc2e9b2ed299f4dfbf6183eed94707afbde8478 (diff)
downloadmongo-7b080dde19c982aee81f2a338295119e2e751a96.tar.gz
SERVER-58691 Implement deletion of pre-images which corresponding oplog entry fell off the oplog
Diffstat (limited to 'jstests/change_streams')
-rw-r--r--jstests/change_streams/write_pit_preimage.js7
1 files changed, 4 insertions, 3 deletions
diff --git a/jstests/change_streams/write_pit_preimage.js b/jstests/change_streams/write_pit_preimage.js
index bf2a0c1eec2..654edc958af 100644
--- a/jstests/change_streams/write_pit_preimage.js
+++ b/jstests/change_streams/write_pit_preimage.js
@@ -12,8 +12,8 @@
(function() {
"use strict";
-load("jstests/libs/collection_drop_recreate.js"); // For assertDropAndRecreateCollection.
-load("jstests/libs/change_stream_util.js"); // For isChangeStreamPreAndPostImagesEnabled.
+load("jstests/libs/collection_drop_recreate.js"); // For assertDropCollection,
+ // assertDropAndRecreateCollection.
const testDB = db.getSiblingDB(jsTestName());
const localDB = db.getSiblingDB("local");
@@ -51,7 +51,8 @@ function assertValidChangeStreamPreImageDocument(preImage) {
function testFunc(collOptions = {}) {
let coll = assertDropAndRecreateCollection(testDB, collName, collOptions);
- const preImagesColl = assertDropAndRecreateCollection(configDB, preImagesCollName);
+ assertDropCollection(configDB, preImagesCollName);
+ const preImagesColl = configDB.getCollection(preImagesCollName);
// Perform an insert and an update modification.
assert.commandWorked(coll.insert(originalDoc));