Trong bài viết trước, chúng ta đã chuẩn bị tất cả các cấu hình cần thiết để có thể xây dựng API lấy tất cả các category từ Core Category Service như: một đối tượng Category để chứa thông tin của một category, một interface CoreCategoryService với implementation là CoreCategoryServiceImpl có trách nhiệm thao tác với Core Category Service, một CategoryController định nghĩa các API của API Category Service sẽ bắt đầu với “/category” và thông tin về Core Category Service được cấu hình trong tập tin application.properties. Bây giờ, chúng ta sẽ tiến hành xây dựng API này các bạn nhé!
Để xây dựng API lấy tất cả category, đầu tiên, mình sẽ thêm mới một phương thức findAll() trong interface CoreCategoryService:
|
1 |
Flux<Category> findAll(); |
với phần implementation của method này trong class CoreCategoryServiceImpl như sau:
|
1 2 3 4 5 6 7 8 9 10 11 |
@Override public Flux<Category> findAll() { WebClient webClient = WebClient.builder() .baseUrl(getServiceUrl()) .build(); return webClient.get() .uri("/category/all") .retrieve() .bodyToFlux(Category.class); } |
Như các bạn thấy, ở đây mình đã sử dụng đối tượng WebClient để kết nối tới Core Category Service và gọi API tìm tất cả category của service này với URI “/category/all”.
Tiếp theo, mình sẽ thêm mới một method để expose một GET request “/all” trong CategoryController:
|
1 2 3 4 |
@GetMapping("/all") public Flux<Category> findAllCategories() { } |
Nhiệm vụ của chúng ta chỉ là gọi tới phương thức findAll() của class CoreCategoryService mà thôi:
|
1 2 3 4 |
@GetMapping("/all") public Flux<Category> findAllCategories() { return coreCategoryService.findAll(); } |
Đến đây thì chúng ta đã hoàn thành việc xây dựng API tìm tất cả category cho API Category Service, hãy test thử xem sao nhé các bạn.
Bây giờ chúng ta sẽ thêm mới Unit Test cho code mà chúng ta vừa thêm vào, các bạn nhé!
Trong bài viết trước, mình đã tạo mới class test cho CategoryController tên là CategoryControllerTest, đối tượng Mock cho CoreCategoryService và inject đối tượng Mock này vào class CategoryController, khởi tạo mock mỗi khi chạy một test case:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 |
package com.huongdanjava.categoryservice; import org.junit.Before; import org.mockito.InjectMocks; import org.mockito.Mock; import org.mockito.MockitoAnnotations; import com.huongdanjava.categoryservice.service.CoreCategoryService; public class CategoryControllerTest { @Mock private CoreCategoryService coreCategoryService; @InjectMocks private CategoryController categoryController; @Before public void init() { MockitoAnnotations.initMocks(this); } } |
Giờ mình sẽ thêm mới một phương thức để test cho phương thức của findAllCategories() của class CategoryController như sau:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 |
@Test public void testFindAllCategories() { // Create category document to return when using findAll Category category = new Category(); category.setId("123"); category.setCode("ABC"); category.setName("ZXC"); // Mock findAll() method of CoreCategoryService to return a Flux when(coreCategoryService.findAll()).thenReturn(Flux.just(category)); // Call method Flux<Category> categories = categoryController.findAllCategories(); Category result = categories.blockFirst(); // Assertions assertEquals("123", result.getId()); assertEquals("ABC", result.getCode()); assertEquals("ZXC", result.getName()); } |
Chạy “Maven test” trong STS hoặc “mvn test” với Apache Maven, các bạn sẽ không lỗi nào cả.
