Ensure redacted commands are logged with elision

JAVA-4195

Author: jyemin

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

@@ -66,9 +66,10 @@ class LoggingCommandEventSender implements CommandEventSender {
     @Override
     public void sendStartedEvent() {
         if (loggingRequired()) {
+            String commandString = redactionRequired ? String.format("{\"%s\": ...", commandName) : getTruncatedJsonCommand();
             logger.debug(
                     format("Sending command '%s' with request id %d to database %s on connection [%s] to server %s",
-                            getTruncatedJsonCommand(), message.getId(),
+                            commandString, message.getId(),
                             message.getNamespace().getDatabaseName(), description.getConnectionId(), description.getServerAddress()));
         }
 

driver-core/src/test/unit/com/mongodb/internal/connection/LoggingCommandEventSenderSpecification.groovy

@@ -155,4 +155,32 @@ class LoggingCommandEventSenderSpecification extends Specification {
                     'to server 127.0.0.1:27017'
         }
     }
+
+    def 'should log redacted command with ellipses'() {
+        given:
+        def connectionDescription = new ConnectionDescription(new ServerId(new ClusterId(), new ServerAddress()))
+        def namespace = new MongoNamespace('test.driver')
+        def messageSettings = MessageSettings.builder().maxWireVersion(THREE_DOT_SIX_WIRE_VERSION).build()
+        def commandDocument = new BsonDocument('createUser', new BsonString('private'))
+        def message = new CommandMessage(namespace, commandDocument, new NoOpFieldNameValidator(), ReadPreference.primary(),
+                messageSettings, null)
+        def bsonOutput = new ByteBufferBsonOutput(new SimpleBufferProvider())
+        message.encode(bsonOutput, NoOpSessionContext.INSTANCE)
+        def logger = Mock(Logger) {
+            isDebugEnabled() >> true
+        }
+        def sender = new LoggingCommandEventSender(['createUser'] as Set, [] as Set, connectionDescription, null, message, bsonOutput,
+                logger)
+
+        when:
+        sender.sendStartedEvent()
+
+        then:
+        1 * logger.debug {
+            it == "Sending command \'{\"createUser\": ...\' " +
+                    "with request id ${message.getId()} to database test " +
+                    "on connection [connectionId{localValue:${connectionDescription.connectionId.localValue}}] " +
+                    'to server 127.0.0.1:27017'
+        }
+    }
 }