refs #198: async support

Author: William Delanoue

CHANGELOG

@@ -21,7 +21,7 @@ release : 13 November 2013
 -----
 release: 02 November 2013
 
-Apologees, it's been a long time since a release. I'm no longer using fongo at Foursquare, so I'll be looking to hand 
+Apologees, it's been a long time since a release. I'm no longer using fongo at Foursquare, so I'll be looking to hand
 it over to an enthusiastic maintainer in the near future.
 
 All changes below by @twillouer:

README.md

@@ -11,18 +11,18 @@ don't want to spin up a `mongod` process.
 ## Usage
 Add dependency to your project:
 
-### If you use 3.X drivers
+### If you use 3.X drivers (async included)
 
 ```xml
 <dependency>
   <groupId>com.github.fakemongo</groupId>
   <artifactId>fongo</artifactId>
-  <version>2.0.6</version>
+  <version>2.1.0</version>
   <scope>test</scope>
 </dependency>
 ```
 
-[Other dependency management](http://search.maven.org/#artifactdetails|com.github.fakemongo|fongo|2.0.0)
+[Other dependency management](http://search.maven.org/#artifactdetails|com.github.fakemongo|fongo|2.1.0)
 
 ### If you use 2.X drivers (this branch *fongo-drivers-2.x*) will be deprecated soon
 
@@ -35,7 +35,7 @@ Add dependency to your project:
 </dependency>
 ```
 
-[Other dependency management](http://search.maven.org/#artifactdetails|com.github.fakemongo|fongo|1.6.2)
+[Other dependency management](http://search.maven.org/#artifactdetails|com.github.fakemongo|fongo|1.6.5)
 
 
 *Alternatively: clone this repo and build the jar: `mvn package` then copy jar to your classpath*
@@ -76,7 +76,7 @@ It also has a "provided" dependency on sl4j-api for logging. If you don't alread
 <dependency> 
   <groupId>ch.qos.logback</groupId>
   <artifactId>logback-classic</artifactId>
-  <version>1.1.1</version>
+  <version>1.1.7</version>
   <scope>test</scope>
 </dependency>
 ```
@@ -145,6 +145,35 @@ public FongoRule fongoRule = new FongoRule(new ServerVersion(2, 6));
 
 In this case, the drivers didn't handle queries with the same way.
 
+## Junit (async drivers)    
+
+If you use JUnit in your project, you can use Rule to instantiate a `Fongo` object :
+
+```java
+@Rule
+public FongoAsyncRule fongoAsyncRule = new FongoAsyncRule();
+```
+
+If you need, you can easily switch to your real MongoDB server (on localhost for now).
+
+```java
+@Rule
+public FongoAsyncRule fongoAsyncRule = new FongoAsyncRule(true);
+```
+
+WARNING : In this case, the database WILL BE DROPPED when test is finish.
+So, use a random database name (e.g. UUID), BUT NOT your real database.
+
+You can specify the version of the database with :
+
+```java
+@Rule
+public FongoAsyncRule fongoAsyncRule = new FongoAsyncRule(new ServerVersion(2, 6));
+```
+
+In this case, the drivers didn't handle queries with the same way.
+
+
 ## Text Search Simulation
 Fongo simulates [text search](http://docs.mongodb.org/manual/reference/command/text/) now.
 The results of text search are quite similar to real, but not exactly.
@@ -201,6 +230,7 @@ your name to the patch contributors below. Please maintain the same code formatt
 
 ## Changelog
 
+Version 2.1.0 include compatibility with 3.X async driver version.
 Version 2.0.0 break compatibility with 2.X driver version.
 Version 1.6.0 break compatibility with 2.12.X driver version.
 

pom.xml

@@ -7,7 +7,7 @@
     </parent>
     <groupId>com.github.fakemongo</groupId>
     <artifactId>fongo</artifactId>
-    <version>2.0.13-SNAPSHOT</version>
+    <version>2.1.0-SNAPSHOT</version>
     <name>fongo</name>
     <description>Fake in-memory mongo</description>
     <url>https://github.com/fakemongo/fongo</url>
@@ -73,7 +73,13 @@
         <dependency>
             <groupId>org.mongodb</groupId>
             <artifactId>mongo-java-driver</artifactId>
-            <version>3.4.1</version>
+            <version>3.4.2</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.mongodb</groupId>
+            <artifactId>mongodb-driver-async</artifactId>
+            <version>3.4.2</version>
             <scope>provided</scope>
         </dependency>
         <dependency>
@@ -151,7 +157,7 @@
         <dependency>
             <groupId>com.google.guava</groupId>
             <artifactId>guava</artifactId>
-            <version>19.0</version>
+            <version>21.0</version>
             <scope>test</scope>
         </dependency>
 
@@ -183,13 +189,13 @@
         <dependency>
             <groupId>org.openjdk.jmh</groupId>
             <artifactId>jmh-core</artifactId>
-            <version>1.12</version>
+            <version>1.17.4</version>
             <scope>test</scope>
         </dependency>
         <dependency>
             <groupId>org.openjdk.jmh</groupId>
             <artifactId>jmh-generator-annprocess</artifactId>
-            <version>1.12</version>
+            <version>1.17.4</version>
             <scope>test</scope>
         </dependency>
         <dependency>
@@ -277,7 +283,7 @@
             <plugin>
                 <groupId>net.alchim31.maven</groupId>
                 <artifactId>scala-maven-plugin</artifactId>
-                <version>3.2.0</version>
+                <version>3.2.2</version>
                 <executions>
                     <execution>
                         <goals>
@@ -330,7 +336,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-javadoc-plugin</artifactId>
-                <version>2.10.2</version>
+                <version>2.10.3</version>
                 <configuration>
                     <excludePackageNames>com.mongodb:com.github.fakemongo.impl</excludePackageNames>
                 </configuration>

src/main/java/com/github/fakemongo/AwaitResultSingleResultCallback.java

@@ -0,0 +1,33 @@
+package com.github.fakemongo;
+
+import com.mongodb.async.SingleResultCallback;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+
+public class AwaitResultSingleResultCallback<T> implements SingleResultCallback<T> {
+
+  private T result;
+  private Throwable throwable;
+  private CountDownLatch countDownLatch = new CountDownLatch(1);
+
+  @Override
+  public void onResult(T result, Throwable t) {
+    this.result = result;
+    throwable = t;
+    countDownLatch.countDown();
+  }
+
+  public T awaitResult() throws Throwable {
+    return awaitResult(1, TimeUnit.MINUTES);
+  }
+
+  public T awaitResult(long time, TimeUnit timeUnit) throws Throwable {
+    if (!countDownLatch.await(time, timeUnit)) {
+      throw new RuntimeException("take too much time...");
+    }
+    if (throwable != null) {
+      throw throwable;
+    }
+    return result;
+  }
+}

src/main/java/com/github/fakemongo/FongoConnection.java

@@ -540,6 +540,13 @@ public <T> T command(String database, BsonDocument command, boolean slaveOk, Fie
 //          new BsonInt64(0)).append("ns", new BsonString(dbCollection.getFullName()))
 //          .append("firstBatch", FongoBsonArrayWrapper.bsonArrayWrapper(each)));
       return reencode(commandResultDecoder, "cursor", new BasicDBObject("id", 0L).append("ns", dbCollection.getFullName()).append("firstBatch", each));
+    } else if (command.containsKey("listDatabases")) {
+      final List<String> databaseNames = fongo.getDatabaseNames();
+      final List<BsonDocument> documents = new ArrayList<BsonDocument>();
+      for (String databaseName : databaseNames) {
+        documents.add(new BsonDocument("name", new BsonString(databaseName)));
+      }
+      return (T) new BsonDocument("databases", FongoBsonArrayWrapper.bsonArrayWrapper(documents));
     } else {
       LOG.warn("Command not implemented: {}", command);
       throw new FongoException("Not implemented for command : " + JSON.serialize(dbObject(command)));