improves

Author: otaviojava

mongodb-driver/src/main/java/org/jnosql/diana/mongodb/document/MongoAuthentication.java

@@ -15,7 +15,21 @@
 
 package org.jnosql.diana.mongodb.document;
 
+import com.mongodb.AuthenticationMechanism;
 import com.mongodb.MongoCredential;
+import org.jnosql.diana.api.Configurations;
+import org.jnosql.diana.api.JNoSQLException;
+import org.jnosql.diana.api.Settings;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.stream.Collectors;
+
+import static org.jnosql.diana.mongodb.document.MongoDBDocumentConfigurations.AUTHENTICATION_DATABASE;
+import static org.jnosql.diana.mongodb.document.MongoDBDocumentConfigurations.AUTHENTICATION_MECHANISM;
+import static org.jnosql.diana.mongodb.document.MongoDBDocumentConfigurations.PASSWORD;
+import static org.jnosql.diana.mongodb.document.MongoDBDocumentConfigurations.USER;
 
 final class MongoAuthentication {
 
@@ -25,15 +39,69 @@ final class MongoAuthentication {
 
     private final char[] password;
 
-    MongoAuthentication(String user, String database, char[] password) {
+    private final AuthenticationMechanism mechanism;
+
+    private MongoAuthentication(String user, String database, char[] password,
+                                AuthenticationMechanism mechanism) {
         this.user = user;
         this.database = database;
         this.password = password;
+        this.mechanism = mechanism;
     }
 
     MongoCredential toCredential() {
-        return MongoCredential.createCredential(user, database, password);
+        switch (mechanism) {
+            case PLAIN:
+                return MongoCredential.createPlainCredential(user, database, password);
+            case GSSAPI:
+                return MongoCredential.createGSSAPICredential(user);
+            case SCRAM_SHA_1:
+                return MongoCredential.createScramSha1Credential(user, database, password);
+            case MONGODB_X509:
+                return MongoCredential.createMongoX509Credential(user);
+            case SCRAM_SHA_256:
+                return MongoCredential.createScramSha256Credential(user, database, password);
+            default:
+                throw new JNoSQLException("There is not support to the type: " + mechanism);
+
+        }
     }
 
 
+    static List<MongoAuthentication> of(Settings settings) {
+
+        List<MongoAuthentication> authentications = new ArrayList<>();
+
+        List<String> users = settings.prefix(Arrays.asList(USER.get(),
+                Configurations.USER.get())).stream()
+                .map(Object::toString).collect(Collectors.toList());
+
+        List<String> passwords = settings.prefix(Arrays.asList(PASSWORD.get(),
+                Configurations.PASSWORD.get())).stream()
+                .map(Object::toString).collect(Collectors.toList());
+
+        List<String> databases = settings.prefix(AUTHENTICATION_DATABASE.get()).stream()
+                .map(Object::toString).collect(Collectors.toList());
+
+        AuthenticationMechanism mechanism = settings.get(AUTHENTICATION_MECHANISM.get())
+                .map(Object::toString)
+                .map(AuthenticationMechanism::fromMechanismName)
+                .orElse(AuthenticationMechanism.PLAIN);
+
+        if (users.size() != passwords.size() && users.size() != databases.size()) {
+            throw new JNoSQLException("There is an inconsistent number of authentication parameter");
+        }
+
+        for (int index = 0; index < databases.size(); index++) {
+            String user = users.get(index);
+            String password = passwords.get(index);
+            String database = databases.get(index);
+            MongoAuthentication authentication = new MongoAuthentication(user,
+                    database, password.toCharArray(), mechanism);
+            authentications.add(authentication);
+        }
+
+        return authentications;
+
+    }
 }

mongodb-driver/src/test/java/org/jnosql/diana/mongodb/document/MongoAuthenticationTest.java

@@ -0,0 +1,7 @@
+package org.jnosql.diana.mongodb.document;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+class MongoAuthenticationTest {
+
+}