Docker compose configure & elastic, redis, mongo, postgres support added

Author: Nasruddin

api/src/main/java/io/javatab/microservices/api/core/course/Course.java

@@ -1,4 +1,4 @@
 package io.javatab.microservices.api.core.course;
 
-public record Course(int courseId, String courseName, String author, String content, int reviewId) {
+public record Course(int courseId, String courseName, String author, String content, int voteId) {
 }

docker/docker-compose.yml

@@ -8,6 +8,9 @@ services:
     mem_limit: 512m
     environment:
       - SPRING_PROFILES_ACTIVE=docker
+    depends_on:
+      mongodb:
+        condition: service_healthy
 
   search:
     build: ../microservices/search-service
@@ -16,6 +19,9 @@ services:
     mem_limit: 512m
     environment:
       - SPRING_PROFILES_ACTIVE=docker
+    depends_on:
+      elasticsearch:
+        condition: service_healthy
 
   student:
     build: ../microservices/student-service
@@ -24,6 +30,9 @@ services:
     mem_limit: 512m
     environment:
       - SPRING_PROFILES_ACTIVE=docker
+    depends_on:
+      postgres:
+        condition: service_healthy
 
   vote:
     build: ../microservices/vote-service
@@ -32,6 +41,9 @@ services:
     mem_limit: 512m
     environment:
       - SPRING_PROFILES_ACTIVE=docker
+    depends_on:
+      redis:
+        condition: service_healthy
 
   course-composite:
     build: ../microservices/course-composite-service
@@ -41,4 +53,63 @@ services:
     ports:
       - "8080:8080" # Only this service will be exposed to outside containers so no port binding for above images
     environment:
-      - SPRING_PROFILES_ACTIVE=docker
+      - SPRING_PROFILES_ACTIVE=docker
+
+  mongodb:
+    image: mongo:4.4.2
+    mem_limit: 512m
+    ports:
+      - "27017:27017"
+    command: mongod
+    healthcheck:
+      test: "mongo --eval 'db.stats().ok'"
+      interval: 5s
+      timeout: 2s
+      retries: 60
+
+  postgres:
+    image: postgres:alpine3.15
+    mem_limit: 512m
+    ports:
+      - "5432:5432"
+    environment:
+      - POSTGRES_DATABASE=test
+      - POSTGRES_USER=user
+      - POSTGRES_PASSWORD=pwd
+    healthcheck:
+      test: [ "CMD-SHELL", "pg_isready -U user" ]
+      interval: 10s
+      timeout: 5s
+      retries: 5
+
+  redis:
+    image: redis:6.2.6-alpine
+    restart: always
+    ports:
+      - "6379:6379"
+    healthcheck:
+      test: [ "CMD-SHELL", "redis-cli ping | grep PONG" ]
+      interval: 5s
+      timeout: 2s
+      retries: 60
+
+  elasticsearch:
+    image: elasticsearch:7.12.1
+    ports:
+      - "9300:9300"
+      - "9200:9200"
+    environment:
+      - node.name=elasticsearch
+      - discovery.type=single-node
+      - cluster.name=docker-cluster
+      - bootstrap.memory_lock=true
+      - "ES_JAVA_OPTS=-Xms512m -Xmx512m"
+    ulimits:
+      memlock:
+        soft: -1
+        hard: -1
+    healthcheck:
+      test: ["CMD-SHELL", "curl --silent --fail localhost:9200/_cluster/health || exit 1"]
+      interval: 5s
+      timeout: 2s
+      retries: 60

microservices/course-service/pom.xml

@@ -15,6 +15,7 @@
 	<description>Demo project for Spring Boot</description>
 	<properties>
 		<java.version>17</java.version>
+		<testcontainers.version>1.16.2</testcontainers.version>
 	</properties>
 	<dependencies>
 		<dependency>
@@ -25,6 +26,16 @@
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-webflux</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-mongodb</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.mapstruct</groupId>
+			<artifactId>mapstruct</artifactId>
+			<version>1.3.1.Final</version>
+		</dependency>
 		<!--Internal Dep-->
 		<dependency>
 			<groupId>io.javatab.microservices.api</groupId>
@@ -46,8 +57,30 @@
 			<artifactId>reactor-test</artifactId>
 			<scope>test</scope>
 		</dependency>
+		<dependency>
+			<groupId>org.testcontainers</groupId>
+			<artifactId>mongodb</artifactId>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.testcontainers</groupId>
+			<artifactId>junit-jupiter</artifactId>
+			<scope>test</scope>
+		</dependency>
 	</dependencies>
 
+	<dependencyManagement>
+		<dependencies>
+			<dependency>
+				<groupId>org.testcontainers</groupId>
+				<artifactId>testcontainers-bom</artifactId>
+				<version>${testcontainers.version}</version>
+				<type>pom</type>
+				<scope>import</scope>
+			</dependency>
+		</dependencies>
+	</dependencyManagement>
+
 	<build>
 		<plugins>
 			<plugin>

microservices/course-service/src/main/java/io/javatab/microservices/core/course/CourseServiceApplication.java

@@ -2,14 +2,17 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.ConfigurableApplicationContext;
 import org.springframework.context.annotation.ComponentScan;
 
 @SpringBootApplication
 @ComponentScan("io.javatab") // To enable Spring Boot's autoconfiguration feature to detect Spring Beans in the api and util projects, we also need to add a @ComponentScan annotation to the main application class, which includes the packages of the api and util projects:
 public class CourseServiceApplication {
 
 	public static void main(String[] args) {
-		SpringApplication.run(CourseServiceApplication.class, args);
+		ConfigurableApplicationContext ctx = SpringApplication.run(CourseServiceApplication.class, args);
+		String mongoUri = ctx.getEnvironment().getProperty("spring.data.mongodb.host");
+		System.out.println("Connected to Mongo: " + mongoUri);
 	}
 
 }

microservices/course-service/src/main/java/io/javatab/microservices/core/course/persistence/CourseEntity.java

@@ -0,0 +1,112 @@
+package io.javatab.microservices.core.course.persistence;
+
+import org.apache.commons.lang3.builder.EqualsBuilder;
+import org.apache.commons.lang3.builder.HashCodeBuilder;
+import org.springframework.data.mongodb.core.index.Indexed;
+import org.springframework.data.mongodb.core.mapping.Document;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.annotation.Version;
+
+@Document(collection = "courses")
+public class CourseEntity {
+
+    @Id
+    private String id;
+
+    @Version
+    private Integer version;
+
+    @Indexed(unique = true)
+    private int courseId;
+
+    private String courseName;
+
+    private String author;
+
+    private int voteId;
+
+    private String content;
+
+    public CourseEntity() {
+    }
+
+    public CourseEntity(int courseId, String courseName, String author, int voteId, String content) {
+        this.courseId = courseId;
+        this.courseName = courseName;
+        this.author = author;
+        this.voteId = voteId;
+        this.content = content;
+    }
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public Integer getVersion() {
+        return version;
+    }
+
+    public void setVersion(Integer version) {
+        this.version = version;
+    }
+
+    public int getCourseId() {
+        return courseId;
+    }
+
+    public void setCourseId(int courseId) {
+        this.courseId = courseId;
+    }
+
+    public String getCourseName() {
+        return courseName;
+    }
+
+    public void setCourseName(String courseName) {
+        this.courseName = courseName;
+    }
+
+    public String getAuthor() {
+        return author;
+    }
+
+    public void setAuthor(String author) {
+        this.author = author;
+    }
+
+    public int getVoteId() {
+        return voteId;
+    }
+
+    public void setVoteId(int voteId) {
+        this.voteId = voteId;
+    }
+
+    public String getContent() {
+        return content;
+    }
+
+    public void setContent(String content) {
+        this.content = content;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+
+        if (o == null || getClass() != o.getClass()) return false;
+
+        CourseEntity entity = (CourseEntity) o;
+
+        return new EqualsBuilder().append(courseId, entity.courseId).append(voteId, entity.voteId).append(id, entity.id).append(version, entity.version).append(courseName, entity.courseName).append(author, entity.author).append(content, entity.content).isEquals();
+    }
+
+    @Override
+    public int hashCode() {
+        return new HashCodeBuilder(17, 37).append(id).append(version).append(courseId).append(courseName).append(author).append(voteId).append(content).toHashCode();
+    }
+}

microservices/course-service/src/main/java/io/javatab/microservices/core/course/persistence/CourseRepository.java

@@ -0,0 +1,6 @@
+package io.javatab.microservices.core.course.persistence;
+
+import org.springframework.data.repository.CrudRepository;
+
+public interface CourseRepository extends CrudRepository<CourseEntity, String> {
+}

microservices/course-service/src/main/resources/application.yml

@@ -5,3 +5,10 @@ logging:
   level:
     root: INFO
     io.javatab.microservices: DEBUG
+
+
+
+---
+spring.config.activate.on-profile: docker
+server.port: 8080
+spring.data.mongodb.host: mongodb

microservices/course-service/src/test/java/io/javatab/microservices/core/course/CourseServiceImplApplicationTests.java

@@ -1,13 +1,10 @@
 package io.javatab.microservices.core.course;
 
-import org.junit.jupiter.api.Test;
 import org.springframework.boot.test.context.SpringBootTest;
 
-@SpringBootTest
-class CourseServiceImplApplicationTests {
+import static org.springframework.boot.test.context.SpringBootTest.WebEnvironment.RANDOM_PORT;
 
-	@Test
-	void contextLoads() {
-	}
+@SpringBootTest(webEnvironment = RANDOM_PORT)
+class CourseServiceImplApplicationTests extends MongoDbTestBase {
 
 }

microservices/course-service/src/test/java/io/javatab/microservices/core/course/MongoDbTestBase.java

@@ -0,0 +1,20 @@
+package io.javatab.microservices.core.course;
+
+import org.springframework.test.context.DynamicPropertyRegistry;
+import org.springframework.test.context.DynamicPropertySource;
+import org.testcontainers.containers.MongoDBContainer;
+
+public abstract class MongoDbTestBase {
+    private static MongoDBContainer database = new MongoDBContainer("mongo:4.4.2");
+
+    static {
+        database.start();
+    }
+
+    @DynamicPropertySource
+    static void setProperties(DynamicPropertyRegistry registry) {
+        registry.add("spring.data.mongodb.host", database::getContainerIpAddress);
+        registry.add("spring.data.mongodb.port", () -> database.getMappedPort(27017));
+        registry.add("spring.data.mongodb.database", () -> "test");
+    }
+}

microservices/course-service/src/test/java/io/javatab/microservices/core/course/PersistenceTests.java

@@ -0,0 +1,40 @@
+package io.javatab.microservices.core.course;
+
+
+import io.javatab.microservices.core.course.persistence.CourseEntity;
+import io.javatab.microservices.core.course.persistence.CourseRepository;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.mongo.embedded.EmbeddedMongoAutoConfiguration;
+import org.springframework.boot.test.autoconfigure.data.mongo.DataMongoTest;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+@DataMongoTest(
+        excludeAutoConfiguration = EmbeddedMongoAutoConfiguration.class
+)
+public class PersistenceTests extends MongoDbTestBase {
+
+    @Autowired
+    private CourseRepository repository;
+    private CourseEntity savedEntity;
+
+    @BeforeEach
+    void setUp() {
+        repository.deleteAll();
+        CourseEntity entity = new CourseEntity(1, "Course Name", "Author", 4, "Content");
+        savedEntity = repository.save(entity);
+        assertEquals(entity, savedEntity);
+    }
+
+    @Test
+    void create() {
+        CourseEntity newEntity = new CourseEntity(1, "Course Name", "Author", 4, "Content");
+        repository.save(newEntity);
+
+        CourseEntity foundEntity = repository.findById(newEntity.getId()).get();
+        assertEquals(newEntity.getId(), foundEntity.getId());
+        assertEquals(2, repository.count());
+    }
+}