Unit test, Integration test, Cucumber test added

Author: prasath116

reactive-micro-service/student-service/.classpath

@@ -36,6 +36,12 @@
 <attribute name="m2e-apt" value="true"/>
 </attributes>
 </classpathentry>
+<classpathentry excluding="**" kind="src" output="target/test-classes" path="src/test/resources">
+<attributes>
+<attribute name="maven.pomderived" value="true"/>
+<attribute name="test" value="true"/>
+</attributes>
+</classpathentry>
 <classpathentry kind="src" output="target/test-classes" path="target/generated-test-sources/test-annotations">
 <attributes>
 <attribute name="optional" value="true"/>

reactive-micro-service/student-service/pom.xml

@@ -13,7 +13,9 @@
 <version>1</version>
 <name>student-service</name>
 <description>Student service</description>
-
+<properties>
+<cucumber.version>7.2.3</cucumber.version>
+</properties>
 <dependencyManagement>
 <dependencies>
 <dependency>
@@ -103,6 +105,31 @@
 </dependency>
 
 <!-- testing dependencies -->
+<dependency>
+<groupId>io.cucumber</groupId>
+<artifactId>cucumber-java</artifactId>
+<version>${cucumber.version}</version>
+<scope>test</scope>
+</dependency>
+<dependency>
+<groupId>io.cucumber</groupId>
+<artifactId>cucumber-junit</artifactId>
+<version>${cucumber.version}</version>
+<scope>test</scope>
+</dependency>
+<dependency>
+<groupId>io.cucumber</groupId>
+<artifactId>cucumber-junit-platform-engine</artifactId>
+<version>${cucumber.version}</version>
+<scope>test</scope>
+</dependency>
+<dependency>
+<groupId>io.cucumber</groupId>
+<artifactId>cucumber-spring</artifactId>
+<version>${cucumber.version}</version>
+<scope>test</scope>
+</dependency>
+
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>

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

@@ -8,6 +8,7 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -37,6 +38,7 @@ public class StudentController {
 IStudentService service;
 
 @PostMapping("/add")
+@ResponseStatus(HttpStatus.CREATED)
 public Mono<Student> add(@RequestBody StudentEntity employee) {
 LOGGER.info("Student add: {}", employee);
 return service.save(employee);
@@ -55,8 +57,11 @@ public Flux<Student> findAll() {
 }
 
 @PutMapping("/update/{id}")
- public Mono<Student> update(@PathVariable("id") Long id,@RequestBody StudentEntity employee){
- return service.update(id, employee);
+@ResponseStatus(HttpStatus.OK)
+ public Mono<ResponseEntity<Student>> update(@PathVariable("id") Long id,@RequestBody StudentEntity student){
+ return service.update(id, student).map(s -> ResponseEntity.ok()
+ .body(s))
+ .switchIfEmpty(Mono.just(ResponseEntity.notFound().build()));
 
  }
 

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

@@ -4,12 +4,16 @@
 import org.springframework.data.relational.core.mapping.Column;
 import org.springframework.data.relational.core.mapping.Table;
 
+import lombok.AllArgsConstructor;
 import lombok.Data;
+import lombok.NoArgsConstructor;
 import lombok.ToString;
 
 @Data
 @Table("Student")
 @ToString
+@AllArgsConstructor
+@NoArgsConstructor
 public class StudentEntity {
 
 @Id

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

@@ -4,13 +4,17 @@
 import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.annotation.JsonInclude.Include;
 
+import lombok.AllArgsConstructor;
 import lombok.Data;
+import lombok.NoArgsConstructor;
 import lombok.ToString;
 
 @Data
 @JsonInclude(Include.NON_NULL)
 @JsonIgnoreProperties(ignoreUnknown = true)
 @ToString
+@AllArgsConstructor
+@NoArgsConstructor
 public class Student {
 
 private Long id;

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

@@ -33,8 +33,8 @@ public class StudentServiceImpl implements IStudentService {
 
 @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().flatMap(mapper);
+//	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(simpleMapper);
 }
 
 @Override
@@ -52,7 +52,7 @@ public Flux<Student> findAll() {
 
 @Override
 public Mono<Student> findById(Long id) {
-return repository.findById(id).flatMap(mapper);
+return repository.findById(id).flatMap(deepMapper);
 }
 
 @Override
@@ -63,37 +63,31 @@ public Mono<Void> deleteById(Long id) {
 @Override
 public Flux<Student> findByCollege(Long 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.getDepartment().getId().equals(departmentId));
-//	return Flux.fromIterable(repository.findByDepartmentId(departmentId)).map(mapper);
 }
 
-private Function<StudentEntity, Mono<Student>> mapper = c -> {
+private Function<StudentEntity, Student> simpleMapper = c -> {
 var student = new Student();
 BeanUtils.copyProperties(c, student);
-var department = departmentClient.findByDepartment(c.getDepartmentId());
+return student;
+};
+
+private Function<StudentEntity, Mono<Student>> deepMapper = c -> {
+var student = simpleMapper.apply(c);
 var college = collegeClient.findByCollege(c.getCollegeId());
-var tuple = Mono.zip(department, college);
+var department = departmentClient.findByDepartment(c.getDepartmentId());
+var tuple = Mono.zip(college,department);
 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);
+student.setCollege(new College());
+student.setDepartment(new Department());
+BeanUtils.copyProperties(t.getT1(), student.getCollege());
+BeanUtils.copyProperties(t.getT2(), student.getDepartment());
 return student;
 });
 };
 
-private Function<StudentEntity, Student> simpleMapper = c -> {
-var student = new Student();
-BeanUtils.copyProperties(c, student);
-return student;
-};
-
-
 }

reactive-micro-service/student-service/src/test/java/com/prs/services/student/controller/StudentControllerIntegrationTest.java

@@ -0,0 +1,123 @@
+package com.prs.services.student.controller;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+import java.util.List;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.web.reactive.AutoConfigureWebTestClient;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.ActiveProfiles;
+import org.springframework.test.web.reactive.server.WebTestClient;
+
+import com.prs.services.student.entity.StudentEntity;
+import com.prs.services.student.model.Student;
+import com.prs.services.student.repository.StudentRepository;
+
+@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
+@ActiveProfiles("test")
+@AutoConfigureWebTestClient
+public class StudentControllerIntegrationTest {
+
+ @Autowired
+ private WebTestClient webTestClient;
+ 
+ @Autowired
+ private StudentRepository studentRepository;
+ 
+// @BeforeEach
+ void setUp() {
+ var students = List.of(new StudentEntity(null,"Prasath",31,1l,1l),
+ new StudentEntity(null,"Mani",62,1l,1l),
+ new StudentEntity(null,"Nishanthi",30,1l,1l));
+
+ studentRepository
+ .deleteAll()
+ .thenMany(studentRepository.saveAll(students))
+ .blockLast();
+ }
+ 
+ @Test
+ void getAllStudents() {
+ webTestClient
+ .get()
+ .uri("/findAll")
+ .exchange()
+ .expectStatus()
+ .is2xxSuccessful()
+ .expectBodyList(Student.class)
+ .consumeWith(l->{
+ l.getResponseBody().forEach(s->{
+ System.out.println("id : "+s.getId());
+	});
+ })
+ .hasSize(4);
+ }
+
+ @Test
+void getStudentById() {
+Long id = 1l;
+webTestClient
+.get()
+.uri("/get-by/{id}", id)
+.exchange()
+.expectStatus()
+.is2xxSuccessful()
+.expectBody(Student.class)
+.consumeWith(result -> {
+var student = result.getResponseBody();
+assert student != null;
+assertEquals("aa", student.getName());
+});
+//.expectBody() .jsonPath("$.name").isEqualTo("Prasath");
+
+}
+ 
+ @Test
+ void updateStudent() {
+ var id = 2l;
+ var updatedStudent = new StudentEntity(2l,"Nishanthi M",30,2l,2l);
+
+ webTestClient
+ .put()
+ .uri("/update/{id}", id)
+ .bodyValue(updatedStudent)
+ .exchange()
+ .expectStatus()
+ .is2xxSuccessful()
+ .expectBody(Student.class)
+ .consumeWith(movieInfoEntityExchangeResult -> {
+ var student = movieInfoEntityExchangeResult.getResponseBody();
+ assert student != null;
+ assertEquals("Nishanthi M", student.getName());
+ });
+ }
+
+ @Test
+ void updateStudent_notFound() {
+ var id = 5l;
+ var updatedStudent = new StudentEntity(2l,"Nishanthi M",30,2l,2l);
+
+ webTestClient
+ .put()
+ .uri("/update/{id}", id)
+ .bodyValue(updatedStudent)
+ .exchange()
+ .expectStatus()
+ .isNotFound();
+ }
+ 
+ @Test
+ void deleteStudentById() {
+ var id = 2l;
+
+ webTestClient
+ .delete()
+ .uri("/delete/{id}", id)
+ .exchange()
+ .expectStatus()
+ .isNoContent();
+ }
+ 
+}