Kubernetes and Spring cloud gateway added

Author: Nasruddin

.idea/compiler.xml

@@ -1,6 +1,6 @@
 services:
  course:
- build: microservices/course-service
+ build: ../microservices/course-service
  mem_limit: 512m
  environment:
  - SPRING_PROFILES_ACTIVE=docker
@@ -11,7 +11,7 @@ services:
  # condition: service_healthy
 
  review:
- build: microservices/review-service
+ build: ../microservices/review-service
  mem_limit: 512m
  environment:
  - SPRING_PROFILES_ACTIVE=docker
@@ -22,7 +22,7 @@ services:
  # condition: service_healthy
 
  course-composite:
- build: microservices/course-composite-service
+ build: ../microservices/course-composite-service
  mem_limit: 512m
  ports:
  - "8080:8080"
@@ -31,6 +31,16 @@ services:
  networks:
  - shared-network
 
+ gateway-service:
+ build: ../spring-cloud/gateway-service
+ mem_limit: 512m
+ ports:
+ - "9000:9000"
+ environment:
+ - SPRING_PROFILES_ACTIVE=docker
+ networks:
+ - shared-network
+
 networks:
  shared-network:
  name: shared-network

.idea/encodings.xml

@@ -26,6 +26,8 @@ services:
  timeout: 5s
  retries: 5
  start_period: 30s
+ volumes:
+ - ./postgresql/init.sql:/docker-entrypoint-initdb.d/init.sql
  networks:
  - shared-network
 networks:

.idea/workspace.xml

@@ -0,0 +1,6 @@
+DO $$
+BEGIN
+ IF NOT EXISTS (SELECT FROM pg_database WHERE datname = 'course_db') THEN
+ CREATE DATABASE course_db;
+ END IF;
+END $$;

docker-compose-base.yml renamed to docker/docker-compose-base.yml

@@ -10,11 +10,6 @@
 @ComponentScan({"io.javatab"})
 public class CourseCompositeServiceApplication {
 
-@Bean
-RestTemplate restTemplate() {
-return new RestTemplate();
-}
-
 public static void main(String[] args) {
 SpringApplication.run(CourseCompositeServiceApplication.class, args);
 }

docker-compose-infra.yml renamed to docker/docker-compose-infra.yml

@@ -0,0 +1,12 @@
+package io.javatab.microservices.composite.course.web;
+
+import lombok.Data;
+
+@Data
+public class Course {
+ private Long id;
+ private String title;
+ private String author;
+ private Double price;
+ private String publisher;
+}

docker/postgresql/init.sql

@@ -1,13 +1,14 @@
 package io.javatab.microservices.composite.course.web;
 
 
+import lombok.Builder;
+import lombok.Data;
+
 import java.util.List;
 
+@Data
+@Builder
 public class CourseAggregate {
- private Long id;
- private String title;
- private String author;
- private Double price;
- private String publisher;
+ private Course course;
  private List<Review> reviews;
 }

microservices/course-composite-service/src/main/java/io/javatab/microservices/composite/course/CourseCompositeServiceApplication.java

@@ -0,0 +1,35 @@
+package io.javatab.microservices.composite.course.web;
+
+import io.javatab.util.http.NetworkUtility;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Mono;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/api/course-aggregate")
+public class CourseAggregateController {
+
+ private static final Logger logger = LoggerFactory.getLogger(CourseAggregateController.class);
+
+
+ private final CourseCompositeIntegration integration;
+ private final NetworkUtility utility;
+
+ public CourseAggregateController(CourseCompositeIntegration integration, NetworkUtility utility) {
+ this.integration = integration;
+ this.utility = utility;
+ }
+
+ @GetMapping("/{id}/with-details")
+ public Mono<CourseAggregate> getCourses(@PathVariable Long id) {
+ logger.info("Fetching course and review details for course id : {}", id);
+ return integration.getCourseDetails(id);
+ }
+}