From: Gustavo Martin Morcuende Date: Sun, 11 Dec 2016 20:29:47 +0000 (+0100) Subject: RxJavaCarControllerIntegrationTest X-Git-Url: https://git.gumartinm.name/?a=commitdiff_plain;h=12adf2016fe937aa912b04d6f9eb139492e415bc;p=JavaForFun RxJavaCarControllerIntegrationTest --- diff --git a/SpringJava/RxJava/web-services-spring-rxjava-server/src/main/java/de/spring/webservices/rest/controller/RxJavaCarController.java b/SpringJava/RxJava/web-services-spring-rxjava-server/src/main/java/de/spring/webservices/rest/controller/RxJavaCarController.java index 34827cb..450a7c4 100644 --- a/SpringJava/RxJava/web-services-spring-rxjava-server/src/main/java/de/spring/webservices/rest/controller/RxJavaCarController.java +++ b/SpringJava/RxJava/web-services-spring-rxjava-server/src/main/java/de/spring/webservices/rest/controller/RxJavaCarController.java @@ -96,7 +96,7 @@ public class RxJavaCarController { private ResponseEntity createResponseCar(Car car) { HttpHeaders headers = new HttpHeaders(); - headers.add(HttpHeaders.LOCATION, "/api/cars/" + car.getId()); + headers.add(HttpHeaders.LOCATION, "/api/rxjava/cars/" + car.getId()); return new ResponseEntity<>(car, headers, HttpStatus.CREATED); } } diff --git a/SpringJava/RxJava/web-services-spring-rxjava-server/src/test/java/de/spring/webservices/rest/controller/RxJavaCarControllerIntegrationTest.java b/SpringJava/RxJava/web-services-spring-rxjava-server/src/test/java/de/spring/webservices/rest/controller/RxJavaCarControllerIntegrationTest.java new file mode 100644 index 0000000..e7eaeda --- /dev/null +++ b/SpringJava/RxJava/web-services-spring-rxjava-server/src/test/java/de/spring/webservices/rest/controller/RxJavaCarControllerIntegrationTest.java @@ -0,0 +1,128 @@ +package de.spring.webservices.rest.controller; + +import static org.hamcrest.CoreMatchers.instanceOf; +import static org.hamcrest.Matchers.any; +import static org.hamcrest.Matchers.is; +import static org.mockito.BDDMockito.given; +import static org.mockito.Mockito.mock; +import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.asyncDispatch; +import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.get; +import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post; +import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.content; +import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.header; +import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.jsonPath; +import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.request; +import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status; + +import java.util.ArrayList; +import java.util.List; + +import org.junit.Before; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.springframework.data.domain.Page; +import org.springframework.data.domain.PageImpl; +import org.springframework.data.domain.PageRequest; +import org.springframework.http.HttpHeaders; +import org.springframework.http.MediaType; +import org.springframework.http.ResponseEntity; +import org.springframework.test.context.ContextConfiguration; +import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; +import org.springframework.test.web.servlet.MockMvc; +import org.springframework.test.web.servlet.MvcResult; +import org.springframework.test.web.servlet.setup.MockMvcBuilders; + +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.ObjectMapper; + +import de.spring.webservices.domain.Car; +import de.spring.webservices.rest.business.service.RxJavaBusinessLogic; +import io.reactivex.Observable; + + +// jsonPath, how to: https://github.com/jayway/JsonPath | http://jsonpath.herokuapp.com/ + +@RunWith(SpringJUnit4ClassRunner.class) +@ContextConfiguration({ "classpath*:spring-configuration/mvc/rest/*.xml"}) +public class RxJavaCarControllerIntegrationTest { + private static final int PAGE = 2; + private static final int PAGE_SIZE = 10; + private static final String TEMPLATE = "Car: %s"; + + private RxJavaBusinessLogic rxJavaBusinessLogic; + private RxJavaCarController controller; + private MockMvc mockMvc; + + @Before + public void setup() { + rxJavaBusinessLogic = mock(RxJavaBusinessLogic.class); + controller = new RxJavaCarController(rxJavaBusinessLogic); + mockMvc = MockMvcBuilders.standaloneSetup(controller).build(); + } + + @Test + public void testWhenGetAllCarsThenRetrieveJsonValues() throws Exception { + final List cars = new ArrayList<>(); + cars.add(new Car(1L, String.format(TEMPLATE, 1))); + Observable> observable = Observable.create(observer -> observer.onNext( new PageImpl<>(cars))); + given(rxJavaBusinessLogic.findAll(new PageRequest(PAGE, PAGE_SIZE))).willReturn(observable); + + MvcResult result = mockMvc.perform(get("/api/rxjava/cars/") + .accept(MediaType.APPLICATION_JSON_UTF8)) + .andExpect(request().asyncStarted()) + .andExpect(request().asyncResult(instanceOf(Page.class))) + .andReturn(); + + mockMvc.perform(asyncDispatch(result)) + .andExpect(status().isOk()) + .andExpect(jsonPath("$.content[0].id", any(Integer.class))) + .andExpect(jsonPath("$.content[0].id", any(Integer.class))) + .andExpect(jsonPath("$.content[0].content", is("Car: 1"))) + .andExpect(content().contentType(MediaType.APPLICATION_JSON_UTF8)); + } + + @Test + public void testWhenGetOneCarThenRetrieveJsonValue() throws Exception { + Observable observable = Observable.create(observer -> observer.onNext( new Car(1L, String.format(TEMPLATE, 1)))); + given(rxJavaBusinessLogic.findById(1L)).willReturn(observable); + + MvcResult result = mockMvc.perform(get("/api/rxjava/cars/{id}", 1L) + .accept(MediaType.APPLICATION_JSON_UTF8)) + .andExpect(request().asyncStarted()) + .andExpect(request().asyncResult(instanceOf(Car.class))) + .andReturn(); + + mockMvc.perform(asyncDispatch(result)) + .andExpect(status().isOk()) + .andExpect(jsonPath("id", any(Integer.class))) + .andExpect(jsonPath("content", is("Car: 1"))) + .andExpect(content().contentType(MediaType.APPLICATION_JSON_UTF8)); + } + + @Test + public void testWhenCreateNewCarThenRetrieveJsonValue() throws Exception { + Car car = new Car(null, "nothing"); + Observable observable = Observable.create(observer -> observer.onNext( new Car(1L, String.format(TEMPLATE, 1)))); + given(rxJavaBusinessLogic.createThrowable(car)).willReturn(observable); + + MvcResult result = mockMvc.perform(post("/api/rxjava/cars/") + .contentType(MediaType.APPLICATION_JSON_UTF8) + .content(asJsonString(car)) + .accept(MediaType.APPLICATION_JSON_UTF8)) + .andExpect(request().asyncStarted()) + .andExpect(request().asyncResult(instanceOf(ResponseEntity.class))) + .andReturn(); + + mockMvc.perform(asyncDispatch(result)) + .andExpect(status().isCreated()) + .andExpect(jsonPath("id", any(Integer.class))) + .andExpect(jsonPath("content", is("Car: 1"))) + .andExpect(header().string(HttpHeaders.LOCATION, "/api/rxjava/cars/1")) + .andExpect(content().contentType(MediaType.APPLICATION_JSON_UTF8)); + } + + private static String asJsonString(final Object obj) throws JsonProcessingException { + final ObjectMapper mapper = new ObjectMapper(); + return mapper.writeValueAsString(obj); + } +}