Add support for auth db

.gitignore

@@ -4,3 +4,5 @@
 .DS_Store
 .vagrant
 target
+*.iml
+.idea

bundle/src/main/java/com/meltmedia/dropwizard/mongo/MongoClientBuilder.java

@@ -101,9 +101,11 @@ static List<ServerAddress> createServerAddressList( List<Server> seeds ) {
 
   static List<MongoCredential> createCredentials( MongoConfiguration configuration ) {
     Credentials credentialConfig = configuration.getCredentials();
+    final String authenticationDatabase = Optional.ofNullable(configuration.getAuthenticationDatabase())
+            .orElse(configuration.getDatabase());
     List<MongoCredential> credentials = credentialConfig == null ?
     Collections.<MongoCredential>emptyList() :
-    Collections.singletonList(MongoCredential.createCredential(credentialConfig.getUserName(), configuration.getDatabase(), credentialConfig
+    Collections.singletonList(MongoCredential.createCredential(credentialConfig.getUserName(), authenticationDatabase, credentialConfig
       .getPassword().toCharArray()));
 
     if( credentials.isEmpty() ) {

bundle/src/main/java/com/meltmedia/dropwizard/mongo/MongoConfiguration.java

@@ -37,6 +37,7 @@ public class MongoConfiguration {
   protected String database;
   protected boolean enabled = true;
   protected Boolean alwaysUseMBeans;
+  protected String authenticationDatabase;
   protected Integer connectionsPerHost;
   protected Integer connectTimeout;
   protected Boolean cursorFinalizerEnabled;
@@ -95,6 +96,12 @@ public void setDatabase( String database ) {
     this.database = database;
   }
 
+  public String getAuthenticationDatabase() {
+    return authenticationDatabase;
+  }
+  public void setAuthenticationDatabase( String authenticationDatabase ) {
+    this.authenticationDatabase = authenticationDatabase;
+  }
   public Boolean getAlwaysUseMBeans() {
     return alwaysUseMBeans;
   }

bundle/src/main/java/com/meltmedia/dropwizard/mongo/junit/MongoRule.java

@@ -15,12 +15,17 @@
  */
 package com.meltmedia.dropwizard.mongo.junit;
 
+import com.mongodb.MongoCredential;
+import com.mongodb.ServerAddress;
 import org.junit.rules.TestRule;
 import org.junit.runner.Description;
 import org.junit.runners.model.Statement;
 
 import com.mongodb.MongoClient;
 
+import java.util.Arrays;
+import java.util.List;
+
 /**
  * A JUnit Rule for creating a mongo client. This rule is designed to be used as
  * a ClassRule.
@@ -33,12 +38,26 @@ public class MongoRule
   MongoClient mongoClient;
   String host;
   int port;
+  String user;
+  String password;
+  String authenticationDatabase;
 
   public MongoRule( String host, int port ) {
     this.host = host;
     this.port = port;
   }
 
+  public MongoRule( String host, int port , String user, String password ) {
+    this(host, port);
+    this.user = user;
+    this.password = password;
+  }
+
+  public MongoRule( String host, int port, String user, String password, String authenticationDatabase ) {
+    this(host, port, user, password);
+    this.authenticationDatabase = authenticationDatabase;
+  }
+
   /**
    * Return an instance of the mongo client when this rule is in effect.
    * 
@@ -58,7 +77,10 @@ public Statement apply( final Statement statement, final Description description
       @Override
       public void evaluate() throws Throwable {
         try {
-          mongoClient = new MongoClient(host, port);
+          final MongoCredential credential = MongoCredential.createCredential(user,authenticationDatabase, password.toCharArray());
+          final List<MongoCredential> creds = Arrays.asList(credential);
+          final ServerAddress dbAddress = new ServerAddress(host, port);
+          mongoClient = new MongoClient(dbAddress, creds);
           statement.evaluate();
         } finally {
           if( mongoClient != null ) {

bundle/src/test/java/com/meltmedia/dropwizard/mongo/rxoplog/RxOplogServiceIT.java

@@ -25,7 +25,7 @@
  */
 public class RxOplogServiceIT {
   @ClassRule
-  public static MongoRule mongo = new MongoRule("localhost", 27017);
+  public static MongoRule mongo = new MongoRule("localhost", 27017, "admin", "password", "admin");
 
   @Test
   public void clientWorks() {

example/conf/example.yml

@@ -4,6 +4,7 @@ mongo:
   - host: "localhost"
     port: 27017
   database: "example"
+  authenticationDatabase: "admin"
   credentials:
     userName: "example"
     password:

jongo/src/test/java/com/meltmedia/dropwizard/jongo/JongoBundleIT.java

@@ -17,7 +17,7 @@
 import io.dropwizard.setup.Environment;
 
 public class JongoBundleIT {
-  @ClassRule public static MongoRule mongoRule = new MongoRule("localhost", 27017);
+  @ClassRule public static MongoRule mongoRule = new MongoRule("localhost", 27017, "admin", "password", "admin");
 
   Bootstrap<?> bootstrap = mock(Bootstrap.class);
   Configuration configuration = mock(Configuration.class);

jongo/src/test/java/com/meltmedia/dropwizard/jongo/ObjectIdMappingIT.java

@@ -21,7 +21,7 @@
  *
  */
 public class ObjectIdMappingIT {
-  @ClassRule public static MongoRule mongoRule = new MongoRule("localhost", 27017);
+  @ClassRule public static MongoRule mongoRule = new MongoRule("localhost", 27017, "admin", "password", "admin");
 
   public abstract class ObjectIdOnly {
     @org.jongo.marshall.jackson.oid.MongoObjectId

pom.xml

@@ -26,7 +26,7 @@
   <artifactId>dropwizard-mongo-parent</artifactId>
   <version>0.6.0-SNAPSHOT</version>
   <packaging>pom</packaging>
-  <name>Dropwizard Mogno Parent</name>
+  <name>Dropwizard Mongo Parent</name>
   <description>A Dropwizard Bundle for accessing Mongo.</description>
   <url>http://github.com/meltmedia/dropwizard-mongo</url>
   <inceptionYear>2014</inceptionYear>
@@ -237,7 +237,7 @@
         <plugin>
           <groupId>org.skife.maven</groupId>
           <artifactId>really-executable-jar-maven-plugin</artifactId>
-          <version>1.0.5</version>
+          <version>1.5.0</version>
           <configuration>
             <programFile>${program.file}</programFile>
             <flags>-Djava.net.preferIPv4Stack=true</flags>