allow more configuration of the database source

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.kapeta</groupId>
     <artifactId>nosql-mongodb</artifactId>
-    <version>1.1.1</version>
+    <version>1.1.2</version>
 
     <name>${project.groupId}:${project.artifactId}</name>
     <description>MongoDB support for Kapeta Spring Boot SDK</description>
@@ -158,6 +158,11 @@
             <version>[1.0,2.0)</version>
             <scope>provided</scope>
         </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter</artifactId>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
 </project>

src/main/java/com/kapeta/spring/mongo/AbstractMongoDBConfig.java

@@ -87,12 +87,25 @@ private MongoProperties createMongoProperties(String databaseName, String dbAuth
         return properties;
     }
 
-    private MongoProperties createMongoUriProperties(String databaseName, String dbAuthDB, ResourceInfo mongoInfo) {
+    protected MongoProperties createMongoUriProperties(String databaseName, String dbAuthDB, ResourceInfo mongoInfo) {
         String username = mongoInfo.getCredentials().get("username");
         String password = mongoInfo.getCredentials().getOrDefault("password","");
 
-        String uri = String.format("mongodb+srv://%s:%s@%s/%s?ssl=false&authSource=%s", username, password, mongoInfo.getHost(), databaseName, dbAuthDB);
+        String ssl = "ssl=false";
+        if(mongoInfo.getOptions().containsKey("ssl")) {
+            if (Boolean.parseBoolean(mongoInfo.getOptions().get("ssl").toString())) {
+                ssl = "ssl=true";
+            }
+        }
+        String dbAuthDBStr = String.format("&authSource=%s", dbAuthDB);
+        if (StringUtils.isEmpty(dbAuthDB)) {
+            dbAuthDBStr = "";
+        }
+
+        String uri = String.format("mongodb+srv://%s:%s@%s/%s?%s%s", username, password, mongoInfo.getHost(), databaseName,ssl, dbAuthDBStr);
+        // Override with environment variable if set
         if(!StringUtils.isEmpty(System.getenv("SPRING_DATA_MONGODB_URI"))) {
+            log.info("Overriding MongoDB URI with environment variable SPRING_DATA_MONGODB_URI");
             uri = System.getenv("SPRING_DATA_MONGODB_URI");
         }
 

src/test/java/com/kapeta/spring/mongo/AbstractMongoDBConfigTest.java

@@ -0,0 +1,110 @@
+/*
+ * Copyright 2023 Kapeta Inc.
+ * SPDX-License-Identifier: MIT
+ */
+package com.kapeta.spring.mongo;
+
+import com.kapeta.spring.config.providers.TestConfigProvider;
+import com.kapeta.spring.config.providers.types.ResourceInfo;
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.autoconfigure.mongo.MongoProperties;
+
+
+import java.util.HashMap;
+import java.util.Map;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+public class AbstractMongoDBConfigTest {
+
+
+    @Test
+    public void testCreateMongoUriProperties() {
+        Map<String, String> credentials = new HashMap<>();
+        credentials.put("username", "testUser");
+        credentials.put("password", "testPass");
+
+        Map<String, Object> options = new HashMap<>();
+        options.put("ssl", "true");
+
+        TestMongoDBConfig mongoDBConfig = new TestMongoDBConfig("testResource");
+
+        ResourceInfo resourceInfo = new ResourceInfo();
+        resourceInfo.setCredentials(credentials);
+        resourceInfo.setOptions(options);
+        resourceInfo.setHost("testHost");
+
+        MongoProperties properties = mongoDBConfig.createMongoUriProperties("testDB", "admin", resourceInfo);
+
+        assertEquals("mongodb+srv://testUser:testPass@testHost/testDB?ssl=true&authSource=admin", properties.getUri());
+    }
+
+
+    @Test
+    public void testSSLFalse() {
+        Map<String, String> credentials = new HashMap<>();
+        credentials.put("username", "testUser");
+        credentials.put("password", "testPass");
+
+        Map<String, Object> options = new HashMap<>();
+        options.put("ssl", "false");
+
+        TestMongoDBConfig mongoDBConfig = new TestMongoDBConfig("testResource");
+
+        ResourceInfo resourceInfo = new ResourceInfo();
+        resourceInfo.setCredentials(credentials);
+        resourceInfo.setOptions(options);
+        resourceInfo.setHost("testHost");
+
+        MongoProperties properties = mongoDBConfig.createMongoUriProperties("testDB", "admin", resourceInfo);
+
+        assertEquals("mongodb+srv://testUser:testPass@testHost/testDB?ssl=false&authSource=admin", properties.getUri());
+    }
+
+    @Test
+    public void testEmptySSLConfig() {
+        Map<String, String> credentials = new HashMap<>();
+        credentials.put("username", "testUser");
+        credentials.put("password", "testPass");
+
+        Map<String, Object> options = new HashMap<>();
+
+        TestMongoDBConfig mongoDBConfig = new TestMongoDBConfig("testResource");
+
+        ResourceInfo resourceInfo = new ResourceInfo();
+        resourceInfo.setCredentials(credentials);
+        resourceInfo.setOptions(options);
+        resourceInfo.setHost("testHost");
+
+        MongoProperties properties = mongoDBConfig.createMongoUriProperties("testDB", "admin", resourceInfo);
+
+        assertEquals("mongodb+srv://testUser:testPass@testHost/testDB?ssl=false&authSource=admin", properties.getUri());
+    }
+
+    @Test
+    public void testEmptyAuthSource() {
+        Map<String, String> credentials = new HashMap<>();
+        credentials.put("username", "testUser");
+        credentials.put("password", "testPass");
+
+        Map<String, Object> options = new HashMap<>();
+        options.put("ssl", "true");
+
+        TestMongoDBConfig mongoDBConfig = new TestMongoDBConfig("testResource");
+
+        ResourceInfo resourceInfo = new ResourceInfo();
+        resourceInfo.setCredentials(credentials);
+        resourceInfo.setOptions(options);
+        resourceInfo.setHost("testHost");
+
+        MongoProperties properties = mongoDBConfig.createMongoUriProperties("testDB", "", resourceInfo);
+
+        assertEquals("mongodb+srv://testUser:testPass@testHost/testDB?ssl=true", properties.getUri());
+    }
+
+    private class TestMongoDBConfig extends AbstractMongoDBConfig {
+        public TestMongoDBConfig(String resourceName) {
+            super(resourceName);
+        }
+    }
+}