Extract method for duplicated logic checking for whether mongocryptd is disabled

JAVA-4739

Author: jyemin

driver-core/src/main/com/mongodb/internal/capi/MongoCryptHelper.java

@@ -138,6 +138,13 @@ private static BsonDocument toBsonDocument(final Map<String, Object> optionsMap)
         return new BsonDocumentWrapper<>(new Document(optionsMap), new DocumentCodec());
     }
 
+    public static boolean isMongocryptdSpawningDisabled(@Nullable final String cryptSharedLibVersion,
+            final AutoEncryptionSettings settings) {
+        boolean cryptSharedLibIsAvailable = cryptSharedLibVersion != null && cryptSharedLibVersion.isEmpty();
+        boolean cryptSharedLibRequired = (boolean) settings.getExtraOptions().getOrDefault("cryptSharedLibRequired", false);
+        return settings.isBypassAutoEncryption() || settings.isBypassQueryAnalysis() || cryptSharedLibRequired || cryptSharedLibIsAvailable;
+    }
+
     @SuppressWarnings("unchecked")
     public static List<String> createMongocryptdSpawnArgs(final Map<String, Object> options) {
         List<String> spawnArgs = new ArrayList<>();

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

@@ -34,6 +34,7 @@
 import static com.mongodb.assertions.Assertions.assertNotNull;
 import static com.mongodb.internal.capi.MongoCryptHelper.createMongocryptdClientSettings;
 import static com.mongodb.internal.capi.MongoCryptHelper.createProcessBuilder;
+import static com.mongodb.internal.capi.MongoCryptHelper.isMongocryptdSpawningDisabled;
 import static com.mongodb.internal.capi.MongoCryptHelper.startProcess;
 
 @SuppressWarnings("UseOfProcessBuilder")
@@ -62,18 +63,12 @@ class CommandMarker implements Closeable {
     CommandMarker(
             final MongoCrypt mongoCrypt,
             final AutoEncryptionSettings settings) {
-        Map<String, Object> extraOptions = settings.getExtraOptions();
-        String cryptSharedLibVersionString = mongoCrypt.getCryptSharedLibVersionString();
 
-        boolean bypassAutoEncryption = settings.isBypassAutoEncryption();
-        boolean isBypassQueryAnalysis = settings.isBypassQueryAnalysis();
-        boolean cryptSharedIsAvailable = cryptSharedLibVersionString != null && cryptSharedLibVersionString.isEmpty();
-        boolean cryptSharedLibRequired = (boolean) extraOptions.getOrDefault("cryptSharedLibRequired", false);
-
-        if (bypassAutoEncryption || isBypassQueryAnalysis || cryptSharedLibRequired || cryptSharedIsAvailable) {
+        if (isMongocryptdSpawningDisabled(mongoCrypt.getCryptSharedLibVersionString(), settings)) {
             processBuilder = null;
             client = null;
         } else {
+            Map<String, Object> extraOptions = settings.getExtraOptions();
             boolean mongocryptdBypassSpawn = (boolean) extraOptions.getOrDefault("mongocryptdBypassSpawn", false);
             if (!mongocryptdBypassSpawn) {
                 processBuilder = createProcessBuilder(extraOptions);

driver-sync/src/main/com/mongodb/client/internal/CommandMarker.java

@@ -34,6 +34,7 @@
 import static com.mongodb.assertions.Assertions.assertNotNull;
 import static com.mongodb.internal.capi.MongoCryptHelper.createMongocryptdClientSettings;
 import static com.mongodb.internal.capi.MongoCryptHelper.createProcessBuilder;
+import static com.mongodb.internal.capi.MongoCryptHelper.isMongocryptdSpawningDisabled;
 import static com.mongodb.internal.capi.MongoCryptHelper.startProcess;
 
 @SuppressWarnings("UseOfProcessBuilder")
@@ -62,18 +63,12 @@ class CommandMarker implements Closeable {
     CommandMarker(
             final MongoCrypt mongoCrypt,
             final AutoEncryptionSettings settings) {
-        Map<String, Object> extraOptions = settings.getExtraOptions();
-        String cryptSharedLibVersionString = mongoCrypt.getCryptSharedLibVersionString();
 
-        boolean bypassAutoEncryption = settings.isBypassAutoEncryption();
-        boolean isBypassQueryAnalysis = settings.isBypassQueryAnalysis();
-        boolean cryptSharedIsAvailable = cryptSharedLibVersionString != null && cryptSharedLibVersionString.isEmpty();
-        boolean cryptSharedLibRequired = (boolean) extraOptions.getOrDefault("cryptSharedLibRequired", false);
-
-        if (bypassAutoEncryption || isBypassQueryAnalysis || cryptSharedLibRequired || cryptSharedIsAvailable) {
+        if (isMongocryptdSpawningDisabled(mongoCrypt.getCryptSharedLibVersionString(), settings)) {
             processBuilder = null;
             client = null;
         } else {
+            Map<String, Object> extraOptions = settings.getExtraOptions();
             boolean mongocryptdBypassSpawn = (boolean) extraOptions.getOrDefault("mongocryptdBypassSpawn", false);
             if (!mongocryptdBypassSpawn) {
                 processBuilder = createProcessBuilder(extraOptions);