1 files changed, 51 insertions, 53 deletions
diff --git a/jstests/sharding/change_streams_establishment_finds_new_shards.js b/jstests/sharding/change_streams_establishment_finds_new_shards.js
index 45bc1583e46..146fc166d50 100644
--- a/jstests/sharding/change_streams_establishment_finds_new_shards.js
+++ b/jstests/sharding/change_streams_establishment_finds_new_shards.js
@@ -2,50 +2,48 @@
 // during cursor establishment.
 // @tags: [uses_change_streams]
 (function() {
-    'use strict';
+'use strict';
 
-    // For supportsMajorityReadConcern().
-    load("jstests/multiVersion/libs/causal_consistency_helpers.js");
+// For supportsMajorityReadConcern().
+load("jstests/multiVersion/libs/causal_consistency_helpers.js");
 
-    if (!supportsMajorityReadConcern()) {
-        jsTestLog("Skipping test since storage engine doesn't support majority read concern.");
-        return;
-    }
+if (!supportsMajorityReadConcern()) {
+    jsTestLog("Skipping test since storage engine doesn't support majority read concern.");
+    return;
+}
 
-    const rsNodeOptions = {
-        // Use a higher frequency for periodic noops to speed up the test.
-        setParameter: {periodicNoopIntervalSecs: 1, writePeriodicNoops: true}
-    };
-    const st =
-        new ShardingTest({shards: 1, mongos: 1, rs: {nodes: 1}, other: {rsOptions: rsNodeOptions}});
+const rsNodeOptions = {
+    // Use a higher frequency for periodic noops to speed up the test.
+    setParameter: {periodicNoopIntervalSecs: 1, writePeriodicNoops: true}
+};
+const st =
+    new ShardingTest({shards: 1, mongos: 1, rs: {nodes: 1}, other: {rsOptions: rsNodeOptions}});
 
-    jsTestLog("Starting new shard (but not adding to shard set yet)");
-    const newShard = new ReplSetTest({name: "newShard", nodes: 1, nodeOptions: rsNodeOptions});
-    newShard.startSet({shardsvr: ''});
-    newShard.initiate();
+jsTestLog("Starting new shard (but not adding to shard set yet)");
+const newShard = new ReplSetTest({name: "newShard", nodes: 1, nodeOptions: rsNodeOptions});
+newShard.startSet({shardsvr: ''});
+newShard.initiate();
 
-    const mongos = st.s;
-    const mongosColl = mongos.getCollection('test.foo');
-    const mongosDB = mongos.getDB("test");
+const mongos = st.s;
+const mongosColl = mongos.getCollection('test.foo');
+const mongosDB = mongos.getDB("test");
 
-    // Enable sharding to inform mongos of the database, allowing us to open a cursor.
-    assert.commandWorked(mongos.adminCommand({enableSharding: mongosDB.getName()}));
+// Enable sharding to inform mongos of the database, allowing us to open a cursor.
+assert.commandWorked(mongos.adminCommand({enableSharding: mongosDB.getName()}));
 
-    // Shard the collection.
-    assert.commandWorked(
-        mongos.adminCommand({shardCollection: mongosColl.getFullName(), key: {_id: 1}}));
+// Shard the collection.
+assert.commandWorked(
+    mongos.adminCommand({shardCollection: mongosColl.getFullName(), key: {_id: 1}}));
 
-    // Split the collection into two chunks: [MinKey, 10) and [10, MaxKey].
-    assert.commandWorked(mongos.adminCommand({split: mongosColl.getFullName(), middle: {_id: 10}}));
+// Split the collection into two chunks: [MinKey, 10) and [10, MaxKey].
+assert.commandWorked(mongos.adminCommand({split: mongosColl.getFullName(), middle: {_id: 10}}));
 
-    // Enable the failpoint.
-    assert.commandWorked(mongos.adminCommand({
-        configureFailPoint: "clusterAggregateHangBeforeEstablishingShardCursors",
-        mode: "alwaysOn"
-    }));
+// Enable the failpoint.
+assert.commandWorked(mongos.adminCommand(
+    {configureFailPoint: "clusterAggregateHangBeforeEstablishingShardCursors", mode: "alwaysOn"}));
 
-    // While opening the cursor, wait for the failpoint and add the new shard.
-    const awaitNewShard = startParallelShell(`
+// While opening the cursor, wait for the failpoint and add the new shard.
+const awaitNewShard = startParallelShell(`
         load("jstests/libs/check_log.js");
         checkLog.contains(db,
             "clusterAggregateHangBeforeEstablishingShardCursors fail point enabled");
@@ -62,27 +60,27 @@
                  mode: "off"}));`,
                                              mongos.port);
 
-    jsTestLog("Opening $changeStream cursor");
-    const changeStream = mongosColl.aggregate([{$changeStream: {}}]);
-    assert(!changeStream.hasNext(), "Do not expect any results yet");
+jsTestLog("Opening $changeStream cursor");
+const changeStream = mongosColl.aggregate([{$changeStream: {}}]);
+assert(!changeStream.hasNext(), "Do not expect any results yet");
 
-    // Clean up the parallel shell.
-    awaitNewShard();
+// Clean up the parallel shell.
+awaitNewShard();
 
-    // Insert two documents in different shards.
-    assert.writeOK(mongosColl.insert({_id: 0}, {writeConcern: {w: "majority"}}));
-    assert.writeOK(mongosColl.insert({_id: 20}, {writeConcern: {w: "majority"}}));
+// Insert two documents in different shards.
+assert.writeOK(mongosColl.insert({_id: 0}, {writeConcern: {w: "majority"}}));
+assert.writeOK(mongosColl.insert({_id: 20}, {writeConcern: {w: "majority"}}));
 
-    // Expect to see them both.
-    for (let id of[0, 20]) {
-        jsTestLog("Expecting Item " + id);
-        assert.soon(() => changeStream.hasNext());
-        let next = changeStream.next();
-        assert.eq(next.operationType, "insert");
-        assert.eq(next.documentKey, {_id: id});
-    }
-    assert(!changeStream.hasNext());
+// Expect to see them both.
+for (let id of [0, 20]) {
+    jsTestLog("Expecting Item " + id);
+    assert.soon(() => changeStream.hasNext());
+    let next = changeStream.next();
+    assert.eq(next.operationType, "insert");
+    assert.eq(next.documentKey, {_id: id});
+}
+assert(!changeStream.hasNext());
 
-    st.stop();
-    newShard.stopSet();
+st.stop();
+newShard.stopSet();
 })();