student update

Author: prasath116

reactive-micro-service/student-service/src/main/java/com/prs/services/student/client/CollegeReactiveClient.java

@@ -0,0 +1,30 @@
+package com.prs.services.student.client;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Component;
+
+import com.prs.services.student.model.College;
+
+import reactor.core.publisher.Mono;
+
+@Component
+public class CollegeReactiveClient {
+
+@Autowired
+@Qualifier("collegeExternalClient")
+private ExternalClient externalClient;
+
+public Mono<College> findByCollege(Long collegeId) {
+return externalClient.getForMono("/get-by/" + collegeId, getDefaultHeaders(), College.class);
+}
+
+private HttpHeaders getDefaultHeaders() {
+HttpHeaders h = new HttpHeaders();
+h.add(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE);
+return h;
+}
+
+}

reactive-micro-service/student-service/src/main/java/com/prs/services/student/client/DepartmentReactiveClient.java

@@ -0,0 +1,31 @@
+package com.prs.services.student.client;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Component;
+
+import com.prs.services.student.model.Department;
+
+import reactor.core.publisher.Mono;
+
+@Component
+public class DepartmentReactiveClient {
+
+@Autowired
+@Qualifier("departmentExternalClient")
+private ExternalClient externalClient;
+
+public Mono<Department> findByDepartment(Long departmentId) {
+return externalClient.getForMono("/get-by/" + departmentId, getDefaultHeaders(), Department.class);
+}
+
+private HttpHeaders getDefaultHeaders() {
+HttpHeaders h = new HttpHeaders();
+h.add(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE);
+return h;
+}
+
+
+}

reactive-micro-service/student-service/src/main/java/com/prs/services/student/client/ExternalClient.java

@@ -0,0 +1,29 @@
+package com.prs.services.student.client;
+
+import java.util.Map;
+import java.util.function.Consumer;
+
+import org.springframework.http.HttpHeaders;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+public interface ExternalClient {
+public <T> Mono<T> getForMono(String path, HttpHeaders httpHeaders, Class<T> resClazz);
+
+public <T> Flux<T> getForFlux(String path, HttpHeaders httpHeaders, Class<T> resClazz);
+
+public <T, U> Mono<U> postForMono(String path, HttpHeaders httpHeaders, Class<U> resClazz, T reqBody,
+Class<T> reqClazz);
+
+public <T, U> Flux<U> postForFlux(String path, HttpHeaders httpHeaders, T reqBody, Class<T> reqClazz,
+Class<U> resClazz);
+
+default Consumer<HttpHeaders> headerConsumer(HttpHeaders httpHeaders) {
+return h -> h.putAll(httpHeaders);
+}
+
+default Consumer<HttpHeaders> headerConsumer(Map<String, String> httpHeaders) {
+return h -> httpHeaders.forEach((k, v) -> h.add(k, v));
+}
+}

reactive-micro-service/student-service/src/main/java/com/prs/services/student/client/ExternalClientImpl.java

@@ -0,0 +1,66 @@
+package com.prs.services.student.client;
+
+import javax.annotation.PostConstruct;
+
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.springframework.http.HttpHeaders;
+import org.springframework.web.reactive.function.client.WebClient;
+import org.springframework.web.reactive.function.client.WebClient.RequestHeadersSpec;
+
+import lombok.AllArgsConstructor;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+//@Component
+@AllArgsConstructor
+public class ExternalClientImpl implements ExternalClient {
+
+private static final Logger LOGGER = LogManager.getLogger(ExternalClientImpl.class);
+
+private WebClient client;
+
+public <T> Mono<T> getForMono(String path, HttpHeaders httpHeaders, Class<T> resClazz) {
+return getClientResponse(path, httpHeaders)
+.exchangeToMono(r -> r.bodyToMono(resClazz));
+}
+
+public <T> Flux<T> getForFlux(String path, HttpHeaders httpHeaders, Class<T> resClazz) {
+return getClientResponse(path, httpHeaders)
+.exchangeToFlux(r -> r.bodyToFlux(resClazz));
+
+}
+
+public <T, U> Mono<U> postForMono(String path, HttpHeaders httpHeaders, Class<U> resClazz,
+T reqBody, Class<T> reqClazz) {
+return postForResponse(path, httpHeaders, reqBody, reqClazz)
+.exchangeToMono(r -> r.bodyToMono(resClazz));
+}
+
+public <T, U> Flux<U> postForFlux(String path, HttpHeaders httpHeaders, T reqBody, Class<T> reqClazz,
+Class<U> resClazz) {
+return postForResponse(path, httpHeaders, reqBody, reqClazz)
+.exchangeToFlux(r -> r.bodyToFlux(resClazz));
+
+}
+
+private <T> RequestHeadersSpec<?> postForResponse(String path, HttpHeaders httpHeaders, T reqBody,
+Class<T> reqClazz) {
+return client.post()
+.uri(path)
+.headers(headerConsumer(httpHeaders))
+.body(Mono.just(reqBody), reqClazz);
+}
+
+private RequestHeadersSpec<?> getClientResponse(String path, HttpHeaders httpHeaders) {
+return client.get()
+.uri(path)
+.headers(headerConsumer(httpHeaders));
+}
+
+@PostConstruct
+private void initiated() {
+LOGGER.debug("ExternalClientImpl initiated");
+}
+
+}

reactive-micro-service/student-service/src/main/java/com/prs/services/student/client/WebClientConfig.java

@@ -0,0 +1,47 @@
+package com.prs.services.student.client;
+
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.cloud.client.loadbalancer.LoadBalanced;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.web.reactive.function.client.WebClient;
+
+@Configuration
+public class WebClientConfig {
+
+@Bean
+@Qualifier("collegeWebClient")
+@LoadBalanced
+public WebClient getCollegeWebClient() {
+WebClient client = WebClient.builder().baseUrl("http://localhost:8060/college")
+.defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
+.build();
+return client;
+}
+
+@Bean
+@Qualifier("departmentWebClient")
+@LoadBalanced
+public WebClient getDepartmentWebClient() {
+WebClient client = WebClient.builder().baseUrl("http://localhost:8060/department")
+.defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
+.build();
+return client;
+}
+
+@Bean
+@Qualifier("collegeExternalClient")
+public ExternalClientImpl getCollegeExternalClient(@Qualifier("collegeWebClient") WebClient collegeWebClient) {
+return new ExternalClientImpl(collegeWebClient);
+}
+
+@Bean
+@Qualifier("departmentExternalClient")
+public ExternalClientImpl getDepartmentExternalClient(@Qualifier("departmentWebClient") WebClient departmentWebClient) {
+return new ExternalClientImpl(departmentWebClient);
+}
+
+
+}

reactive-micro-service/student-service/src/main/java/com/prs/services/student/model/College.java

@@ -0,0 +1,18 @@
+package com.prs.services.student.model;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonInclude.Include;
+
+import lombok.Data;
+import lombok.ToString;
+
+@Data
+@ToString
+@JsonInclude(Include.NON_NULL)
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class College {
+private Long id;
+private String name;
+private String address;
+}

reactive-micro-service/student-service/src/main/java/com/prs/services/student/model/Department.java

@@ -0,0 +1,18 @@
+package com.prs.services.student.model;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonInclude.Include;
+
+import lombok.Data;
+import lombok.ToString;
+
+@Data
+@ToString
+@JsonInclude(Include.NON_NULL)
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class Department {
+private Long id;
+private String name;
+
+}

reactive-micro-service/student-service/src/main/java/com/prs/services/student/model/Student.java

@@ -14,9 +14,10 @@
 public class Student {
 
 private Long id;
-private Long collegeId;
-private Long departmentId;
 private String name;
 private int age;
+
+private College college;
+private Department department;
 
 }

reactive-micro-service/student-service/src/main/java/com/prs/services/student/service/StudentServiceImpl.java

@@ -8,7 +8,11 @@
 import org.springframework.stereotype.Service;
 
 import com.prs.services.exceptionHandler.DataException;
+import com.prs.services.student.client.CollegeReactiveClient;
+import com.prs.services.student.client.DepartmentReactiveClient;
 import com.prs.services.student.entity.StudentEntity;
+import com.prs.services.student.model.College;
+import com.prs.services.student.model.Department;
 import com.prs.services.student.model.Student;
 import com.prs.services.student.repository.StudentRepository;
 
@@ -20,11 +24,17 @@ public class StudentServiceImpl implements IStudentService {
 
 @Autowired
 private StudentRepository repository;
+
+@Autowired
+private DepartmentReactiveClient departmentClient;
+@Autowired
+private CollegeReactiveClient collegeClient;
+
 
 @Override
 public Mono<Student> save(StudentEntity entity) {
 //	return repository.save(entity).map(mapper);Issue in SimpleR2dbcRepository save(e); So used saveAll for time being
-return repository.saveAll(Arrays.asList(entity)).last().map(mapper);
+return repository.saveAll(Arrays.asList(entity)).last().flatMap(mapper);
 }
 
 @Override
@@ -37,12 +47,12 @@ public Mono<Student> update(Long id, StudentEntity entity) {
 
 @Override
 public Flux<Student> findAll() {
-return repository.findAll().map(mapper);
+return repository.findAll().map(simpleMapper);
 }
 
 @Override
 public Mono<Student> findById(Long id) {
-return repository.findById(id).map(mapper);
+return repository.findById(id).flatMap(mapper);
 }
 
 @Override
@@ -52,20 +62,37 @@ public Mono<Void> deleteById(Long id) {
 
 @Override
 public Flux<Student> findByCollege(Long collegeId) {
-return findAll().filter(a -> a.getCollegeId().equals(collegeId));
+return findAll().filter(a -> a.getCollege().getId().equals(collegeId));
 //	return Flux.fromIterable(repository.findByCollegeId(collegeId)).map(mapper);
 }
 
 @Override
 public Flux<Student> findByDepartment(Long departmentId) {
-return findAll().filter(a -> a.getDepartmentId().equals(departmentId));
+return findAll().filter(a -> a.getDepartment().getId().equals(departmentId));
 //	return Flux.fromIterable(repository.findByDepartmentId(departmentId)).map(mapper);
 }
 
-private Function<StudentEntity, Student> mapper = c -> {
-Student response = new Student();
-BeanUtils.copyProperties(c, response);
-return response;
+private Function<StudentEntity, Mono<Student>> mapper = c -> {
+var student = new Student();
+BeanUtils.copyProperties(c, student);
+var department = departmentClient.findByDepartment(c.getDepartmentId());
+var college = collegeClient.findByCollege(c.getCollegeId());
+var tuple = Mono.zip(department, college);
+return tuple.map(t-> {
+var dept = new Department();
+var coll = new College();
+BeanUtils.copyProperties(t.getT1(), dept);
+BeanUtils.copyProperties(t.getT2(), coll);
+student.setCollege(coll);
+student.setDepartment(dept);
+return student;
+});
+};
+
+private Function<StudentEntity, Student> simpleMapper = c -> {
+var student = new Student();
+BeanUtils.copyProperties(c, student);
+return student;
 };