Fix test failures on 8.0 sharded clusters

Advance cluster time on all session entities in unified tests to one after the initial data is created

JAVA-5334

Author: jyemin

driver-core/src/test/functional/com/mongodb/client/test/CollectionHelper.java

@@ -109,6 +109,11 @@ public static void dropDatabase(final String name, final WriteConcern writeConce
         }
     }
 
+    public static BsonDocument getCurrentClusterTime() {
+        return new CommandReadOperation<BsonDocument>("admin", new BsonDocument("ping", new BsonInt32(1)), new BsonDocumentCodec())
+                .execute(getBinding()).getDocument("$clusterTime", null);
+    }
+
     public MongoNamespace getNamespace() {
         return namespace;
     }

driver-sync/src/test/functional/com/mongodb/client/unified/Entities.java

@@ -24,6 +24,7 @@
 import com.mongodb.ServerApi;
 import com.mongodb.ServerApiVersion;
 import com.mongodb.internal.connection.TestClusterListener;
+import com.mongodb.lang.Nullable;
 import com.mongodb.logging.TestLoggingInterceptor;
 import com.mongodb.TransactionOptions;
 import com.mongodb.WriteConcern;
@@ -300,6 +301,7 @@ private <T> void putEntity(final String id, final T entity, final Map<String, T>
     }
 
     public void init(final BsonArray entitiesArray,
+                     final BsonDocument startingClusterTime,
                      final boolean waitForPoolAsyncWorkManagerStart,
                      final Function<MongoClientSettings, MongoClient> mongoClientSupplier,
                      final Function<MongoDatabase, GridFSBucket> gridFSBucketSupplier,
@@ -324,7 +326,7 @@ public void init(final BsonArray entitiesArray,
                     break;
                 }
                 case "session": {
-                    initSession(entity, id);
+                    initSession(entity, id, startingClusterTime);
                     break;
                 }
                 case "bucket": {
@@ -596,7 +598,7 @@ private void initCollection(final BsonDocument entity, final String id) {
         putEntity(id, collection, collections);
     }
 
-    private void initSession(final BsonDocument entity, final String id) {
+    private void initSession(final BsonDocument entity, final String id, final BsonDocument startingClusterTime) {
         MongoClient client = clients.get(entity.getString("client").getValue());
         ClientSessionOptions.Builder optionsBuilder = ClientSessionOptions.builder();
         if (entity.containsKey("sessionOptions")) {
@@ -614,6 +616,7 @@ private void initSession(final BsonDocument entity, final String id) {
             }
         }
         ClientSession session = client.startSession(optionsBuilder.build());
+        session.advanceClusterTime(startingClusterTime);
         putEntity(id, session, sessions);
         putEntity(id + "-identifier", session.getServerSession().getIdentifier(), sessionIdentifiers);
     }

driver-sync/src/test/functional/com/mongodb/client/unified/UnifiedTest.java

@@ -73,6 +73,7 @@
 import static com.mongodb.ClusterFixture.getServerVersion;
 import static com.mongodb.client.Fixture.getMongoClient;
 import static com.mongodb.client.Fixture.getMongoClientSettings;
+import static com.mongodb.client.test.CollectionHelper.getCurrentClusterTime;
 import static com.mongodb.client.unified.RunOnRequirementsMatcher.runOnRequirementsMet;
 import static java.util.Collections.singletonList;
 import static java.util.stream.Collectors.toList;
@@ -105,6 +106,7 @@ public abstract class UnifiedTest {
     private final UnifiedClientEncryptionHelper clientEncryptionHelper = new UnifiedClientEncryptionHelper(entities);
     private final List<FailPoint> failPoints = new ArrayList<>();
     private final UnifiedTestContext rootContext = new UnifiedTestContext();
+    private BsonDocument startingClusterTime;
 
     private class UnifiedTestContext {
         private final AssertionContext context = new AssertionContext();
@@ -212,12 +214,12 @@ public void setUp() {
         if (definition.containsKey("skipReason")) {
             throw new AssumptionViolatedException(definition.getString("skipReason").getValue());
         }
-        entities.init(entitiesArray,
+        startingClusterTime = addInitialData();
+        entities.init(entitiesArray, startingClusterTime,
                 fileDescription != null && PRESTART_POOL_ASYNC_WORK_MANAGER_FILE_DESCRIPTIONS.contains(fileDescription),
                 this::createMongoClient,
                 this::createGridFSBucket,
                 this::createClientEncryption);
-        addInitialData();
     }
 
     @After
@@ -561,6 +563,7 @@ protected boolean terminateLoop() {
 
     private OperationResult executeCreateEntities(final BsonDocument operation) {
         entities.init(operation.getDocument("arguments").getArray("entities"),
+                startingClusterTime,
                 false,
                 this::createMongoClient,
                 this::createGridFSBucket,
@@ -890,7 +893,7 @@ private List<CommandEvent> lastTwoCommandEvents(final TestCommandListener listen
         return events.subList(events.size() - 2, events.size());
     }
 
-    private void addInitialData() {
+    private BsonDocument addInitialData() {
         for (BsonValue cur : initialData.getValues()) {
             BsonDocument curDataSet = cur.asDocument();
             CollectionHelper<BsonDocument> helper = new CollectionHelper<>(new BsonDocumentCodec(),
@@ -905,5 +908,6 @@ private void addInitialData() {
                         WriteConcern.MAJORITY);
             }
         }
+        return getCurrentClusterTime();
     }
 }