Unit test the analytics-microservice

Author: BOURGUI07

analytics-service/src/test/java/com/example/analytics_service/AbstractIntegrationTests.java renamed to analytics-service/src/test/java/com/example/analytics_service/intergration_tests/AbstractIntegrationTests.java

@@ -1,4 +1,4 @@
-package com.example.analytics_service;
+package com.example.analytics_service.intergration_tests;
 
 import com.example.analytics_service.dto.ProductViewDTO;
 import com.example.analytics_service.events.ProductEvent;
@@ -8,18 +8,12 @@
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.cloud.stream.function.StreamBridge;
 import org.springframework.context.annotation.Import;
-import org.springframework.core.ParameterizedTypeReference;
-import org.springframework.http.MediaType;
 import org.springframework.kafka.test.context.EmbeddedKafka;
 import org.springframework.test.annotation.DirtiesContext;
 import org.springframework.test.web.reactive.server.WebTestClient;
 import reactor.core.publisher.Flux;
 import reactor.test.StepVerifier;
 
-import java.time.Duration;
-import java.util.List;
-import java.util.function.Consumer;
-
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
 @Import(TestcontainersConfiguration.class)

analytics-service/src/test/java/com/example/analytics_service/AnalyticsServiceTests.java renamed to analytics-service/src/test/java/com/example/analytics_service/intergration_tests/AnalyticsServiceTests.java

@@ -1,11 +1,8 @@
-package com.example.analytics_service;
+package com.example.analytics_service.intergration_tests;
 
-import com.example.analytics_service.dto.ProductViewDTO;
 import org.junit.jupiter.api.Test;
 import org.springframework.test.annotation.DirtiesContext;
 
-import java.util.stream.Collectors;
-
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
 public class AnalyticsServiceTests extends AbstractIntegrationTests{

analytics-service/src/test/java/com/example/analytics_service/TestAnalyticsServiceApplication.java renamed to analytics-service/src/test/java/com/example/analytics_service/intergration_tests/TestAnalyticsServiceApplication.java

@@ -1,5 +1,6 @@
-package com.example.analytics_service;
+package com.example.analytics_service.intergration_tests;
 
+import com.example.analytics_service.AnalyticsServiceApplication;
 import org.springframework.boot.SpringApplication;
 
 public class TestAnalyticsServiceApplication {

analytics-service/src/test/java/com/example/analytics_service/TestcontainersConfiguration.java renamed to analytics-service/src/test/java/com/example/analytics_service/intergration_tests/TestcontainersConfiguration.java

@@ -1,4 +1,4 @@
-package com.example.analytics_service;
+package com.example.analytics_service.intergration_tests;
 
 import org.springframework.boot.test.context.TestConfiguration;
 import org.springframework.boot.testcontainers.service.connection.ServiceConnection;

analytics-service/src/test/java/com/example/analytics_service/unit_tests/AbstractUnitTest.java

@@ -0,0 +1,17 @@
+package com.example.analytics_service.unit_tests;
+
+import com.example.analytics_service.repo.ProductViewRepo;
+import com.example.analytics_service.service.ProductViewService;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+@ExtendWith(MockitoExtension.class)
+public class AbstractUnitTest {
+    @Mock
+    protected ProductViewRepo repo;
+
+    @InjectMocks
+    protected ProductViewService service;
+}

analytics-service/src/test/java/com/example/analytics_service/unit_tests/ProductViewServiceTests.java

@@ -0,0 +1,82 @@
+package com.example.analytics_service.unit_tests;
+
+import com.example.analytics_service.entity.ProductView;
+import com.example.analytics_service.events.ProductEvent;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+import org.mockito.Mockito;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import reactor.test.StepVerifier;
+
+public class ProductViewServiceTests extends AbstractUnitTest{
+
+    @Test
+    @DisplayName("Test findAll")
+    void testFindAll_whenInvoked_ThenReturnFluxOfProducts() {
+        //Arrange
+        var flux = Flux.just(
+                ProductView.builder().viewCount(25L).productCode("P111").build(),
+                ProductView.builder().viewCount(15L).productCode("P151").build(),
+                ProductView.builder().viewCount(5L).productCode("P113").build()
+        );
+
+        Mockito.when(repo.findTop5ByOrderByViewCountDesc()).thenReturn(flux);
+
+        //Act and Assert
+
+        service.products()
+                .collectList()
+                .as(StepVerifier::create)
+                .expectNextMatches(list -> list.size() == 3)
+                .verifyComplete();
+    }
+
+    @Test
+    @DisplayName("Test consume() for new product")
+    void testConsume_WhenNewProductIsConsumed_ThenItsViewCountInitializedAtOne(){
+        //Arrange
+        var event = ProductEvent.View.builder().code("P111").build();
+        var expectedProductView = Mono.fromSupplier(() ->
+                ProductView.builder().viewCount(1L).productCode("P111").build());
+
+        Mockito.when(repo.findByProductCode(Mockito.anyString())).thenReturn(Mono.empty());
+        Mockito.when(repo.save(Mockito.any(ProductView.class))).thenReturn(expectedProductView);
+
+        //Act
+        service.consume().apply(event)
+                .as(StepVerifier::create)
+                .verifyComplete();
+
+        //Assert
+        Mockito.verify(repo, Mockito.times(1)).save(Mockito.argThat(
+                x-> x.getViewCount() == 1 && x.getProductCode().equals("P111")));
+
+    }
+
+
+    @Test
+    @DisplayName("Test consume() for existing product")
+    void testConsume_WhenExistingProductIsConsumed_ThenItsViewCountIncremented(){
+        //Arrange
+        var event = ProductEvent.View.builder().code("P111").build();
+
+        var existingProductView = Mono.fromSupplier(() ->
+                ProductView.builder().viewCount(17L).productCode("P111").build());
+        var expectedProductView = Mono.fromSupplier(() ->
+                ProductView.builder().viewCount(18L).productCode("P111").build());
+
+        Mockito.when(repo.findByProductCode(Mockito.anyString())).thenReturn(existingProductView);
+        Mockito.when(repo.save(Mockito.any(ProductView.class))).thenReturn(expectedProductView);
+
+        //Act
+        service.consume().apply(event)
+                .as(StepVerifier::create)
+                .verifyComplete();
+
+        //Assert
+        Mockito.verify(repo, Mockito.times(1)).save(Mockito.argThat(
+                x-> x.getViewCount() == 18L && x.getProductCode().equals("P111")));
+
+    }
+}