CSHARP-3705: Updated spec testing code to handle hello, ignore tests related to not-yet-implemented load balancer support, and update sharded cluster tests to reflect new explain plan output from 5.0 sharded clusters. (#548)

JamesKovacs · web-flow · commit b370f5f48a9f · 2021-06-14T14:31:27.000-06:00
diff --git a/tests/MongoDB.Driver.Core.TestHelpers/XunitExtensions/RequireServer.cs b/tests/MongoDB.Driver.Core.TestHelpers/XunitExtensions/RequireServer.cs
@@ -222,6 +222,11 @@ private bool CanRunOn(ICluster cluster, BsonDocument requirement)
             {
                 switch (item.Name)
                 {
+                    case "authEnabled":
+                        {
+                            var actualAuthentication = CoreTestConfiguration.ConnectionString.Username != null;
+                            return actualAuthentication == item.Value.AsBoolean;
+                        }
                     case "minServerVersion":
                         {
                             var actualVersion = CoreTestConfiguration.ServerVersion;
@@ -277,6 +282,7 @@ private ClusterType MapTopologyToClusterType(string topology)
         {
             switch (topology)
             {
+                case "load-balanced": throw new SkipException("Topology load-balanced has not been implemented yet.");
                 case "single": return Clusters.ClusterType.Standalone;
                 case "replicaset": return Clusters.ClusterType.ReplicaSet;
                 case "sharded-replicaset":
diff --git a/tests/MongoDB.Driver.Core.Tests/Specifications/server-discovery-and-monitoring/MonitoringTestRunner.cs b/tests/MongoDB.Driver.Core.Tests/Specifications/server-discovery-and-monitoring/MonitoringTestRunner.cs
@@ -84,7 +84,7 @@ private void ApplyResponse(BsonArray response)
 
             var address = response[0].AsString;
             var isMasterDocument = response[1].AsBsonDocument;
-            JsonDrivenHelper.EnsureAllFieldsAreValid(isMasterDocument, "hosts", "ismaster", "maxWireVersion", "minWireVersion", "ok", "primary", "secondary", "setName", "setVersion");
+            JsonDrivenHelper.EnsureAllFieldsAreValid(isMasterDocument, "hosts", "isWritablePrimary", OppressiveLanguageConstants.LegacyHelloResponseIsWritablePrimaryFieldName, "maxWireVersion", "minWireVersion", "ok", "primary", "secondary", "setName", "setVersion");
 
             var endPoint = EndPointHelper.Parse(address);
             var isMasterResult = new IsMasterResult(isMasterDocument);
@@ -362,6 +362,12 @@ protected override IEnumerable<JsonDrivenTestCase> CreateTestCases(BsonDocument
                 var name = GetTestCaseName(document, document, 0);
                 yield return new JsonDrivenTestCase(name, document, document);
             }
+
+            protected override bool ShouldReadJsonDocument(string path)
+            {
+                // load balancer support not yet implemented
+                return base.ShouldReadJsonDocument(path) && !path.EndsWith("load_balancer.json");
+            }
         }
     }
 }
diff --git a/tests/MongoDB.Driver.Core.Tests/Specifications/server-discovery-and-monitoring/ServerDiscoveryAndMonitoringTestRunner.cs b/tests/MongoDB.Driver.Core.Tests/Specifications/server-discovery-and-monitoring/ServerDiscoveryAndMonitoringTestRunner.cs
@@ -15,6 +15,7 @@
 
 using System;
 using System.Collections.Generic;
+using System.IO;
 using System.Linq;
 using System.Threading;
 using FluentAssertions;
@@ -121,7 +122,7 @@ private void ApplyApplicationError(BsonDocument applicationError)
                     mongoConnectionException.Generation = generation;
                 }
             }
-            
+
             mockConnection.SetupGet(c => c.Generation).Returns(generation);
             mockConnection
                 .SetupGet(c => c.Generation)
@@ -186,7 +187,8 @@ private void ApplyResponse(BsonArray response)
                 "electionId",
                 "hidden",
                 "hosts",
-                "ismaster",
+                "isWritablePrimary",
+                OppressiveLanguageConstants.LegacyHelloResponseIsWritablePrimaryFieldName,
                 "isreplicaset",
                 "logicalSessionTimeoutMinutes",
                 "maxWireVersion",
@@ -529,7 +531,11 @@ private ICluster BuildCluster(BsonDocument definition)
         private class TestCaseFactory : JsonDrivenTestCaseFactory
         {
             // private constants
-            private const string MonitoringPrefix = "MongoDB.Driver.Core.Tests.Specifications.server_discovery_and_monitoring.tests.monitoring.";
+            private readonly string[] MonitoringPrefixes =
+            {
+                "MongoDB.Driver.Core.Tests.Specifications.server_discovery_and_monitoring.tests.monitoring.",
+                "MongoDB.Driver.Core.Tests.Specifications.server_discovery_and_monitoring.tests.legacy_hello.monitoring."
+            };
 
             protected override string PathPrefix => "MongoDB.Driver.Core.Tests.Specifications.server_discovery_and_monitoring.tests.";
 
@@ -541,7 +547,10 @@ protected override IEnumerable<JsonDrivenTestCase> CreateTestCases(BsonDocument
 
             protected override bool ShouldReadJsonDocument(string path)
             {
-                return base.ShouldReadJsonDocument(path) && !path.StartsWith(MonitoringPrefix);
+                var loadBalancerTestDirectory = $"{Path.PathSeparator}load-balanced{Path.PathSeparator}";
+                return base.ShouldReadJsonDocument(path) &&
+                       !MonitoringPrefixes.Any(prefix => path.StartsWith(prefix)) &&
+                       !path.Contains(loadBalancerTestDirectory);  // load balancer support not yet implemented
             }
         }
     }
diff --git a/tests/MongoDB.Driver.Legacy.Tests/Jira/CSharp365Tests.cs b/tests/MongoDB.Driver.Legacy.Tests/Jira/CSharp365Tests.cs
@@ -51,6 +51,11 @@ public void TestExplainWithFieldsAndCoveredIndex()
                     if (winningPlan.Contains("shards"))
                     {
                         winningPlan = winningPlan["shards"][0]["winningPlan"].AsBsonDocument;
+                        // MongoDB 5.0 changes the explain plan output to nest the shard's winningPlan 1 level deeper
+                        if (winningPlan.Contains("queryPlan"))
+                        {
+                            winningPlan = winningPlan["queryPlan"].AsBsonDocument;
+                        }
                     }
                     var inputStage = winningPlan["inputStage"].AsBsonDocument;
                     var stage = inputStage["stage"].AsString;
diff --git a/tests/MongoDB.Driver.Legacy.Tests/Linq/WithIndexTests.cs b/tests/MongoDB.Driver.Legacy.Tests/Linq/WithIndexTests.cs
@@ -134,6 +134,11 @@ public void TestIndexNameHintIsUsedInQuery()
                 if (winningPlan.Contains("shards"))
                 {
                     winningPlan = winningPlan["shards"][0]["winningPlan"].AsBsonDocument;
+                    // MongoDB 5.0 changes the explain plan output to nest the shard's winningPlan 1 level deeper
+                    if (winningPlan.Contains("queryPlan"))
+                    {
+                        winningPlan = winningPlan["queryPlan"].AsBsonDocument;
+                    }
                 }
                 var inputStage = winningPlan["inputStage"].AsBsonDocument;
                 var stage = inputStage["stage"].AsString;
@@ -221,6 +226,11 @@ public void TestIndexDocumentHintIsUsedInQuery()
                 if (winningPlan.Contains("shards"))
                 {
                     winningPlan = winningPlan["shards"][0]["winningPlan"].AsBsonDocument;
+                    // MongoDB 5.0 changes the explain plan output to nest the shard's winningPlan 1 level deeper
+                    if (winningPlan.Contains("queryPlan"))
+                    {
+                        winningPlan = winningPlan["queryPlan"].AsBsonDocument;
+                    }
                 }
                 var inputStage = winningPlan["inputStage"].AsBsonDocument;
                 var stage = inputStage["stage"].AsString;
diff --git a/tests/MongoDB.Driver.Tests/ClusterTests.cs b/tests/MongoDB.Driver.Tests/ClusterTests.cs
@@ -40,7 +40,8 @@ public class ClusterTests
     {
         private static readonly HashSet<string> __commandsToNotCapture = new HashSet<string>
         {
-            "isMaster",
+            "hello",
+            OppressiveLanguageConstants.LegacyHelloCommandName,
             "buildInfo",
             "getLastError",
             "authenticate",
diff --git a/tests/MongoDB.Driver.Tests/JsonDrivenTests/JsonDrivenTestFactory.cs b/tests/MongoDB.Driver.Tests/JsonDrivenTests/JsonDrivenTestFactory.cs
@@ -18,6 +18,7 @@
 using MongoDB.Bson;
 using MongoDB.Bson.TestHelpers.JsonDrivenTests;
 using MongoDB.Driver.Core;
+using Xunit;
 
 namespace MongoDB.Driver.Tests.JsonDrivenTests
 {
@@ -114,6 +115,7 @@ public JsonDrivenTest CreateTest(string receiver, string name)
                     switch (name)
                     {
                         case "listDatabaseNames": return new JsonDrivenListDatabaseNamesTest(_client, _objectMap);
+                        case "listDatabaseObjects": throw new SkipException(".NET/C# driver does not implement a ListDatabaseObjects helper.");
                         case "listDatabases": return new JsonDrivenListDatabasesTest(_client, _objectMap);
                         case "watch": return new JsonDrivenClientWatchTest(_client, _objectMap);
                         default: throw new FormatException($"Invalid method name: \"{name}\".");
@@ -138,6 +140,7 @@ public JsonDrivenTest CreateTest(string receiver, string name)
                         case "createCollection": return new JsonDrivenCreateCollectionTest(database, _objectMap);
                         case "dropCollection": return new JsonDrivenDropCollectionTest(database, _objectMap);
                         case "listCollectionNames": return new JsonDrivenListCollectionNamesTest(database, _objectMap);
+                        case "listCollectionObjects": throw new SkipException(".NET/C# driver does not implement a ListCollectionObjects helper.");
                         case "listCollections": return new JsonDrivenListCollectionsTest(database, _objectMap);
                         case "runCommand": return new JsonDrivenRunCommandTest(database, _objectMap);
                         case "watch": return new JsonDrivenDatabaseWatchTest(database, _objectMap);
@@ -168,6 +171,7 @@ public JsonDrivenTest CreateTest(string receiver, string name)
                         case "insertMany": return new JsonDrivenInsertManyTest(collection, _objectMap);
                         case "insertOne": return new JsonDrivenInsertOneTest(collection, _objectMap);
                         case "listIndexes": return new JsonDrivenListIndexesTest(collection, _objectMap);
+                        case "listIndexNames": throw new SkipException(".NET/C# driver does not implement a ListIndexNames helper.");
                         case "mapReduce": return new JsonDrivenMapReduceTest(collection, _objectMap);
                         case "replaceOne": return new JsonDrivenReplaceOneTest(collection, _objectMap);
                         case "updateMany": return new JsonDrivenUpdateManyTest(collection, _objectMap);
diff --git a/tests/MongoDB.Driver.Tests/PinnedShardRouterTests.cs b/tests/MongoDB.Driver.Tests/PinnedShardRouterTests.cs
@@ -34,7 +34,8 @@ public class PinnedShardRouterTests
     {
         private static readonly HashSet<string> __commandsToNotCapture = new HashSet<string>
         {
-            "isMaster",
+            "hello",
+            OppressiveLanguageConstants.LegacyHelloCommandName,
             "buildInfo",
             "getLastError",
             "authenticate",
diff --git a/tests/MongoDB.Driver.Tests/Specifications/Runner/MongoClientJsonDrivenTestRunnerBase.cs b/tests/MongoDB.Driver.Tests/Specifications/Runner/MongoClientJsonDrivenTestRunnerBase.cs
@@ -49,7 +49,8 @@ public abstract class MongoClientJsonDrivenTestRunnerBase
         private readonly string _skipReasonKey = "skipReason";
         private readonly HashSet<string> _defaultCommandsToNotCapture = new HashSet<string>
         {
-            "isMaster",
+            "hello",
+            OppressiveLanguageConstants.LegacyHelloCommandName,
             "buildInfo",
             "getLastError",
             "authenticate",
@@ -329,14 +330,30 @@ protected virtual bool TryConfigureClientOption(MongoClientSettings settings, Bs
                     settings.ConnectTimeout = TimeSpan.FromMilliseconds(option.Value.ToInt32());
                     break;
 
+                case "directConnection":
+                    settings.DirectConnection = option.Value.ToBoolean();
+                    break;
+
                 case "heartbeatFrequencyMS":
                     settings.HeartbeatInterval = TimeSpan.FromMilliseconds(option.Value.ToInt32());
                     break;
 
+                case "maxPoolSize":
+                    settings.MaxConnectionPoolSize = option.Value.ToInt32();
+                    break;
+
+                case "minPoolSize":
+                    settings.MinConnectionPoolSize = option.Value.ToInt32();
+                    break;
+
                 case "serverSelectionTimeoutMS":
                     settings.ServerSelectionTimeout = TimeSpan.FromMilliseconds(option.Value.ToInt32());
                     break;
 
+                case "socketTimeoutMS":
+                    settings.SocketTimeout = TimeSpan.FromMilliseconds(option.Value.ToInt32());
+                    break;
+
                 default:
                     return false;
             }
diff --git a/tests/MongoDB.Driver.Tests/Specifications/change-streams/ChangeStreamTestRunner.cs b/tests/MongoDB.Driver.Tests/Specifications/change-streams/ChangeStreamTestRunner.cs
@@ -25,6 +25,7 @@
 using MongoDB.Driver.Core.Bindings;
 using MongoDB.Driver.Core.Clusters.ServerSelectors;
 using MongoDB.Driver.Core.Events;
+using MongoDB.Driver.Core.Misc;
 using MongoDB.Driver.Core.TestHelpers;
 using MongoDB.Driver.Core.TestHelpers.JsonDrivenTests;
 using MongoDB.Driver.Core.TestHelpers.XunitExtensions;
@@ -91,7 +92,8 @@ private void Run(BsonDocument shared, BsonDocument test)
                 }
             }
 
-            if (test.Contains("expectations") && actualEvents != null)
+            // expectations == null indicates that expectations should not be asserted.
+            if (test.Contains("expectations") && !test["expectations"].IsBsonNull && actualEvents != null)
             {
                 var expectedEvents = test["expectations"].AsBsonArray.Cast<BsonDocument>().ToList();
                 AssertEvents(actualEvents, expectedEvents);
@@ -174,7 +176,8 @@ private EventCapturer CreateEventCapturer()
         {
             var commandsToNotCapture = new HashSet<string>
             {
-                "isMaster",
+                "hello",
+                OppressiveLanguageConstants.LegacyHelloCommandName,
                 "buildInfo",
                 "getLastError",
                 "authenticate",
diff --git a/tests/MongoDB.Driver.Tests/Specifications/client-side-encryption/prose-tests/ClientEncryptionProseTests.cs b/tests/MongoDB.Driver.Tests/Specifications/client-side-encryption/prose-tests/ClientEncryptionProseTests.cs
@@ -1497,7 +1497,8 @@ private EventCapturer CreateEventCapturer(string commandNameFilter = null)
         {
             var defaultCommandsToNotCapture = new HashSet<string>
             {
-                "isMaster",
+                "hello",
+                OppressiveLanguageConstants.LegacyHelloCommandName,
                 "buildInfo",
                 "getLastError",
                 "authenticate",
diff --git a/tests/MongoDB.Driver.Tests/Specifications/crud/CrudTestRunner.cs b/tests/MongoDB.Driver.Tests/Specifications/crud/CrudTestRunner.cs
@@ -21,6 +21,7 @@
 using MongoDB.Bson.TestHelpers.JsonDrivenTests;
 using MongoDB.Driver.Core;
 using MongoDB.Driver.Core.Events;
+using MongoDB.Driver.Core.Misc;
 using MongoDB.Driver.Core.TestHelpers.JsonDrivenTests;
 using MongoDB.Driver.Core.TestHelpers.XunitExtensions;
 using MongoDB.Driver.TestHelpers;
@@ -34,7 +35,8 @@ public class CrudTestRunner
         private static readonly HashSet<string> __commandsToNotCapture = new HashSet<string>
         {
             "configureFailPoint",
-            "isMaster",
+            "hello",
+            OppressiveLanguageConstants.LegacyHelloCommandName,
             "buildInfo",
             "getLastError",
             "authenticate",
diff --git a/tests/MongoDB.Driver.Tests/Specifications/retryable-reads/RetryableReadsTestRunner.cs b/tests/MongoDB.Driver.Tests/Specifications/retryable-reads/RetryableReadsTestRunner.cs
@@ -24,6 +24,7 @@
 using MongoDB.Driver.Core.Bindings;
 using MongoDB.Driver.Core.Clusters.ServerSelectors;
 using MongoDB.Driver.Core.Events;
+using MongoDB.Driver.Core.Misc;
 using MongoDB.Driver.Core.TestHelpers;
 using MongoDB.Driver.Core.TestHelpers.JsonDrivenTests;
 using MongoDB.Driver.Core.TestHelpers.XunitExtensions;
@@ -38,7 +39,8 @@ public sealed class RetryableReadsTestRunner
         #region static
         private static readonly HashSet<string> __commandsToNotCapture = new HashSet<string>
         {
-            "isMaster",
+            "hello",
+            OppressiveLanguageConstants.LegacyHelloCommandName,
             "buildInfo",
             "getLastError",
             "authenticate",
diff --git a/tests/MongoDB.Driver.Tests/Specifications/retryable-writes/prose-tests/CommandConstructionTests.cs b/tests/MongoDB.Driver.Tests/Specifications/retryable-writes/prose-tests/CommandConstructionTests.cs
@@ -435,7 +435,8 @@ private EventCapturer CreateEventCapturer()
         {
             var commandsToNotCapture = new HashSet<string>
             {
-                "isMaster",
+                "hello",
+                OppressiveLanguageConstants.LegacyHelloCommandName,
                 "buildInfo",
                 "getLastError",
                 "authenticate",
diff --git a/tests/MongoDB.Driver.Tests/Specifications/server-discovery-and-monitoring/ServerDiscoveryAndMonitoringIntegrationTestRunner.cs b/tests/MongoDB.Driver.Tests/Specifications/server-discovery-and-monitoring/ServerDiscoveryAndMonitoringIntegrationTestRunner.cs
@@ -18,7 +18,6 @@
 using System.Threading.Tasks;
 using MongoDB.Bson;
 using MongoDB.Bson.TestHelpers.JsonDrivenTests;
-using MongoDB.Driver;
 using MongoDB.Driver.Core;
 using MongoDB.Driver.Core.Bindings;
 using MongoDB.Driver.Core.Clusters;
diff --git a/tests/MongoDB.Driver.Tests/Specifications/transactions/TransactionTestRunner.cs b/tests/MongoDB.Driver.Tests/Specifications/transactions/TransactionTestRunner.cs
@@ -27,6 +27,7 @@
 using MongoDB.Driver.Core.Clusters;
 using MongoDB.Driver.Core.Clusters.ServerSelectors;
 using MongoDB.Driver.Core.Events;
+using MongoDB.Driver.Core.Misc;
 using MongoDB.Driver.Core.Servers;
 using MongoDB.Driver.Core.TestHelpers;
 using MongoDB.Driver.Core.TestHelpers.JsonDrivenTests;
@@ -43,7 +44,8 @@ public sealed class TransactionTestRunner : IJsonDrivenTestRunner, IDisposable
         private static readonly HashSet<string> __commandsToNotCapture = new HashSet<string>
         {
             "configureFailPoint",
-            "isMaster",
+            "hello",
+            OppressiveLanguageConstants.LegacyHelloCommandName,
             "buildInfo",
             "getLastError",
             "authenticate",
diff --git a/tests/MongoDB.Driver.Tests/Specifications/transactions/TransactionUnifiedTestRunner.cs b/tests/MongoDB.Driver.Tests/Specifications/transactions/TransactionUnifiedTestRunner.cs
@@ -27,6 +27,11 @@ public sealed class TransactionUnifiedTestRunner
         [ClassData(typeof(TestCaseFactory))]
         public void Run(JsonDrivenTestCase testCase)
         {
+            if (testCase.Name.Contains("mongos-unpin.json"))
+            {
+                throw new SkipException("Load balancer support not yet implemented.");
+            }
+
             using (var runner = new UnifiedTestRunner())
             {
                 runner.Run(testCase);
diff --git a/tests/MongoDB.Driver.Tests/UnifiedTestOperations/UnifiedEntityMap.cs b/tests/MongoDB.Driver.Tests/UnifiedTestOperations/UnifiedEntityMap.cs
@@ -501,7 +501,8 @@ private IGridFSBucket CreateBucket(BsonDocument entity, Dictionary<string, IMong
                     "configureFailPoint",
                     "getLastError",
                     "getnonce",
-                    "isMaster",
+                    "hello",
+                    OppressiveLanguageConstants.LegacyHelloCommandName,
                     "saslContinue",
                     "saslStart"
                 };

Original file line number	Diff line number	Diff line change
`@@ -222,6 +222,11 @@ private bool CanRunOn(ICluster cluster, BsonDocument requirement)`
`222`	`222`	`{`
`223`	`223`	`switch (item.Name)`
`224`	`224`	`{`
	`225`	`+ case "authEnabled":`
	`226`	`+ {`
	`227`	`+ var actualAuthentication = CoreTestConfiguration.ConnectionString.Username != null;`
	`228`	`+ return actualAuthentication == item.Value.AsBoolean;`
	`229`	`+ }`
`225`	`230`	`case "minServerVersion":`
`226`	`231`	`{`
`227`	`232`	`var actualVersion = CoreTestConfiguration.ServerVersion;`
`@@ -277,6 +282,7 @@ private ClusterType MapTopologyToClusterType(string topology)`
`277`	`282`	`{`
`278`	`283`	`switch (topology)`
`279`	`284`	`{`
	`285`	`+ case "load-balanced": throw new SkipException("Topology load-balanced has not been implemented yet.");`
`280`	`286`	`case "single": return Clusters.ClusterType.Standalone;`
`281`	`287`	`case "replicaset": return Clusters.ClusterType.ReplicaSet;`
`282`	`288`	`case "sharded-replicaset":`
Original file line number	Diff line number	Diff line change
`@@ -84,7 +84,7 @@ private void ApplyResponse(BsonArray response)`
`84`	`84`
`85`	`85`	`var address = response[0].AsString;`
`86`	`86`	`var isMasterDocument = response[1].AsBsonDocument;`
`87`		`- JsonDrivenHelper.EnsureAllFieldsAreValid(isMasterDocument, "hosts", "ismaster", "maxWireVersion", "minWireVersion", "ok", "primary", "secondary", "setName", "setVersion");`
	`87`	`+ JsonDrivenHelper.EnsureAllFieldsAreValid(isMasterDocument, "hosts", "isWritablePrimary", OppressiveLanguageConstants.LegacyHelloResponseIsWritablePrimaryFieldName, "maxWireVersion", "minWireVersion", "ok", "primary", "secondary", "setName", "setVersion");`
`88`	`88`
`89`	`89`	`var endPoint = EndPointHelper.Parse(address);`
`90`	`90`	`var isMasterResult = new IsMasterResult(isMasterDocument);`
`@@ -362,6 +362,12 @@ protected override IEnumerable<JsonDrivenTestCase> CreateTestCases(BsonDocument`
`362`	`362`	`var name = GetTestCaseName(document, document, 0);`
`363`	`363`	`yield return new JsonDrivenTestCase(name, document, document);`
`364`	`364`	`}`
	`365`	`+`
	`366`	`+ protected override bool ShouldReadJsonDocument(string path)`
	`367`	`+ {`
	`368`	`+ // load balancer support not yet implemented`
	`369`	`+ return base.ShouldReadJsonDocument(path) && !path.EndsWith("load_balancer.json");`
	`370`	`+ }`
`365`	`371`	`}`
`366`	`372`	`}`
`367`	`373`	`}`
Original file line number	Diff line number	Diff line change
`@@ -51,6 +51,11 @@ public void TestExplainWithFieldsAndCoveredIndex()`
`51`	`51`	`if (winningPlan.Contains("shards"))`
`52`	`52`	`{`
`53`	`53`	`winningPlan = winningPlan["shards"][0]["winningPlan"].AsBsonDocument;`
	`54`	`+ // MongoDB 5.0 changes the explain plan output to nest the shard's winningPlan 1 level deeper`
	`55`	`+ if (winningPlan.Contains("queryPlan"))`
	`56`	`+ {`
	`57`	`+ winningPlan = winningPlan["queryPlan"].AsBsonDocument;`
	`58`	`+ }`
`54`	`59`	`}`
`55`	`60`	`var inputStage = winningPlan["inputStage"].AsBsonDocument;`
`56`	`61`	`var stage = inputStage["stage"].AsString;`
Original file line number	Diff line number	Diff line change
`@@ -134,6 +134,11 @@ public void TestIndexNameHintIsUsedInQuery()`
`134`	`134`	`if (winningPlan.Contains("shards"))`
`135`	`135`	`{`
`136`	`136`	`winningPlan = winningPlan["shards"][0]["winningPlan"].AsBsonDocument;`
	`137`	`+ // MongoDB 5.0 changes the explain plan output to nest the shard's winningPlan 1 level deeper`
	`138`	`+ if (winningPlan.Contains("queryPlan"))`
	`139`	`+ {`
	`140`	`+ winningPlan = winningPlan["queryPlan"].AsBsonDocument;`
	`141`	`+ }`
`137`	`142`	`}`
`138`	`143`	`var inputStage = winningPlan["inputStage"].AsBsonDocument;`
`139`	`144`	`var stage = inputStage["stage"].AsString;`
`@@ -221,6 +226,11 @@ public void TestIndexDocumentHintIsUsedInQuery()`
`221`	`226`	`if (winningPlan.Contains("shards"))`
`222`	`227`	`{`
`223`	`228`	`winningPlan = winningPlan["shards"][0]["winningPlan"].AsBsonDocument;`
	`229`	`+ // MongoDB 5.0 changes the explain plan output to nest the shard's winningPlan 1 level deeper`
	`230`	`+ if (winningPlan.Contains("queryPlan"))`
	`231`	`+ {`
	`232`	`+ winningPlan = winningPlan["queryPlan"].AsBsonDocument;`
	`233`	`+ }`
`224`	`234`	`}`
`225`	`235`	`var inputStage = winningPlan["inputStage"].AsBsonDocument;`
`226`	`236`	`var stage = inputStage["stage"].AsString;`
Original file line number	Diff line number	Diff line change
`@@ -40,7 +40,8 @@ public class ClusterTests`
`40`	`40`	`{`
`41`	`41`	`private static readonly HashSet<string> __commandsToNotCapture = new HashSet<string>`
`42`	`42`	`{`
`43`		`- "isMaster",`
	`43`	`+ "hello",`
	`44`	`+ OppressiveLanguageConstants.LegacyHelloCommandName,`
`44`	`45`	`"buildInfo",`
`45`	`46`	`"getLastError",`
`46`	`47`	`"authenticate",`
Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,8 @@ public class PinnedShardRouterTests`
`34`	`34`	`{`
`35`	`35`	`private static readonly HashSet<string> __commandsToNotCapture = new HashSet<string>`
`36`	`36`	`{`
`37`		`- "isMaster",`
	`37`	`+ "hello",`
	`38`	`+ OppressiveLanguageConstants.LegacyHelloCommandName,`
`38`	`39`	`"buildInfo",`
`39`	`40`	`"getLastError",`
`40`	`41`	`"authenticate",`
Original file line number	Diff line number	Diff line change
`@@ -25,6 +25,7 @@`
`25`	`25`	`using MongoDB.Driver.Core.Bindings;`
`26`	`26`	`using MongoDB.Driver.Core.Clusters.ServerSelectors;`
`27`	`27`	`using MongoDB.Driver.Core.Events;`
	`28`	`+using MongoDB.Driver.Core.Misc;`
`28`	`29`	`using MongoDB.Driver.Core.TestHelpers;`
`29`	`30`	`using MongoDB.Driver.Core.TestHelpers.JsonDrivenTests;`
`30`	`31`	`using MongoDB.Driver.Core.TestHelpers.XunitExtensions;`
`@@ -91,7 +92,8 @@ private void Run(BsonDocument shared, BsonDocument test)`
`91`	`92`	`}`
`92`	`93`	`}`
`93`	`94`
`94`		`- if (test.Contains("expectations") && actualEvents != null)`
	`95`	`+ // expectations == null indicates that expectations should not be asserted.`
	`96`	`+ if (test.Contains("expectations") && !test["expectations"].IsBsonNull && actualEvents != null)`
`95`	`97`	`{`
`96`	`98`	`var expectedEvents = test["expectations"].AsBsonArray.Cast<BsonDocument>().ToList();`
`97`	`99`	`AssertEvents(actualEvents, expectedEvents);`
`@@ -174,7 +176,8 @@ private EventCapturer CreateEventCapturer()`
`174`	`176`	`{`
`175`	`177`	`var commandsToNotCapture = new HashSet<string>`
`176`	`178`	`{`
`177`		`- "isMaster",`
	`179`	`+ "hello",`
	`180`	`+ OppressiveLanguageConstants.LegacyHelloCommandName,`
`178`	`181`	`"buildInfo",`
`179`	`182`	`"getLastError",`
`180`	`183`	`"authenticate",`