Use Quarkus application framework - step 2: dependency injection in adapter

Author: SvenWoltmann

adapter/pom.xml

@@ -64,18 +64,6 @@
             <scope>test</scope>
         </dependency>
 
-        <!-- Required temporarily during migration -->
-        <dependency>
-            <groupId>org.jboss.resteasy</groupId>
-            <artifactId>resteasy-undertow</artifactId>
-            <scope>test</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.testcontainers</groupId>
-            <artifactId>mysql</artifactId>
-            <scope>test</scope>
-        </dependency>
-
         <!-- To use the "attached test JAR" from the "model" module -->
         <dependency>
             <groupId>eu.happycoders.shop</groupId>

adapter/src/main/java/eu/happycoders/shop/QuarkusAppConfig.java

@@ -0,0 +1,47 @@
+package eu.happycoders.shop;
+
+import eu.happycoders.shop.application.port.in.cart.AddToCartUseCase;
+import eu.happycoders.shop.application.port.in.cart.EmptyCartUseCase;
+import eu.happycoders.shop.application.port.in.cart.GetCartUseCase;
+import eu.happycoders.shop.application.port.in.product.FindProductsUseCase;
+import eu.happycoders.shop.application.port.out.persistence.CartRepository;
+import eu.happycoders.shop.application.port.out.persistence.ProductRepository;
+import eu.happycoders.shop.application.service.cart.AddToCartService;
+import eu.happycoders.shop.application.service.cart.EmptyCartService;
+import eu.happycoders.shop.application.service.cart.GetCartService;
+import eu.happycoders.shop.application.service.product.FindProductsService;
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.enterprise.inject.Instance;
+import jakarta.enterprise.inject.Produces;
+import jakarta.inject.Inject;
+
+class QuarkusAppConfig {
+
+  @Inject Instance<CartRepository> cartRepository;
+
+  @Inject Instance<ProductRepository> productRepository;
+
+  @Produces
+  @ApplicationScoped
+  GetCartUseCase getCartUseCase() {
+    return new GetCartService(cartRepository.get());
+  }
+
+  @Produces
+  @ApplicationScoped
+  EmptyCartUseCase emptyCartUseCase() {
+    return new EmptyCartService(cartRepository.get());
+  }
+
+  @Produces
+  @ApplicationScoped
+  FindProductsUseCase findProductsUseCase() {
+    return new FindProductsService(productRepository.get());
+  }
+
+  @Produces
+  @ApplicationScoped
+  AddToCartUseCase addToCartUseCase() {
+    return new AddToCartService(cartRepository.get(), productRepository.get());
+  }
+}

adapter/src/main/java/eu/happycoders/shop/adapter/out/persistence/inmemory/InMemoryCartRepository.java

@@ -3,6 +3,8 @@
 import eu.happycoders.shop.application.port.out.persistence.CartRepository;
 import eu.happycoders.shop.model.cart.Cart;
 import eu.happycoders.shop.model.customer.CustomerId;
+import io.quarkus.arc.lookup.LookupIfProperty;
+import jakarta.enterprise.context.ApplicationScoped;
 import java.util.Map;
 import java.util.Optional;
 import java.util.concurrent.ConcurrentHashMap;
@@ -12,6 +14,8 @@
  *
  * @author Sven Woltmann
  */
+@LookupIfProperty(name = "persistence", stringValue = "inmemory", lookupIfMissing = true)
+@ApplicationScoped
 public class InMemoryCartRepository implements CartRepository {
 
   private final Map<CustomerId, Cart> carts = new ConcurrentHashMap<>();

adapter/src/main/java/eu/happycoders/shop/adapter/out/persistence/inmemory/InMemoryProductRepository.java

@@ -4,6 +4,8 @@
 import eu.happycoders.shop.application.port.out.persistence.ProductRepository;
 import eu.happycoders.shop.model.product.Product;
 import eu.happycoders.shop.model.product.ProductId;
+import io.quarkus.arc.lookup.LookupIfProperty;
+import jakarta.enterprise.context.ApplicationScoped;
 import java.util.List;
 import java.util.Locale;
 import java.util.Map;
@@ -15,6 +17,8 @@
  *
  * @author Sven Woltmann
  */
+@LookupIfProperty(name = "persistence", stringValue = "inmemory", lookupIfMissing = true)
+@ApplicationScoped
 public class InMemoryProductRepository implements ProductRepository {
 
   private final Map<ProductId, Product> products = new ConcurrentHashMap<>();

adapter/src/main/java/eu/happycoders/shop/adapter/out/persistence/jpa/JpaCartRepository.java

@@ -3,6 +3,8 @@
 import eu.happycoders.shop.application.port.out.persistence.CartRepository;
 import eu.happycoders.shop.model.cart.Cart;
 import eu.happycoders.shop.model.customer.CustomerId;
+import io.quarkus.arc.lookup.LookupIfProperty;
+import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.persistence.EntityManager;
 import jakarta.persistence.EntityManagerFactory;
 import java.util.Optional;
@@ -12,6 +14,8 @@
  *
  * @author Sven Woltmann
  */
+@LookupIfProperty(name = "persistence", stringValue = "mysql")
+@ApplicationScoped
 public class JpaCartRepository implements CartRepository {
 
   private final EntityManagerFactory entityManagerFactory;

adapter/src/main/java/eu/happycoders/shop/adapter/out/persistence/jpa/JpaProductRepository.java

@@ -4,6 +4,8 @@
 import eu.happycoders.shop.application.port.out.persistence.ProductRepository;
 import eu.happycoders.shop.model.product.Product;
 import eu.happycoders.shop.model.product.ProductId;
+import io.quarkus.arc.lookup.LookupIfProperty;
+import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.persistence.EntityManager;
 import jakarta.persistence.EntityManagerFactory;
 import jakarta.persistence.TypedQuery;
@@ -15,6 +17,8 @@
  *
  * @author Sven Woltmann
  */
+@LookupIfProperty(name = "persistence", stringValue = "mysql")
+@ApplicationScoped
 public class JpaProductRepository implements ProductRepository {
 
   private final EntityManagerFactory entityManagerFactory;

adapter/src/main/resources/META-INF/persistence.xml

@@ -0,0 +1,12 @@
+package eu.happycoders.shop.adapter;
+
+import io.quarkus.test.junit.QuarkusTestProfile;
+import java.util.Map;
+
+public class TestProfileWithMySQL implements QuarkusTestProfile {
+
+  @Override
+  public Map<String, String> getConfigOverrides() {
+    return Map.of("persistence", "mysql");
+  }
+}

adapter/src/test/java/eu/happycoders/shop/adapter/TestProfileWithMySQL.java

@@ -1,14 +1,12 @@
 package eu.happycoders.shop.adapter.in.rest.cart;
 
-import static eu.happycoders.shop.adapter.in.rest.HttpTestCommons.TEST_PORT;
 import static eu.happycoders.shop.adapter.in.rest.HttpTestCommons.assertThatResponseIsError;
 import static eu.happycoders.shop.adapter.in.rest.cart.CartsControllerAssertions.assertThatResponseIsCart;
 import static eu.happycoders.shop.model.money.TestMoneyFactory.euros;
 import static eu.happycoders.shop.model.product.TestProductFactory.createTestProduct;
 import static io.restassured.RestAssured.given;
 import static jakarta.ws.rs.core.Response.Status.BAD_REQUEST;
 import static jakarta.ws.rs.core.Response.Status.NO_CONTENT;
-import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
 
@@ -21,62 +19,27 @@
 import eu.happycoders.shop.model.customer.CustomerId;
 import eu.happycoders.shop.model.product.Product;
 import eu.happycoders.shop.model.product.ProductId;
+import io.quarkus.test.InjectMock;
+import io.quarkus.test.junit.QuarkusTest;
 import io.restassured.response.Response;
-import jakarta.ws.rs.core.Application;
-import java.util.Set;
-import org.jboss.resteasy.plugins.server.undertow.UndertowJaxrsServer;
-import org.junit.jupiter.api.AfterAll;
-import org.junit.jupiter.api.BeforeAll;
-import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
-import org.mockito.Mockito;
 
+@QuarkusTest
 class CartsControllerTest {
 
   private static final CustomerId TEST_CUSTOMER_ID = new CustomerId(61157);
   private static final Product TEST_PRODUCT_1 = createTestProduct(euros(19, 99));
   private static final Product TEST_PRODUCT_2 = createTestProduct(euros(25, 99));
 
-  private static final AddToCartUseCase addToCartUseCase = mock(AddToCartUseCase.class);
-  private static final GetCartUseCase getCartUseCase = mock(GetCartUseCase.class);
-  private static final EmptyCartUseCase emptyCartUseCase = mock(EmptyCartUseCase.class);
-
-  private static UndertowJaxrsServer server;
-
-  @BeforeAll
-  static void init() {
-    server =
-        new UndertowJaxrsServer()
-            .setPort(TEST_PORT)
-            .start()
-            .deploy(
-                new Application() {
-                  @Override
-                  public Set<Object> getSingletons() {
-                    return Set.of(
-                        new AddToCartController(addToCartUseCase),
-                        new GetCartController(getCartUseCase),
-                        new EmptyCartController(emptyCartUseCase));
-                  }
-                });
-  }
-
-  @AfterAll
-  static void stop() {
-    server.stop();
-  }
-
-  @BeforeEach
-  void resetMocks() {
-    Mockito.reset(addToCartUseCase, getCartUseCase, emptyCartUseCase);
-  }
+  @InjectMock AddToCartUseCase addToCartUseCase;
+  @InjectMock GetCartUseCase getCartUseCase;
+  @InjectMock EmptyCartUseCase emptyCartUseCase;
 
   @Test
   void givenASyntacticallyInvalidCustomerId_getCart_returnsAnError() {
     String customerId = "foo";
 
-    Response response =
-        given().port(TEST_PORT).get("/carts/" + customerId).then().extract().response();
+    Response response = given().get("/carts/" + customerId).then().extract().response();
 
     assertThatResponseIsError(response, BAD_REQUEST, "Invalid 'customerId'");
   }
@@ -92,8 +55,7 @@ void givenAValidCustomerIdAndACart_getCart_requestsCartFromUseCaseAndReturnsIt()
 
     when(getCartUseCase.getCart(customerId)).thenReturn(cart);
 
-    Response response =
-        given().port(TEST_PORT).get("/carts/" + customerId.value()).then().extract().response();
+    Response response = given().get("/carts/" + customerId.value()).then().extract().response();
 
     assertThatResponseIsCart(response, cart);
   }
@@ -112,7 +74,6 @@ void givenSomeTestData_addLineItem_invokesAddToCartUseCaseAndReturnsUpdatedCart(
 
     Response response =
         given()
-            .port(TEST_PORT)
             .queryParam("productId", productId.value())
             .queryParam("quantity", quantity)
             .post("/carts/" + customerId.value() + "/line-items")
@@ -131,7 +92,6 @@ void givenAnInvalidProductId_addLineItem_returnsAnError() {
 
     Response response =
         given()
-            .port(TEST_PORT)
             .queryParam("productId", productId)
             .queryParam("quantity", quantity)
             .post("/carts/" + customerId.value() + "/line-items")
@@ -154,7 +114,6 @@ void givenProductNotFound_addLineItem_returnsAnError()
 
     Response response =
         given()
-            .port(TEST_PORT)
             .queryParam("productId", productId.value())
             .queryParam("quantity", quantity)
             .post("/carts/" + customerId.value() + "/line-items")
@@ -177,7 +136,6 @@ void givenNotEnoughItemsInStock_addLineItem_returnsAnError()
 
     Response response =
         given()
-            .port(TEST_PORT)
             .queryParam("productId", productId.value())
             .queryParam("quantity", quantity)
             .post("/carts/" + customerId.value() + "/line-items")
@@ -192,11 +150,7 @@ void givenNotEnoughItemsInStock_addLineItem_returnsAnError()
   void givenACustomerId_deleteCart_invokesDeleteCartUseCaseAndReturnsUpdatedCart() {
     CustomerId customerId = TEST_CUSTOMER_ID;
 
-    given()
-        .port(TEST_PORT)
-        .delete("/carts/" + customerId.value())
-        .then()
-        .statusCode(NO_CONTENT.getStatusCode());
+    given().delete("/carts/" + customerId.value()).then().statusCode(NO_CONTENT.getStatusCode());
 
     verify(emptyCartUseCase).emptyCart(customerId);
   }