add missing embedded mongoDB

Change-Id: I141c429a1bf4c32e49fe992a77f40b2ed9f3ed72

Author: Vali (Vasile Baluta)

src/test/java/com/ericsson/ei/handlers/test/ObjectHandlerTest.java

@@ -27,13 +27,22 @@
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 
+import de.flapdoodle.embed.mongo.MongodExecutable;
+import de.flapdoodle.embed.mongo.MongodProcess;
+import de.flapdoodle.embed.mongo.MongodStarter;
+import de.flapdoodle.embed.mongo.config.IMongodConfig;
+import de.flapdoodle.embed.mongo.config.MongodConfigBuilder;
+import de.flapdoodle.embed.mongo.config.Net;
+import de.flapdoodle.embed.mongo.distribution.Version;
+import de.flapdoodle.embed.process.runtime.Network;
+
 public class ObjectHandlerTest {
 
     static Logger log = (Logger) LoggerFactory.getLogger(ObjectHandlerTest.class);
 
     static ObjectHandler objHandler = new ObjectHandler();
-
-    static MongoDBHandler mongoDBHandler = new MongoDBHandler();
+    static MongodExecutable mongodExecutable = null;
+    static MongoDBHandler mongoDBHandler = null;
     static JmesPathInterface jmesPathInterface = new JmesPathInterface();
 
     static private RulesObject rulesObject;
@@ -50,10 +59,32 @@ public class ObjectHandlerTest {
     static String condition = "{\"_id\" : \"eventId\"}";
     static String event = "{\"meta\":{\"id\":\"eventId\"}}";
 
+    public static void setUpEmbeddedMongo() throws Exception {
+        System.setProperty("mongodb.port", ""+port);
+
+        MongodStarter starter = MongodStarter.getDefaultInstance();
+
+        String bindIp = "localhost";
+
+        IMongodConfig mongodConfig = new MongodConfigBuilder()
+            .version(Version.Main.PRODUCTION)
+            .net(new Net(bindIp, port, Network.localhostIsIPv6()))
+            .build();
+
+
+        try {
+            mongodExecutable = starter.prepare(mongodConfig);
+            MongodProcess mongod = mongodExecutable.start();
+        } catch (Exception e) {
+            log.info(e.getMessage(),e);
+        }
+    }
 
     @BeforeClass
-    public static void init()
+    public static void init() throws Exception
     {
+        setUpEmbeddedMongo();
+        mongoDBHandler = new MongoDBHandler();
         mongoDBHandler.createConnection(host,port);
         EventToObjectMapHandler eventToObjectMapHandler = mock(EventToObjectMapHandler.class);
         objHandler.setEventToObjectMap(eventToObjectMapHandler);
@@ -84,5 +115,8 @@ public void test() {
     public static void dropCollection()
     {
         mongoDBHandler.dropDocument(dataBaseName, collectionName, condition);
+
+        if (mongodExecutable != null)
+            mongodExecutable.stop();
     }
 }

src/test/java/com/ericsson/ei/mongoDBHandler/test/MongoDBHandlerTest.java

@@ -3,9 +3,21 @@
 import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
+import com.ericsson.ei.handlers.test.ObjectHandlerTest;
 import com.ericsson.ei.mongodbhandler.MongoDBHandler;
 
+import de.flapdoodle.embed.mongo.MongodExecutable;
+import de.flapdoodle.embed.mongo.MongodProcess;
+import de.flapdoodle.embed.mongo.MongodStarter;
+import de.flapdoodle.embed.mongo.config.IMongodConfig;
+import de.flapdoodle.embed.mongo.config.MongodConfigBuilder;
+import de.flapdoodle.embed.mongo.config.Net;
+import de.flapdoodle.embed.mongo.distribution.Version;
+import de.flapdoodle.embed.process.runtime.Network;
+
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.assertEquals;
 
@@ -15,7 +27,10 @@
 
 public class MongoDBHandlerTest {
 
-    static MongoDBHandler mongoDBHandler = new MongoDBHandler();
+    static Logger log = (Logger) LoggerFactory.getLogger(MongoDBHandlerTest.class);
+
+    static MongodExecutable mongodExecutable = null;
+    static MongoDBHandler mongoDBHandler = null;
 
     static String host = "localhost";
     static int port = 27017;
@@ -26,9 +41,32 @@ public class MongoDBHandlerTest {
     String updateInput = "{\"id\":\"eventId\",\"type\":\"eventType11\",\"test_cases\" : [{\"event_id\" : \"testcaseid1\", \"test_data\" : \"testcase2data\"},{\"event_id\" : \"testcaseid3\", \"test_data\" : \"testcase3data\"}]}";
     static String condition = "{\"test_cases.event_id\" : \"testcaseid1\"}";
 
+    public static void setUpEmbeddedMongo() throws Exception {
+        System.setProperty("mongodb.port", ""+port);
+
+        MongodStarter starter = MongodStarter.getDefaultInstance();
+
+        String bindIp = "localhost";
+
+        IMongodConfig mongodConfig = new MongodConfigBuilder()
+            .version(Version.Main.PRODUCTION)
+            .net(new Net(bindIp, port, Network.localhostIsIPv6()))
+            .build();
+
+
+        try {
+            mongodExecutable = starter.prepare(mongodConfig);
+            MongodProcess mongod = mongodExecutable.start();
+        } catch (Exception e) {
+            log.info(e.getMessage(),e);
+        }
+    }
+
     @BeforeClass
-    public static void init()
+    public static void init() throws Exception
     {
+        setUpEmbeddedMongo();
+        mongoDBHandler = new MongoDBHandler();
         mongoDBHandler.createConnection(host,port);
         assertTrue(mongoDBHandler.insertDocument(dataBaseName, collectionName, input));
     }
@@ -62,5 +100,7 @@ public void testUpdateDocument(){
     public static void dropCollection()
     {
         assertTrue(mongoDBHandler.dropDocument(dataBaseName, collectionName, condition));
+        if (mongodExecutable != null)
+            mongodExecutable.stop();
     }
 }