juplo.de Git - demos/kafka/chat/blob - src/test/java/de/juplo/kafka/chat/backend/InMemoryWithMongoDbConfigurationIT.java

   1 package de.juplo.kafka.chat.backend;
   2
   3 import lombok.extern.slf4j.Slf4j;
   4 import org.junit.jupiter.api.BeforeEach;
   5 import org.springframework.boot.test.context.SpringBootTest;
   6 import org.springframework.test.context.DynamicPropertyRegistry;
   7 import org.springframework.test.context.DynamicPropertySource;
   8 import org.testcontainers.containers.BindMode;
   9 import org.testcontainers.containers.GenericContainer;
  10 import org.testcontainers.containers.output.Slf4jLogConsumer;
  11 import org.testcontainers.junit.jupiter.Container;
  12 import org.testcontainers.junit.jupiter.Testcontainers;
  13
  14
  15 @SpringBootTest(
  16                 webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
  17                 properties = {
  18                                 "chat.backend.storage=mongodb",
  19                                 "spring.data.mongodb.host=localhost",
  20                                 "spring.data.mongodb.database=test" })
  21 @Testcontainers
  22 @Slf4j
  23 class InMemoryWithMongoDbConfigurationIT extends AbstractConfigurationIT
  24 {
  25         private static final int MONGODB_PORT = 27017;
  26
  27         @Container
  28         private static final GenericContainer CONTAINER =
  29                         new GenericContainer("mongo:6")
  30                                         .withClasspathResourceMapping(
  31                                                         "data/mongodb",
  32                                                         "/docker-entrypoint-initdb.d",
  33                                                         BindMode.READ_ONLY)
  34                                         .withExposedPorts(MONGODB_PORT);
  35
  36         @DynamicPropertySource
  37         static void addMongoPortProperty(DynamicPropertyRegistry registry)
  38         {
  39                 registry.add("spring.data.mongodb.port", () -> CONTAINER.getMappedPort(27017));
  40         }
  41
  42         @BeforeEach
  43         void setUpLogging()
  44         {
  45                 Slf4jLogConsumer logConsumer = new Slf4jLogConsumer(log);
  46                 CONTAINER.followOutput(logConsumer);
  47         }
  48 }