WIP

Author: qingyang-hu

internal/integration/sessions_test.go

@@ -597,7 +597,10 @@ func TestSessionsProse(t *testing.T) {
 		})
 	*/
 
-	mt.Run("ping test", func(mt *mtest.T) {
+	pingOpts := mtest.NewOptions().
+		CreateCollection(false).
+		Topologies(mtest.ReplicaSet) // Read preference isn't sent to standalones so we can test on replica sets.
+	mt.RunOpts("ping test", pingOpts, func(mt *mtest.T) {
 		serverMonitor := &event.ServerMonitor{
 			ServerHeartbeatStarted: func(e *event.ServerHeartbeatStartedEvent) {
 				fmt.Println("Server heartbeat started:", e.ConnectionID)
@@ -616,10 +619,12 @@ func TestSessionsProse(t *testing.T) {
 			},
 		}
 
+		firstServerAddr := mtest.GlobalTopology().Description().Servers[0].Addr
 		opts := options.Client().
-			ApplyURI(mtest.ClusterURI()).
-			// SetHosts([]string{mtest.ClusterConnString().Hosts[0]}).
-			// SetDirect(true).
+			ApplyURI(fmt.Sprintf("mongodb://%s", firstServerAddr)).
+			SetHeartbeatInterval(500 * time.Millisecond). // Minimum interval
+			SetReadPreference(readpref.Primary()).
+			SetDirect(true).
 			SetHeartbeatInterval(500 * time.Millisecond). // Minimum interval
 			SetServerMonitor(serverMonitor).
 			SetMonitor(commandMonitor)
@@ -632,7 +637,8 @@ func TestSessionsProse(t *testing.T) {
 		}()
 
 		err = client.Ping(context.Background(), readpref.Primary())
-		require.NoError(mt, err, "expected no error, got: %v", err)
+		assert.NoError(mt, err, "expected no error, got: %v", err)
+		// mt.Fatal(mtest.ClusterURI(), mtest.ClusterConnString().Hosts, mtest.GlobalTopology().Description().Servers)
 	})
 }