feat: add Redis test with TestContainers

Author: hebcodee

domain/src/main/java/br/com/alura/marketplace/domain/usecase/CadastroProdutoUseCase.java

@@ -35,10 +35,8 @@ public Produto cadastrar(Produto produto) {
 
         var produtoSalvo = produtoRepository.save(produto);
 
-//        queueRepository.notificarCadastro(produtoSalvo);
+        queueRepository.notificarCadastro(produtoSalvo);
 
-//        return produtoSalvo;
-
-        return Produto.builder().build();
+        return produtoSalvo;
     }
 }

iandt/src/test/java/br/com/alura/marketplace/iandt/ConsultaProdutoTest.java

@@ -0,0 +1,96 @@
+package br.com.alura.marketplace.iandt;
+
+import br.com.alura.marketplace.application.Application;
+import br.com.alura.marketplace.domain.repository.ProdutoRepository;
+import br.com.alura.marketplace.iandt.setup.LocalStackSetup;
+import br.com.alura.marketplace.iandt.setup.PostgresSetup;
+import br.com.alura.marketplace.iandt.setup.RedisSetup;
+import io.restassured.RestAssured;
+import org.junit.jupiter.api.*;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.test.web.server.LocalServerPort;
+import org.springframework.test.context.ActiveProfiles;
+import org.springframework.test.context.ContextConfiguration;
+import org.testcontainers.junit.jupiter.Testcontainers;
+
+import static br.com.alura.marketplace.domain.entity.ProdutoFactory.criarProduto;
+import static io.restassured.RestAssured.given;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.springframework.boot.test.context.SpringBootTest.WebEnvironment.RANDOM_PORT;
+
+@ActiveProfiles("test")
+@SpringBootTest(webEnvironment = RANDOM_PORT)
+@ContextConfiguration(classes = Application.class)
+@Testcontainers
+class ConsultaProdutoTest implements PostgresSetup, LocalStackSetup, RedisSetup {
+
+    @LocalServerPort
+    Integer port;
+
+    @Autowired
+    ProdutoRepository produtoRepository;
+
+    @BeforeEach
+    void beforeEach() {
+        RestAssured.baseURI = String.format("http://localhost:%s/api", port);
+    }
+
+    @AfterEach
+    void afterEach() {
+        produtoRepository.deleteAll();
+    }
+
+    @DisplayName("Quando consultar um produto")
+    @Nested
+    class ConsultarProduto {
+
+        @DisplayName("Então deve executar com sucesso")
+        @Nested
+        class Sucesso {
+
+            @DisplayName("Dado um produto com todos os campos salvo na base")
+            @Test
+            void teste1() {
+                // Dado
+                var produto = criarProduto()
+                        .comTodosOsCamposExcetoDB();
+                produtoRepository.save(produto);
+                // Quando
+                var response = given()
+                        .log().all()
+                        .get("/v1/produtos/{id}", produto.getProdutoId())
+                        .then()
+                        .log().all()
+                        .extract()
+                        .response();
+                // Então
+                assertThat(response.statusCode())
+                        .isEqualTo(200);
+            }
+
+            @DisplayName("Dado uma segunda consulta do mesmo produto deve usar o cache")
+            @Test
+            void teste2() {
+                // Dado
+                var produto = criarProduto()
+                        .comTodosOsCamposExcetoDB();
+                produtoRepository.save(produto);
+                for (var i = 0; i < 2; i++) {
+                    // Quando
+                    var response = given()
+                            .log().all()
+                            .get("/v1/produtos/{id}", produto.getProdutoId())
+                            .then()
+                            .log().all()
+                            .extract()
+                            .response();
+                    // Então
+                    assertThat(response.statusCode())
+                            .isEqualTo(200);
+                    produtoRepository.deleteAll();
+                }
+            }
+        }
+    }
+}

iandt/src/test/java/br/com/alura/marketplace/iandt/setup/RedisSetup.java

@@ -0,0 +1,23 @@
+package br.com.alura.marketplace.iandt.setup;
+
+import com.redis.testcontainers.RedisContainer;
+import org.junit.jupiter.api.BeforeAll;
+import org.springframework.test.context.DynamicPropertyRegistry;
+import org.springframework.test.context.DynamicPropertySource;
+import org.testcontainers.utility.DockerImageName;
+
+public interface RedisSetup {
+
+    RedisContainer REDIS = new RedisContainer(DockerImageName.parse("redis:6.2.6"));
+
+    @DynamicPropertySource
+    static void RedisDynamicPropertySource(DynamicPropertyRegistry registry) {
+        registry.add("spring.data.redis.host", REDIS::getHost);
+        registry.add("spring.data.redis.port", REDIS::getRedisPort);
+    }
+
+    @BeforeAll
+    static void redisBeforeAll() {
+        REDIS.start();
+    }
+}