diff options
Diffstat (limited to 'src')
17 files changed, 122 insertions, 87 deletions
diff --git a/src/main/java/org/onap/aai/cacher/Application.java b/src/main/java/org/onap/aai/cacher/Application.java index 6d40b68..e2dbca9 100644 --- a/src/main/java/org/onap/aai/cacher/Application.java +++ b/src/main/java/org/onap/aai/cacher/Application.java @@ -28,9 +28,10 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.EnableAutoConfiguration; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; +import org.springframework.boot.autoconfigure.mongo.embedded.EmbeddedMongoAutoConfiguration; import org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration; import org.springframework.boot.builder.SpringApplicationBuilder; -import org.springframework.boot.web.support.SpringBootServletInitializer; +import org.springframework.boot.web.servlet.support.SpringBootServletInitializer; import org.springframework.context.annotation.ComponentScan; import org.springframework.scheduling.annotation.EnableScheduling; @@ -39,7 +40,7 @@ import java.util.UUID; @SpringBootApplication @EnableScheduling -@EnableAutoConfiguration(exclude = { DataSourceAutoConfiguration.class, HibernateJpaAutoConfiguration.class }) +@EnableAutoConfiguration(exclude = { DataSourceAutoConfiguration.class, HibernateJpaAutoConfiguration.class, EmbeddedMongoAutoConfiguration.class}) @ComponentScan(basePackages = { "org.onap.aai.cacher", "com" }) public class Application extends SpringBootServletInitializer { @@ -65,7 +66,7 @@ public class Application extends SpringBootServletInitializer { LoggingContext.statusCode(StatusCode.COMPLETE); SpringApplication app = new SpringApplication(Application.class); - app.setLogStartupInfo(false); + app.setLogStartupInfo(true); app.setRegisterShutdownHook(true); app.addInitializers(new PropertyPasswordConfiguration()); app.run(args); diff --git a/src/main/java/org/onap/aai/cacher/common/MongoConfig.java b/src/main/java/org/onap/aai/cacher/common/MongoConfig.java index ca063a7..854437d 100644 --- a/src/main/java/org/onap/aai/cacher/common/MongoConfig.java +++ b/src/main/java/org/onap/aai/cacher/common/MongoConfig.java @@ -28,7 +28,10 @@ import de.flapdoodle.embed.mongo.Command; import de.flapdoodle.embed.mongo.MongodExecutable; import de.flapdoodle.embed.mongo.MongodProcess; import de.flapdoodle.embed.mongo.MongodStarter; -import de.flapdoodle.embed.mongo.config.*; +import de.flapdoodle.embed.mongo.config.Defaults; +import de.flapdoodle.embed.mongo.config.MongoCmdOptions; +import de.flapdoodle.embed.mongo.config.MongodConfig; +import de.flapdoodle.embed.mongo.config.Net; import de.flapdoodle.embed.mongo.distribution.Version; import de.flapdoodle.embed.process.config.io.ProcessOutput; import de.flapdoodle.embed.process.io.Processors; @@ -50,11 +53,11 @@ public class MongoConfig { private static final EELFLogger EELF_LOGGER = EELFManager.getInstance().getLogger(MongoConfig.class); - @Value("${mongodb.host}") + @Value("${spring.data.mongodb.host}") private String MONGO_DB_HOST; - @Value("${mongodb.dbName}") + @Value("${spring.data.mongodb.database}") private String MONGO_DB_NAME; - @Value("${mongodb.port}") + @Value("${spring.data.mongodb.port}") private int MONGO_DB_PORT; private MongodProcess mongod; @@ -93,19 +96,18 @@ public class MongoConfig { Logger logger = LoggerFactory.getLogger("mongo"); int port = MONGO_DB_PORT; - IMongodConfig mongoConfigConfig = new MongodConfigBuilder() + MongodConfig mongoConfigConfig = MongodConfig.builder() .version(Version.Main.PRODUCTION) .net(new Net(port, Network.localhostIsIPv6())) - .cmdOptions(new MongoCmdOptionsBuilder().enableTextSearch(true).useNoPrealloc(false).build()) - .configServer(false) + .cmdOptions(MongoCmdOptions.builder().enableTextSearch(true).useNoPrealloc(false).build()) + .isConfigServer(false) .build(); ProcessOutput processOutput = new ProcessOutput(Processors.logTo(logger, Slf4jLevel.WARN), Processors.logTo(logger, Slf4jLevel.WARN), Processors.logTo(logger, Slf4jLevel.WARN)); MongodExecutable mongodExecutable = MongodStarter - .getInstance((new RuntimeConfigBuilder()) - .defaults(Command.MongoD) + .getInstance(Defaults.runtimeConfigFor(Command.MongoD) .processOutput(processOutput) .build()) .prepare(mongoConfigConfig); diff --git a/src/main/java/org/onap/aai/cacher/injestion/parser/strategy/aai/AAIResourcesUriTemplates.java b/src/main/java/org/onap/aai/cacher/injestion/parser/strategy/aai/AAIResourcesUriTemplates.java index 819a7a6..0a4c931 100644 --- a/src/main/java/org/onap/aai/cacher/injestion/parser/strategy/aai/AAIResourcesUriTemplates.java +++ b/src/main/java/org/onap/aai/cacher/injestion/parser/strategy/aai/AAIResourcesUriTemplates.java @@ -227,11 +227,7 @@ public class AAIResourcesUriTemplates { * @return */ public String encodeProp(String string) { - try { - return UriUtils.encode(string, "UTF-8"); - } catch (UnsupportedEncodingException e) { - return ""; - } + return UriUtils.encode(string, "UTF-8"); } /** @@ -241,11 +237,7 @@ public class AAIResourcesUriTemplates { * @return */ public String decodeProp(String string) { - try { - return UriUtils.decode(string, "UTF-8"); - } catch (UnsupportedEncodingException e) { - return ""; - } + return UriUtils.decode(string, "UTF-8"); } public String getAAIUriFromEntityUri(String fullUri) { diff --git a/src/main/java/org/onap/aai/cacher/service/tasks/ScheduledTaskConfig.java b/src/main/java/org/onap/aai/cacher/service/tasks/ScheduledTaskConfig.java index cdd9a2c..3f09124 100644 --- a/src/main/java/org/onap/aai/cacher/service/tasks/ScheduledTaskConfig.java +++ b/src/main/java/org/onap/aai/cacher/service/tasks/ScheduledTaskConfig.java @@ -42,7 +42,7 @@ public class ScheduledTaskConfig { private static final int TASK_INTERVAL_TIME = 30000; private static final int TASK_DELAY_TIME = 0; - private ScheduledTaskConfig(){} + //private ScheduledTaskConfig(){} @Configuration static class RegisterTaskSchedulerViaSchedulingConfigurer implements SchedulingConfigurer { diff --git a/src/main/java/org/onap/aai/cacher/util/RestClient.java b/src/main/java/org/onap/aai/cacher/util/RestClient.java index 9613d81..f836287 100644 --- a/src/main/java/org/onap/aai/cacher/util/RestClient.java +++ b/src/main/java/org/onap/aai/cacher/util/RestClient.java @@ -125,7 +125,7 @@ public class RestClient { @Bean RestTemplate restTemplate(RestTemplateBuilder builder) throws Exception { - RestTemplate restTemplate = builder.requestFactory(new HttpComponentsClientHttpRequestFactory(restClient)) + RestTemplate restTemplate = builder.requestFactory(() -> new HttpComponentsClientHttpRequestFactory(restClient)) .build(); restTemplate.setErrorHandler(new ResponseErrorHandler() { diff --git a/src/main/java/org/onap/aai/cacher/web/JerseyConfiguration.java b/src/main/java/org/onap/aai/cacher/web/JerseyConfiguration.java index b18e840..d0a15cd 100644 --- a/src/main/java/org/onap/aai/cacher/web/JerseyConfiguration.java +++ b/src/main/java/org/onap/aai/cacher/web/JerseyConfiguration.java @@ -19,7 +19,7 @@ */ package org.onap.aai.cacher.web; -import org.glassfish.jersey.filter.LoggingFilter; +import org.glassfish.jersey.logging.LoggingFeature; import org.glassfish.jersey.server.ResourceConfig; import org.onap.aai.cacher.service.rest.CacheInteractionService; import org.onap.aai.cacher.service.rest.CacheKeyService; @@ -60,7 +60,7 @@ public class JerseyConfiguration extends ResourceConfig { // If the LoggingFilter second argument is set to true, it will print response // value as well if ("true".equalsIgnoreCase(env.getProperty("aai.request.logging.enabled"))) { - register(new LoggingFilter(log, false)); + register(new LoggingFeature(log, 0)); } } diff --git a/src/main/java/org/onap/aai/cacher/web/LocalHostAccessLog.java b/src/main/java/org/onap/aai/cacher/web/LocalHostAccessLog.java index 81addb5..ff7d79f 100644 --- a/src/main/java/org/onap/aai/cacher/web/LocalHostAccessLog.java +++ b/src/main/java/org/onap/aai/cacher/web/LocalHostAccessLog.java @@ -22,9 +22,9 @@ package org.onap.aai.cacher.web; import ch.qos.logback.access.jetty.RequestLogImpl; import org.eclipse.jetty.server.handler.HandlerCollection; import org.eclipse.jetty.server.handler.RequestLogHandler; -import org.springframework.boot.context.embedded.EmbeddedServletContainerFactory; -import org.springframework.boot.context.embedded.jetty.JettyEmbeddedServletContainerFactory; -import org.springframework.boot.context.embedded.jetty.JettyServerCustomizer; +import org.springframework.boot.web.embedded.jetty.JettyServerCustomizer; +import org.springframework.boot.web.embedded.jetty.JettyServletWebServerFactory; +import org.springframework.boot.web.servlet.server.AbstractServletWebServerFactory; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @@ -34,8 +34,8 @@ import java.util.Arrays; public class LocalHostAccessLog { @Bean - public EmbeddedServletContainerFactory jettyConfigBean() { - JettyEmbeddedServletContainerFactory jef = new JettyEmbeddedServletContainerFactory(); + public AbstractServletWebServerFactory jettyConfigBean() { + JettyServletWebServerFactory jef = new JettyServletWebServerFactory(); jef.addServerCustomizers((JettyServerCustomizer) server -> { HandlerCollection handlers = new HandlerCollection(); diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties index cd51b92..1937032 100644 --- a/src/main/resources/application.properties +++ b/src/main/resources/application.properties @@ -8,7 +8,7 @@ spring.jersey.type=filter spring.mvc.urls=swagger,docs,prometheus -server.contextPath=/ +server.servlet.context-path=/ spring.autoconfigure.exclude=org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration,org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration spring.profiles.active=production,one-way-ssl @@ -36,7 +36,7 @@ archetype.name=sdk-java-jersey-archetype server.local.startpath=src/main/resources/ server.basic.auth.location=${server.local.startpath}etc/auth/realm.properties -server.port = 8444 +server.port=8444 server.ssl.enabled-protocols=TLSv1.1,TLSv1.2 server.ssl.key-store=${server.local.startpath}etc/auth/aai_keystore server.ssl.key-store-password=password(OBF:1vn21ugu1saj1v9i1v941sar1ugw1vo0) @@ -46,9 +46,9 @@ server.ssl.client-auth=want server.ssl.key-store-type=JKS #mongodb configuration values -mongodb.host=localhost -mongodb.dbName=aai -mongodb.port=27017 +spring.data.mongodb.host=localhost +spring.data.mongodb.database=aai +spring.data.mongodb.port=27017 #logging configurations aai.transaction.logging=true diff --git a/src/test/java/org/onap/aai/cacher/common/LimitTest.java b/src/test/java/org/onap/aai/cacher/common/LimitTest.java index 366181d..2753ca2 100644 --- a/src/test/java/org/onap/aai/cacher/common/LimitTest.java +++ b/src/test/java/org/onap/aai/cacher/common/LimitTest.java @@ -30,7 +30,10 @@ import de.flapdoodle.embed.mongo.Command; import de.flapdoodle.embed.mongo.MongodExecutable; import de.flapdoodle.embed.mongo.MongodProcess; import de.flapdoodle.embed.mongo.MongodStarter; -import de.flapdoodle.embed.mongo.config.*; +import de.flapdoodle.embed.mongo.config.Defaults; +import de.flapdoodle.embed.mongo.config.MongoCmdOptions; +import de.flapdoodle.embed.mongo.config.MongodConfig; +import de.flapdoodle.embed.mongo.config.Net; import de.flapdoodle.embed.mongo.distribution.Version; import de.flapdoodle.embed.process.config.io.ProcessOutput; import de.flapdoodle.embed.process.io.Processors; @@ -111,19 +114,18 @@ public class LimitTest { protected static void startEmbedded(int port) throws IOException { Logger logger = LoggerFactory.getLogger("mongo"); - IMongodConfig mongoConfigConfig = new MongodConfigBuilder() + MongodConfig mongoConfigConfig = MongodConfig.builder() .version(Version.Main.PRODUCTION) .net(new Net(port, Network.localhostIsIPv6())) - .cmdOptions(new MongoCmdOptionsBuilder().enableTextSearch(true).useNoPrealloc(false).build()) - .configServer(false) + .cmdOptions(MongoCmdOptions.builder().enableTextSearch(true).useNoPrealloc(false).build()) + .isConfigServer(false) .build(); ProcessOutput processOutput = new ProcessOutput(Processors.logTo(logger, Slf4jLevel.WARN), Processors.logTo(logger, Slf4jLevel.WARN), Processors.logTo(logger, Slf4jLevel.WARN)); MongodExecutable mongodExecutable = MongodStarter - .getInstance((new RuntimeConfigBuilder()) - .defaults(Command.MongoD) + .getInstance(Defaults.runtimeConfigFor(Command.MongoD) .processOutput(processOutput) .build()) .prepare(mongoConfigConfig); diff --git a/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonNoFakeTest.java b/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonNoFakeTest.java index 3f236a2..52ef9c6 100644 --- a/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonNoFakeTest.java +++ b/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonNoFakeTest.java @@ -83,19 +83,18 @@ public class MongoHelperSingletonNoFakeTest { protected static void startEmbedded(int port) throws IOException { Logger logger = LoggerFactory.getLogger("mongo"); - IMongodConfig mongoConfigConfig = new MongodConfigBuilder() + MongodConfig mongoConfigConfig = MongodConfig.builder() .version(Version.Main.PRODUCTION) .net(new Net(port, Network.localhostIsIPv6())) - .cmdOptions(new MongoCmdOptionsBuilder().enableTextSearch(true).useNoPrealloc(false).build()) - .configServer(false) + .cmdOptions(MongoCmdOptions.builder().enableTextSearch(true).useNoPrealloc(false).build()) + .isConfigServer(false) .build(); ProcessOutput processOutput = new ProcessOutput(Processors.logTo(logger, Slf4jLevel.WARN), Processors.logTo(logger, Slf4jLevel.WARN), Processors.logTo(logger, Slf4jLevel.WARN)); MongodExecutable mongodExecutable = MongodStarter - .getInstance((new RuntimeConfigBuilder()) - .defaults(Command.MongoD) + .getInstance(Defaults.runtimeConfigFor(Command.MongoD) .processOutput(processOutput) .build()) .prepare(mongoConfigConfig); diff --git a/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonTest.java b/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonTest.java index 872f099..b458b29 100644 --- a/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonTest.java +++ b/src/test/java/org/onap/aai/cacher/common/MongoHelperSingletonTest.java @@ -19,12 +19,15 @@ */ package org.onap.aai.cacher.common; -import com.github.fakemongo.Fongo; import com.google.gson.JsonParser; import com.mongodb.DB; +import com.mongodb.MongoClient; +import com.mongodb.ServerAddress; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoDatabase; import com.mongodb.client.model.UpdateOptions; +import de.bwaldvogel.mongo.MongoServer; +import de.bwaldvogel.mongo.backend.memory.MemoryBackend; import org.bson.Document; import org.json.JSONException; import org.json.JSONObject; @@ -36,6 +39,7 @@ import org.onap.aai.cacher.model.CacheEntry; import org.onap.aai.cacher.model.DBAction; import org.skyscreamer.jsonassert.JSONAssert; +import java.net.InetSocketAddress; import java.util.ArrayList; import java.util.List; import java.util.Optional; @@ -54,9 +58,12 @@ public class MongoHelperSingletonTest { @BeforeClass public static void setup() { - Fongo fongo = new Fongo(DB_NAME); - mongoDatabase = fongo.getDatabase(DB_NAME); - db = fongo.getDB(DB_NAME); + MongoServer mongoServer = new MongoServer(new MemoryBackend()); + InetSocketAddress serverAddress = mongoServer.bind(); + + MongoClient client = new MongoClient(new ServerAddress(serverAddress)); + mongoDatabase = client.getDatabase(DB_NAME); + db = client.getDB(DB_NAME); } @Before @@ -169,7 +176,6 @@ public class MongoHelperSingletonTest { .getClass() .getEnclosingMethod() .getName(); - setupCollection(collectionName); MongoCollection<Document> collection = setupCollection(collectionName); @@ -193,7 +199,6 @@ public class MongoHelperSingletonTest { .getClass() .getEnclosingMethod() .getName(); - setupCollection(collectionName); MongoCollection<Document> collection = setupCollection(collectionName); @@ -224,7 +229,6 @@ public class MongoHelperSingletonTest { .getClass() .getEnclosingMethod() .getName(); - setupCollection(collectionName); MongoCollection<Document> collection = setupCollection(collectionName); @@ -258,7 +262,6 @@ public class MongoHelperSingletonTest { .getClass() .getEnclosingMethod() .getName(); - setupCollection(collectionName); MongoCollection<Document> collection = setupCollection(collectionName); @@ -295,7 +298,6 @@ public class MongoHelperSingletonTest { .getClass() .getEnclosingMethod() .getName(); - setupCollection(collectionName); MongoCollection<Document> collection = setupCollection(collectionName); diff --git a/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIDmaapEventProcessorScenariosTest.java b/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIDmaapEventProcessorScenariosTest.java index c5d39a0..6139fb5 100644 --- a/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIDmaapEventProcessorScenariosTest.java +++ b/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIDmaapEventProcessorScenariosTest.java @@ -19,13 +19,15 @@ */ package org.onap.aai.cacher.dmaap.consumer; -import com.github.fakemongo.Fongo; import com.google.gson.JsonArray; import com.google.gson.JsonObject; import com.google.gson.JsonParser; import com.mongodb.DB; import com.mongodb.MongoClient; +import com.mongodb.ServerAddress; import com.mongodb.client.MongoDatabase; +import de.bwaldvogel.mongo.MongoServer; +import de.bwaldvogel.mongo.backend.memory.MemoryBackend; import de.flapdoodle.embed.mongo.MongodProcess; import org.apache.commons.io.IOUtils; import org.bson.Document; @@ -49,6 +51,7 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import java.io.IOException; import java.io.InputStream; +import java.net.InetSocketAddress; import java.net.URI; import java.util.ArrayList; import java.util.List; @@ -100,9 +103,12 @@ public class AAIDmaapEventProcessorScenariosTest { @BeforeClass public static void setup() throws IOException, InterruptedException { - Fongo fongo = new Fongo(DB_NAME); - mongoDb = fongo.getDatabase(DB_NAME); - db = fongo.getDB(DB_NAME); + MongoServer mongoServer = new MongoServer(new MemoryBackend()); + InetSocketAddress serverAddress = mongoServer.bind(); + + MongoClient client = new MongoClient(new ServerAddress(serverAddress)); + mongoDb = client.getDatabase(DB_NAME); + db = client.getDB(DB_NAME); } @AfterClass diff --git a/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIEventConsumerTest.java b/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIEventConsumerTest.java index 12d1416..c4a69c9 100644 --- a/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIEventConsumerTest.java +++ b/src/test/java/org/onap/aai/cacher/dmaap/consumer/AAIEventConsumerTest.java @@ -20,10 +20,12 @@ package org.onap.aai.cacher.dmaap.consumer; import com.att.nsa.mr.client.MRConsumer; -import com.github.fakemongo.Fongo; import com.mongodb.DB; import com.mongodb.MongoClient; +import com.mongodb.ServerAddress; import com.mongodb.client.MongoDatabase; +import de.bwaldvogel.mongo.MongoServer; +import de.bwaldvogel.mongo.backend.memory.MemoryBackend; import de.flapdoodle.embed.mongo.MongodProcess; import org.hamcrest.Matchers; import org.junit.*; @@ -41,6 +43,7 @@ import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import java.io.IOException; +import java.net.InetSocketAddress; import java.util.ArrayList; import java.util.List; import java.util.Properties; @@ -48,7 +51,6 @@ import java.util.Properties; import static org.junit.Assert.assertNotEquals; import static org.junit.Assert.assertThat; -//@Ignore @RunWith(SpringJUnit4ClassRunner.class) @Configuration @ContextConfiguration(classes = {InjestionTestComponent.class, AAIEventConsumerTest.class}) @@ -100,9 +102,13 @@ public class AAIEventConsumerTest { @BeforeClass public static void setup() throws IOException, InterruptedException { - Fongo fongo = new Fongo(DB_NAME); - mongoDb = fongo.getDatabase(DB_NAME); - db = fongo.getDB(DB_NAME); + + MongoServer mongoServer = new MongoServer(new MemoryBackend()); + InetSocketAddress serverAddress = mongoServer.bind(); + + MongoClient client = new MongoClient(new ServerAddress(serverAddress)); + mongoDb = client.getDatabase(DB_NAME); + db = client.getDB(DB_NAME); } @Before diff --git a/src/test/java/org/onap/aai/cacher/injestion/parser/AAIResourcesUriTemplatesTest.java b/src/test/java/org/onap/aai/cacher/injestion/parser/AAIResourcesUriTemplatesTest.java index d093b6c..8a888dc 100644 --- a/src/test/java/org/onap/aai/cacher/injestion/parser/AAIResourcesUriTemplatesTest.java +++ b/src/test/java/org/onap/aai/cacher/injestion/parser/AAIResourcesUriTemplatesTest.java @@ -19,10 +19,12 @@ */ package org.onap.aai.cacher.injestion.parser; -import com.github.fakemongo.Fongo; import com.mongodb.DB; import com.mongodb.MongoClient; +import com.mongodb.ServerAddress; import com.mongodb.client.MongoDatabase; +import de.bwaldvogel.mongo.MongoServer; +import de.bwaldvogel.mongo.backend.memory.MemoryBackend; import de.flapdoodle.embed.mongo.MongodProcess; import org.junit.After; import org.junit.AfterClass; @@ -38,6 +40,7 @@ import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import java.io.IOException; +import java.net.InetSocketAddress; import java.util.*; import static org.hamcrest.CoreMatchers.is; @@ -74,9 +77,12 @@ public class AAIResourcesUriTemplatesTest { @BeforeClass public static void setup() throws IOException, InterruptedException { - Fongo fongo = new Fongo(DB_NAME); - mongoDb = fongo.getDatabase(DB_NAME); - db = fongo.getDB(DB_NAME); + MongoServer mongoServer = new MongoServer(new MemoryBackend()); + InetSocketAddress serverAddress = mongoServer.bind(); + + MongoClient client = new MongoClient(new ServerAddress(serverAddress)); + mongoDb = client.getDatabase(DB_NAME); + db = client.getDB(DB_NAME); } @AfterClass diff --git a/src/test/java/org/onap/aai/cacher/injestion/parser/PayloadParserServiceTest.java b/src/test/java/org/onap/aai/cacher/injestion/parser/PayloadParserServiceTest.java index ddac8e3..7ab8da7 100644 --- a/src/test/java/org/onap/aai/cacher/injestion/parser/PayloadParserServiceTest.java +++ b/src/test/java/org/onap/aai/cacher/injestion/parser/PayloadParserServiceTest.java @@ -19,20 +19,21 @@ */ package org.onap.aai.cacher.injestion.parser; -import com.github.fakemongo.Fongo; import com.google.gson.Gson; import com.google.gson.GsonBuilder; import com.google.gson.JsonObject; import com.google.gson.JsonParser; import com.mongodb.DB; import com.mongodb.MongoClient; +import com.mongodb.ServerAddress; import com.mongodb.client.MongoDatabase; +import de.bwaldvogel.mongo.MongoServer; +import de.bwaldvogel.mongo.backend.memory.MemoryBackend; 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.MongoCmdOptionsBuilder; -import de.flapdoodle.embed.mongo.config.MongodConfigBuilder; +import de.flapdoodle.embed.mongo.config.MongoCmdOptions; +import de.flapdoodle.embed.mongo.config.MongodConfig; import de.flapdoodle.embed.mongo.config.Net; import de.flapdoodle.embed.mongo.distribution.Version; import de.flapdoodle.embed.process.runtime.Network; @@ -51,6 +52,7 @@ import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import java.io.IOException; +import java.net.InetSocketAddress; import java.util.List; import static org.hamcrest.CoreMatchers.is; @@ -107,17 +109,20 @@ public class PayloadParserServiceTest { @BeforeClass public static void setup() throws IOException, InterruptedException { - Fongo fongo = new Fongo(DB_NAME); - mongoDb = fongo.getDatabase(DB_NAME); - db = fongo.getDB(DB_NAME); + MongoServer mongoServer = new MongoServer(new MemoryBackend()); + InetSocketAddress serverAddress = mongoServer.bind(); + + MongoClient client = new MongoClient(new ServerAddress(serverAddress)); + mongoDb = client.getDatabase(DB_NAME); + db = client.getDB(DB_NAME); } protected static void startEmbedded(int port) throws IOException { - IMongodConfig mongoConfigConfig = new MongodConfigBuilder() + MongodConfig mongoConfigConfig = MongodConfig.builder() .version(Version.Main.PRODUCTION) .net(new Net(port, Network.localhostIsIPv6())) - .cmdOptions(new MongoCmdOptionsBuilder().verbose(true).build()) - .configServer(false) + .cmdOptions(MongoCmdOptions.builder().isVerbose(true).build()) + .isConfigServer(false) .build(); MongodExecutable mongodExecutable = MongodStarter.getDefaultInstance().prepare(mongoConfigConfig); diff --git a/src/test/java/org/onap/aai/cacher/service/helper/CacheHelperServiceScenariosTest.java b/src/test/java/org/onap/aai/cacher/service/helper/CacheHelperServiceScenariosTest.java index 00beab6..7f2a952 100644 --- a/src/test/java/org/onap/aai/cacher/service/helper/CacheHelperServiceScenariosTest.java +++ b/src/test/java/org/onap/aai/cacher/service/helper/CacheHelperServiceScenariosTest.java @@ -19,10 +19,12 @@ */ package org.onap.aai.cacher.service.helper; -import com.github.fakemongo.Fongo; import com.mongodb.DB; import com.mongodb.MongoClient; +import com.mongodb.ServerAddress; import com.mongodb.client.MongoDatabase; +import de.bwaldvogel.mongo.MongoServer; +import de.bwaldvogel.mongo.backend.memory.MemoryBackend; import de.flapdoodle.embed.mongo.MongodProcess; import org.junit.After; import org.junit.AfterClass; @@ -44,6 +46,7 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import javax.ws.rs.core.Response; import java.io.IOException; +import java.net.InetSocketAddress; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.ArrayList; @@ -98,7 +101,7 @@ public class CacheHelperServiceScenariosTest { @Bean public RestClientHelperService restClientHelperService() { - return restClientHelperService; + return new RestClientHelperService(); } @Bean @@ -113,9 +116,12 @@ public class CacheHelperServiceScenariosTest { @BeforeClass public static void setup() throws IOException, InterruptedException { - Fongo fongo = new Fongo(DB_NAME); - mongoDb = fongo.getDatabase(DB_NAME); - db = fongo.getDB(DB_NAME); + MongoServer mongoServer = new MongoServer(new MemoryBackend()); + InetSocketAddress serverAddress = mongoServer.bind(); + + MongoClient client = new MongoClient(new ServerAddress(serverAddress)); + mongoDb = client.getDatabase(DB_NAME); + db = client.getDB(DB_NAME); } @AfterClass diff --git a/src/test/java/org/onap/aai/cacher/service/helper/CrudOperationsTest.java b/src/test/java/org/onap/aai/cacher/service/helper/CrudOperationsTest.java index 1aa1d81..3fce450 100644 --- a/src/test/java/org/onap/aai/cacher/service/helper/CrudOperationsTest.java +++ b/src/test/java/org/onap/aai/cacher/service/helper/CrudOperationsTest.java @@ -19,16 +19,21 @@ */ package org.onap.aai.cacher.service.helper; -import com.github.fakemongo.Fongo; +import com.mongodb.MongoClient; +import com.mongodb.ServerAddress; import com.mongodb.client.FindIterable; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoDatabase; import com.mongodb.client.model.FindOneAndUpdateOptions; import com.mongodb.client.model.UpdateOptions; +import de.bwaldvogel.mongo.MongoServer; +import de.bwaldvogel.mongo.backend.memory.MemoryBackend; import org.bson.Document; import org.junit.BeforeClass; import org.junit.Test; +import java.net.InetSocketAddress; + import static org.junit.Assert.assertEquals; public class CrudOperationsTest { @@ -38,8 +43,11 @@ public class CrudOperationsTest { @BeforeClass public static void setup() { - Fongo fongo = new Fongo(DB_NAME); - mongoDatabase = fongo.getDatabase(DB_NAME); + MongoServer mongoServer = new MongoServer(new MemoryBackend()); + InetSocketAddress serverAddress = mongoServer.bind(); + + MongoClient client = new MongoClient(new ServerAddress(serverAddress)); + mongoDatabase = client.getDatabase(DB_NAME); } @Test |