Micronaut: Add Transfer operation impl

Author: bitxon

micronaut-app/build.gradle

@@ -32,6 +32,8 @@ dependencies {
     testImplementation("org.testcontainers:junit-jupiter")
     testImplementation("org.testcontainers:postgresql")
     testImplementation("org.testcontainers:testcontainers")
+    testImplementation project(":common-wiremock")
+    testImplementation("com.github.tomakehurst:wiremock:2.27.2")
     implementation("io.micronaut:micronaut-validation")
 }
 

micronaut-app/src/main/java/bitxon/micronaut/client/exchange/ExchangeClient.java

@@ -0,0 +1,13 @@
+package bitxon.micronaut.client.exchange;
+
+import bitxon.api.thirdparty.exchange.model.ExchangeRate;
+import io.micronaut.http.annotation.Get;
+import io.micronaut.http.annotation.QueryValue;
+import io.micronaut.http.client.annotation.Client;
+
+@Client("exchange-client")
+public interface ExchangeClient {
+
+    @Get("/exchanges{?currency}")
+    ExchangeRate getExchangeRate(@QueryValue String currency);
+}

micronaut-app/src/main/java/bitxon/micronaut/controller/AccountController.java

@@ -10,6 +10,7 @@
 
 import bitxon.api.model.Account;
 import bitxon.api.model.MoneyTransfer;
+import bitxon.micronaut.client.exchange.ExchangeClient;
 import bitxon.micronaut.db.AccountDao;
 import bitxon.micronaut.mapper.AccountMapper;
 import io.micronaut.core.annotation.Nullable;
@@ -34,6 +35,7 @@ public class AccountController {
 
     private final AccountDao dao;
     private final AccountMapper mapper;
+    private final ExchangeClient exchangeClient;
 
     @Get
     @ReadOnly
@@ -72,8 +74,8 @@ public void create(@Body @Valid MoneyTransfer transfer,
         var recipient = dao.findById(transfer.getRecipientId())
             .orElseThrow(() -> new RuntimeException("Recipient not found"));
 
-        var exchangeRateValue =  1.0d;
-        //exchangeClient.getExchangeRate(sender.getCurrency()).getRates().getOrDefault(recipient.getCurrency(), 1.0);
+        var exchangeRateValue = exchangeClient.getExchangeRate(sender.getCurrency())
+            .getRates().getOrDefault(recipient.getCurrency(), 1.0);
 
         sender.setMoneyAmount(sender.getMoneyAmount() - transfer.getMoneyAmount());
         dao.save(sender);

micronaut-app/src/main/resources/application.yml

@@ -3,6 +3,11 @@ micronaut:
     name: micronaut-app
   server:
     port: 8080
+  http:
+    services:
+      exchange-client:
+        url: "http://localhost:8888"
+        read-timeout: 1m
 endpoints:
   all:
     port: 8081

micronaut-app/src/test/java/bitxon/micronaut/AbstractMicronautTest.java

@@ -1,15 +1,34 @@
 package bitxon.micronaut;
 
+import java.util.Map;
+
+import com.github.tomakehurst.wiremock.WireMockServer;
+import com.github.tomakehurst.wiremock.client.WireMock;
+import com.github.tomakehurst.wiremock.core.WireMockConfiguration;
 import io.micronaut.http.client.HttpClient;
 import io.micronaut.http.client.annotation.Client;
 import io.micronaut.runtime.EmbeddedApplication;
 import io.micronaut.test.extensions.junit5.annotation.MicronautTest;
+import io.micronaut.test.support.TestPropertyProvider;
 import jakarta.inject.Inject;
+import org.junit.jupiter.api.TestInstance;
 import org.testcontainers.junit.jupiter.Testcontainers;
 
 @Testcontainers
 @MicronautTest // default environments is 'test'
-class AbstractMicronautTest {
+@TestInstance(TestInstance.Lifecycle.PER_CLASS)
+class AbstractMicronautTest implements TestPropertyProvider {
+
+    private static final WireMockServer WIREMOCK;
+
+    static {
+        WIREMOCK = new WireMockServer(WireMockConfiguration.options()
+            .usingFilesUnderClasspath("stubs") // Loading stubs from common-wiremock
+            .dynamicPort()
+        );
+        WIREMOCK.start();
+        WireMock.configureFor(WIREMOCK.port());
+    }
 
     @Inject
     private EmbeddedApplication<?> application;
@@ -21,4 +40,10 @@ protected HttpClient client() {
         return client;
     }
 
+    @Override
+    public Map<String, String> getProperties() {
+        return Map.of(
+            "micronaut.http.services.exchange-client.url", WIREMOCK.baseUrl()
+        );
+    }
 }

micronaut-app/src/test/java/bitxon/micronaut/MoneyTransferMicronautTest.java

@@ -7,13 +7,16 @@
 
 import bitxon.api.model.Account;
 import bitxon.api.model.MoneyTransfer;
+import com.github.tomakehurst.wiremock.client.WireMock;
 import io.micronaut.http.HttpRequest;
 import io.micronaut.http.HttpResponse;
 import io.micronaut.http.HttpStatus;
 import io.micronaut.http.client.exceptions.HttpClientResponseException;
+import io.micronaut.test.extensions.junit5.annotation.MicronautTest;
 import org.junit.jupiter.api.Test;
 
 
+@MicronautTest(rebuildContext = true)
 class MoneyTransferMicronautTest extends AbstractMicronautTest {
 
     @Test

micronaut-app/src/test/resources/application-test.yml

@@ -1,3 +1,10 @@
+micronaut:
+  http:
+    services:
+      exchange-client:
+        url: 'will-be-replaced-in-test'
+        read-timeout: 1m
+
 datasources:
   default:
     url: jdbc:tc:postgresql:14.4:///postgres?TC_INITSCRIPT=file:src/test/resources/sql/db-test-data.sql

spring-app/src/main/resources/application.yml

@@ -20,3 +20,4 @@ logging:
   level:
     root: INFO
     bitxon.dropwizard: DEBUG
+    org.springframework.web.servlet.mvc.support.DefaultHandlerExceptionResolver: ERROR