Add prose tests.

JAVA-5854

Author: vbabanin

buildSrc/src/main/kotlin/conventions/testing-base.gradle.kts

@@ -105,3 +105,7 @@ testlogger {
     showFailedStandardStreams = true
     logLevel = LogLevel.LIFECYCLE
 }
+
+dependencies {
+    testImplementation(libs.assertj)
+}

driver-core/src/main/com/mongodb/internal/connection/InternalStreamConnectionFactory.java

@@ -33,7 +33,6 @@ class InternalStreamConnectionFactory implements InternalConnectionFactory {
     private final ClusterConnectionMode clusterConnectionMode;
     private final boolean isMonitoringConnection;
     private final StreamFactory streamFactory;
-    //TODO UPDATE
     private final ClientMetadata clientMetadata;
     private final List<MongoCompressor> compressorList;
     private final LoggerSettings loggerSettings;

driver-kotlin-coroutine/src/integrationTest/kotlin/com/mongodb/kotlin/client/coroutine/syncadapter/SyncMongoClient.kt

@@ -25,7 +25,7 @@ internal class SyncMongoClient(override val wrapped: MongoClient) : SyncMongoClu
 
     override fun getClusterDescription(): ClusterDescription = wrapped.getClusterDescription()
 
-    override fun updateClientMetadata(mongoDriverInformation: MongoDriverInformation) {
-        // TODO
+    override fun updateMetadata(mongoDriverInformation: MongoDriverInformation) {
+        throw UnsupportedOperationException("TODO-JAVA-5871")
     }
 }

driver-kotlin-sync/src/integrationTest/kotlin/com/mongodb/kotlin/client/syncadapter/SyncMongoClient.kt

@@ -24,7 +24,7 @@ internal class SyncMongoClient(override val wrapped: MongoClient) : SyncMongoClu
     override fun close(): Unit = wrapped.close()
 
     override fun getClusterDescription(): ClusterDescription = wrapped.clusterDescription
-    override fun updateClientMetadata(mongoDriverInformation: MongoDriverInformation) {
-        TODO("Not yet implemented")
+    override fun updateMetadata(mongoDriverInformation: MongoDriverInformation) {
+        throw UnsupportedOperationException("TODO-JAVA-5871")
     }
 }

driver-reactive-streams/src/main/com/mongodb/reactivestreams/client/MongoClient.java

@@ -16,6 +16,7 @@
 
 package com.mongodb.reactivestreams.client;
 
+import com.mongodb.MongoDriverInformation;
 import com.mongodb.annotations.Immutable;
 import com.mongodb.connection.ClusterDescription;
 import com.mongodb.connection.ClusterSettings;
@@ -58,4 +59,7 @@ public interface MongoClient extends MongoCluster, Closeable {
      * @since 4.1
      */
     ClusterDescription getClusterDescription();
+
+
+    void updateMetadata(MongoDriverInformation mongoDriverInformation);
 }

driver-reactive-streams/src/main/com/mongodb/reactivestreams/client/internal/MongoClientImpl.java

@@ -325,4 +325,9 @@ public MongoDatabase getDatabase(final String name) {
     public ClusterDescription getClusterDescription() {
         return getCluster().getCurrentDescription();
     }
+
+    @Override
+    public void updateMetadata(final MongoDriverInformation mongoDriverInformation) {
+        getCluster().getClientMetadata().append(mongoDriverInformation);
+    }
 }

driver-reactive-streams/src/test/functional/com/mongodb/reactivestreams/client/AbstractClientMetadataProseTest.java

@@ -0,0 +1,34 @@
+/*
+ * Copyright 2008-present MongoDB, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.mongodb.reactivestreams.client;
+
+import com.mongodb.MongoClientSettings;
+import com.mongodb.MongoDriverInformation;
+import com.mongodb.client.AbstractClientMetadataProseTest;
+import com.mongodb.client.MongoClient;
+import com.mongodb.lang.Nullable;
+import com.mongodb.reactivestreams.client.syncadapter.SyncMongoClient;
+
+/**
+ * See <a href="https://github.com/mongodb/specifications/blob/master/source/mongodb-handshake/handshake.md#test-plan">spec</a>
+ */
+class ClientMetadataProseTest extends AbstractClientMetadataProseTest {
+
+    protected MongoClient createMongoClient(@Nullable final MongoDriverInformation mongoDriverInformation, final MongoClientSettings mongoClientSettings) {
+        return new SyncMongoClient(MongoClients.create(mongoClientSettings, mongoDriverInformation));
+    }
+}

driver-reactive-streams/src/test/functional/com/mongodb/reactivestreams/client/syncadapter/SyncMongoClient.java

@@ -313,8 +313,7 @@ public ClusterDescription getClusterDescription() {
     }
 
     @Override
-    public void updateClientMetadata(final MongoDriverInformation mongoDriverInformation) {
-        //TODO
+    public void updateMetadata(final MongoDriverInformation mongoDriverInformation) {
+        wrapped.updateMetadata(mongoDriverInformation);
     }
-
 }

driver-scala/src/integrationTest/scala/org/mongodb/scala/syncadapter/SyncMongoClient.scala

@@ -1,20 +1,15 @@
 package org.mongodb.scala.syncadapter
 
-import com.mongodb.ClientSessionOptions
-import com.mongodb.client.{ ClientSession, MongoClient => JMongoClient, MongoDatabase => JMongoDatabase }
-import org.bson.Document
-import org.bson.conversions.Bson
+import com.mongodb.MongoDriverInformation
+import com.mongodb.client.{MongoClient => JMongoClient}
 import org.mongodb.scala.MongoClient
-import org.mongodb.scala.bson.DefaultHelper.DefaultsTo
-
-import scala.collection.JavaConverters._
-import scala.concurrent.Await
-import scala.reflect.ClassTag
 
 case class SyncMongoClient(wrapped: MongoClient) extends SyncMongoCluster(wrapped) with JMongoClient {
 
   override def close(): Unit = wrapped.close()
 
   override def getClusterDescription = throw new UnsupportedOperationException
 
+  override def updateMetadata(mongoDriverInformation: MongoDriverInformation): Unit =
+    throw new UnsupportedOperationException("TODO-JAVA-5871")
 }

driver-sync/src/main/com/mongodb/client/MongoClient.java

@@ -63,5 +63,5 @@ public interface MongoClient extends MongoCluster, Closeable {
      */
     ClusterDescription getClusterDescription();
 
-    void updateClientMetadata(MongoDriverInformation mongoDriverInformation);
+    void updateMetadata(MongoDriverInformation mongoDriverInformation);
 }