diff --git a/pom.xml b/pom.xml
index 7431833..78cfbdb 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
eu.ztsh
wymiana-walut
- 1.0.0
+ 1.1.0
diff --git a/readme.md b/readme.md
index 3e0fd54..f2ce86f 100644
--- a/readme.md
+++ b/readme.md
@@ -28,9 +28,9 @@ Prosty mikroserwis stworzony na potrzeby rekrutacji
"pesel": {
"type": "string"
},
- "pln": {
+ "initial": {
"type": "number",
- "description": "początkowy stan konta w złotówkach"
+ "description": "początkowy stan konta w domyślnej walucie"
}
},
"required": [
@@ -168,6 +168,35 @@ Prosty mikroserwis stworzony na potrzeby rekrutacji
actor <--> exchange
endpoint <--> core
core <--> tabC
- core <-- hsql.port --> hsqldb
+ core <-- hsql . port --> hsqldb
```
+
+## Konfiguracja
+
+Aplikacja posiada dostosowaną konfigurację, która obejmuje własności:
+
+### `hsqldb`
+
+Konfiguracja bazy danych
+
+| Nazwa | Opis | Typ | Wartość domyślna |
+|-------|------------------|--------|------------------|
+| name | host bazy danych | string | db |
+| port | port bazy danych | int | 9090 |
+
+### `nbp`
+
+Konfiguracja połączenia z Narodowym Bankiem Polskim
+
+| Nazwa | Opis | Typ | Wartość domyślna |
+|---------|--------------|--------|-------------------|
+| baseurl | host API nbp | string | http://api.nbp.pl |
+
+### `currency`
+
+Konfiguracja walut
+
+| Nazwa | Opis | Typ | Wartość domyślna |
+|---------|-----------------------------------------|--------|------------------|
+| initial | waluta początkowa przy zakładaniu konta | string | PLN |
diff --git a/src/main/java/eu/ztsh/wymiana/config/CurrencyProperties.java b/src/main/java/eu/ztsh/wymiana/config/CurrencyProperties.java
new file mode 100644
index 0000000..9cfbce1
--- /dev/null
+++ b/src/main/java/eu/ztsh/wymiana/config/CurrencyProperties.java
@@ -0,0 +1,9 @@
+package eu.ztsh.wymiana.config;
+
+import eu.ztsh.wymiana.model.Symbol;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+@ConfigurationProperties("currency")
+public record CurrencyProperties(Symbol initial) {
+
+}
diff --git a/src/main/java/eu/ztsh/wymiana/data/entity/CurrencyEntity.java b/src/main/java/eu/ztsh/wymiana/data/entity/CurrencyEntity.java
index f468a67..95615f0 100644
--- a/src/main/java/eu/ztsh/wymiana/data/entity/CurrencyEntity.java
+++ b/src/main/java/eu/ztsh/wymiana/data/entity/CurrencyEntity.java
@@ -1,6 +1,9 @@
package eu.ztsh.wymiana.data.entity;
+import eu.ztsh.wymiana.model.Symbol;
import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
import jakarta.persistence.Id;
import jakarta.persistence.Table;
import lombok.AllArgsConstructor;
@@ -19,7 +22,8 @@ public class CurrencyEntity {
@Id
String pesel;
@Id
- String symbol;
+ @Enumerated(EnumType.STRING)
+ Symbol symbol;
BigDecimal amount;
}
diff --git a/src/main/java/eu/ztsh/wymiana/exception/NoDataException.java b/src/main/java/eu/ztsh/wymiana/exception/NoDataException.java
index 8da9ad6..1472b0b 100644
--- a/src/main/java/eu/ztsh/wymiana/exception/NoDataException.java
+++ b/src/main/java/eu/ztsh/wymiana/exception/NoDataException.java
@@ -1,8 +1,10 @@
package eu.ztsh.wymiana.exception;
+import eu.ztsh.wymiana.model.Symbol;
+
public class NoDataException extends RuntimeException {
- public NoDataException(String code, String date) {
+ public NoDataException(Symbol code, String date) {
super("No data for code %s and date %s".formatted(code, date));
}
diff --git a/src/main/java/eu/ztsh/wymiana/model/Currency.java b/src/main/java/eu/ztsh/wymiana/model/Currency.java
index e644aff..05e7ab1 100644
--- a/src/main/java/eu/ztsh/wymiana/model/Currency.java
+++ b/src/main/java/eu/ztsh/wymiana/model/Currency.java
@@ -2,6 +2,6 @@ package eu.ztsh.wymiana.model;
import java.math.BigDecimal;
-public record Currency(String symbol, BigDecimal amount) {
+public record Currency(Symbol symbol, BigDecimal amount) {
}
diff --git a/src/main/java/eu/ztsh/wymiana/model/Symbol.java b/src/main/java/eu/ztsh/wymiana/model/Symbol.java
new file mode 100644
index 0000000..4d38bbd
--- /dev/null
+++ b/src/main/java/eu/ztsh/wymiana/model/Symbol.java
@@ -0,0 +1,6 @@
+package eu.ztsh.wymiana.model;
+
+public enum Symbol {
+ PLN,
+ USD
+}
diff --git a/src/main/java/eu/ztsh/wymiana/model/User.java b/src/main/java/eu/ztsh/wymiana/model/User.java
index a1f28f1..7ae46a1 100644
--- a/src/main/java/eu/ztsh/wymiana/model/User.java
+++ b/src/main/java/eu/ztsh/wymiana/model/User.java
@@ -2,6 +2,6 @@ package eu.ztsh.wymiana.model;
import java.util.Map;
-public record User(String name, String surname, String pesel, Map currencies) {
+public record User(String name, String surname, String pesel, Map currencies) {
}
diff --git a/src/main/java/eu/ztsh/wymiana/model/UserCreateRequestConfiguredWrapper.java b/src/main/java/eu/ztsh/wymiana/model/UserCreateRequestConfiguredWrapper.java
new file mode 100644
index 0000000..b4a3619
--- /dev/null
+++ b/src/main/java/eu/ztsh/wymiana/model/UserCreateRequestConfiguredWrapper.java
@@ -0,0 +1,65 @@
+package eu.ztsh.wymiana.model;
+
+import eu.ztsh.wymiana.web.model.UserCreateRequest;
+
+import java.math.BigDecimal;
+
+public class UserCreateRequestConfiguredWrapper {
+
+ private final UserCreateRequest request;
+ private final Symbol initialSymbol;
+
+ public String name() {
+ return request.name();
+ }
+
+ public String surname() {
+ return request.surname();
+ }
+
+ public String pesel() {
+ return request.pesel();
+ }
+
+ public BigDecimal initial() {
+ return request.initial();
+ }
+
+ public Symbol initialSymbol() {
+ return initialSymbol;
+ }
+
+ private UserCreateRequestConfiguredWrapper(Builder builder) {
+ this.request = builder.request;
+ this.initialSymbol = builder.initial;
+ }
+
+ public static Builder wrap(UserCreateRequest request) {
+ return new Builder().withRequest(request);
+ }
+
+ public static final class Builder {
+
+ private UserCreateRequest request;
+ private Symbol initial;
+
+ private Builder() {
+ }
+
+ private Builder withRequest(UserCreateRequest request) {
+ this.request = request;
+ return this;
+ }
+
+ public Builder withInitial(Symbol initial) {
+ this.initial = initial;
+ return this;
+ }
+
+ public UserCreateRequestConfiguredWrapper build() {
+ return new UserCreateRequestConfiguredWrapper(this);
+ }
+
+ }
+
+}
diff --git a/src/main/java/eu/ztsh/wymiana/service/CurrencyService.java b/src/main/java/eu/ztsh/wymiana/service/CurrencyService.java
index 9480825..e9736d7 100644
--- a/src/main/java/eu/ztsh/wymiana/service/CurrencyService.java
+++ b/src/main/java/eu/ztsh/wymiana/service/CurrencyService.java
@@ -4,6 +4,7 @@ import eu.ztsh.wymiana.exception.ExchangeFailedException;
import eu.ztsh.wymiana.exception.InsufficientFundsException;
import eu.ztsh.wymiana.exception.UserNotFoundException;
import eu.ztsh.wymiana.model.Currency;
+import eu.ztsh.wymiana.model.Symbol;
import eu.ztsh.wymiana.model.User;
import eu.ztsh.wymiana.validation.InstanceValidator;
import eu.ztsh.wymiana.web.model.CurrencyExchangeRequest;
@@ -28,23 +29,17 @@ public class CurrencyService {
public User exchange(CurrencyExchangeRequest request) {
validator.validate(request);
return userService.get(request.pesel()).map(user -> {
- if (!request.from().equalsIgnoreCase("PLN") && !request.to().equalsIgnoreCase("PLN")) {
+ if (!request.from().equals(Symbol.PLN) && !request.to().equals(Symbol.PLN)) {
throw new ExchangeFailedException("Either 'from' or 'to' has to be PLN");
}
- // As we support only USD now, we need to limit second parameter too
- // Begin: unlock other currencies
- if (!request.from().equalsIgnoreCase("USD") && !request.to().equalsIgnoreCase("USD")) {
- throw new ExchangeFailedException("Either 'from' or 'to' has to be USD");
- }
- // End: unlock other currencies
- var from = user.currencies().get(request.from().toUpperCase());
+ var from = user.currencies().get(request.from());
if (from == null) {
// There is no currency 'from' opened so no need to check if user has funds to exchange
throw new InsufficientFundsException();
}
var exchanged = performExchange(from,
- Optional.ofNullable(user.currencies().get(request.to().toUpperCase())).orElse(create(request.to())),
+ Optional.ofNullable(user.currencies().get(request.to())).orElse(create(request.to())),
Optional.ofNullable(request.toSell()).orElse(BigDecimal.ZERO),
Optional.ofNullable(request.toBuy()).orElse(BigDecimal.ZERO));
user.currencies().putAll(exchanged);
@@ -53,16 +48,15 @@ public class CurrencyService {
.orElseThrow(() -> new UserNotFoundException(request));
}
- private Currency create(String symbol) {
- // TODO: check if supported - now limited to PLN <-> USD
- return new Currency(symbol.toUpperCase(), BigDecimal.ZERO);
+ private Currency create(Symbol symbol) {
+ return new Currency(symbol, BigDecimal.ZERO);
}
- private Map performExchange(Currency from, Currency to, BigDecimal toSell, BigDecimal toBuy) {
+ private Map performExchange(Currency from, Currency to, BigDecimal toSell, BigDecimal toBuy) {
BigDecimal exchangeRate;
BigDecimal neededFromAmount;
BigDecimal requestedToAmount;
- if (from.symbol().equalsIgnoreCase("PLN")) {
+ if (from.symbol().equals(Symbol.PLN)) {
exchangeRate = nbpService.getSellRate(to.symbol());
neededFromAmount = round(toBuy.signum() != 0 ? toBuy.multiply(exchangeRate) : toSell);
requestedToAmount = round(toBuy.signum() != 0 ? toBuy : divide(toSell, exchangeRate));
diff --git a/src/main/java/eu/ztsh/wymiana/service/NbpService.java b/src/main/java/eu/ztsh/wymiana/service/NbpService.java
index 3fca0d1..3d5edd3 100644
--- a/src/main/java/eu/ztsh/wymiana/service/NbpService.java
+++ b/src/main/java/eu/ztsh/wymiana/service/NbpService.java
@@ -2,6 +2,7 @@ package eu.ztsh.wymiana.service;
import eu.ztsh.wymiana.exception.NoDataException;
import eu.ztsh.wymiana.model.Rates;
+import eu.ztsh.wymiana.model.Symbol;
import lombok.RequiredArgsConstructor;
import org.assertj.core.util.VisibleForTesting;
import org.springframework.http.HttpStatusCode;
@@ -29,17 +30,17 @@ public class NbpService {
private static final String URI_PATTERN = "/api/exchangerates/rates/c/{code}/{date}/";
private final DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd");
- private final ConcurrentMap cache = new ConcurrentHashMap<>(1);
+ private final ConcurrentMap cache = new ConcurrentHashMap<>(1);
- public BigDecimal getSellRate(String currency) {
- return getCurrency(currency.toUpperCase()).sell();
+ public BigDecimal getSellRate(Symbol currency) {
+ return getCurrency(currency).sell();
}
- public BigDecimal getBuyRate(String currency) {
- return getCurrency(currency.toUpperCase()).buy();
+ public BigDecimal getBuyRate(Symbol currency) {
+ return getCurrency(currency).buy();
}
- private synchronized RatesCache getCurrency(String currency) {
+ private synchronized RatesCache getCurrency(Symbol currency) {
var today = getFetchDate();
var cacheObject = cache.get(currency);
if (cacheObject == null || cacheObject.date().isBefore(today)) {
@@ -50,7 +51,7 @@ public class NbpService {
rate.getBid(),
rate.getAsk()
);
- cache.put(fresh.getCode(), cacheObject);
+ cache.put(Symbol.valueOf(fresh.getCode().toUpperCase()), cacheObject);
}
return cacheObject;
}
@@ -69,8 +70,8 @@ public class NbpService {
}
@VisibleForTesting
- Rates fetchData(String code, String date) {
- return restClient.get().uri(URI_PATTERN, code.toLowerCase(), date)
+ Rates fetchData(Symbol code, String date) {
+ return restClient.get().uri(URI_PATTERN, code.name().toLowerCase(), date)
.retrieve()
.onStatus(HttpStatusCode::is4xxClientError, ((request, response) -> {
throw new NoDataException(code, date);
diff --git a/src/main/java/eu/ztsh/wymiana/service/UserService.java b/src/main/java/eu/ztsh/wymiana/service/UserService.java
index 857bc0f..2205d19 100644
--- a/src/main/java/eu/ztsh/wymiana/service/UserService.java
+++ b/src/main/java/eu/ztsh/wymiana/service/UserService.java
@@ -1,8 +1,10 @@
package eu.ztsh.wymiana.service;
+import eu.ztsh.wymiana.config.CurrencyProperties;
import eu.ztsh.wymiana.data.repository.UserRepository;
import eu.ztsh.wymiana.exception.UserAlreadyExistsException;
import eu.ztsh.wymiana.model.User;
+import eu.ztsh.wymiana.model.UserCreateRequestConfiguredWrapper;
import eu.ztsh.wymiana.util.UserMapper;
import eu.ztsh.wymiana.validation.InstanceValidator;
import eu.ztsh.wymiana.web.model.UserCreateRequest;
@@ -20,13 +22,16 @@ public class UserService {
private final UserRepository userRepository;
private final InstanceValidator validator;
+ private final CurrencyProperties currencyProperties;
public User create(UserCreateRequest request) {
validator.validate(request);
if (userRepository.findById(request.pesel()).isPresent()) {
throw new UserAlreadyExistsException(request);
}
- return UserMapper.entityToPojo(userRepository.save(UserMapper.requestToEntity(request)));
+ return UserMapper.entityToPojo(userRepository.save(UserMapper.requestToEntity(
+ UserCreateRequestConfiguredWrapper.wrap(request).withInitial(currencyProperties.initial()).build()
+ )));
}
public Optional get(@PESEL String pesel) {
diff --git a/src/main/java/eu/ztsh/wymiana/util/CurrencyMapper.java b/src/main/java/eu/ztsh/wymiana/util/CurrencyMapper.java
index b962ddc..697e956 100644
--- a/src/main/java/eu/ztsh/wymiana/util/CurrencyMapper.java
+++ b/src/main/java/eu/ztsh/wymiana/util/CurrencyMapper.java
@@ -2,6 +2,7 @@ package eu.ztsh.wymiana.util;
import eu.ztsh.wymiana.data.entity.CurrencyEntity;
import eu.ztsh.wymiana.model.Currency;
+import eu.ztsh.wymiana.model.Symbol;
import java.util.List;
import java.util.Map;
@@ -17,12 +18,12 @@ public class CurrencyMapper {
return new CurrencyEntity(pesel, pojo.symbol(), pojo.amount());
}
- public static Map entitiesToPojoMap(List values) {
+ public static Map entitiesToPojoMap(List values) {
return values.stream().map(CurrencyMapper::entityToPojo)
.collect(Collectors.toMap(Currency::symbol, pojo -> pojo));
}
- public static List pojoMapToEntities(Map currencies, String pesel) {
+ public static List pojoMapToEntities(Map currencies, String pesel) {
return currencies.values().stream().map(entry -> pojoToEntity(entry, pesel)).toList();
}
diff --git a/src/main/java/eu/ztsh/wymiana/util/UserMapper.java b/src/main/java/eu/ztsh/wymiana/util/UserMapper.java
index 44f2524..31c2a20 100644
--- a/src/main/java/eu/ztsh/wymiana/util/UserMapper.java
+++ b/src/main/java/eu/ztsh/wymiana/util/UserMapper.java
@@ -3,7 +3,7 @@ package eu.ztsh.wymiana.util;
import eu.ztsh.wymiana.data.entity.CurrencyEntity;
import eu.ztsh.wymiana.data.entity.UserEntity;
import eu.ztsh.wymiana.model.User;
-import eu.ztsh.wymiana.web.model.UserCreateRequest;
+import eu.ztsh.wymiana.model.UserCreateRequestConfiguredWrapper;
import eu.ztsh.wymiana.web.model.UserResponse;
import java.util.List;
@@ -24,9 +24,9 @@ public class UserMapper {
return new UserResponse(pojo.name(), pojo.surname(), pojo.pesel(), pojo.currencies().values().stream().toList());
}
- public static UserEntity requestToEntity(UserCreateRequest request) {
+ public static UserEntity requestToEntity(UserCreateRequestConfiguredWrapper request) {
return new UserEntity(request.pesel(), request.name(), request.surname(),
- List.of(new CurrencyEntity(request.pesel(), "PLN", request.initial())));
+ List.of(new CurrencyEntity(request.pesel(), request.initialSymbol(), request.initial())));
}
private UserMapper() {
diff --git a/src/main/java/eu/ztsh/wymiana/web/model/CurrencyExchangeRequest.java b/src/main/java/eu/ztsh/wymiana/web/model/CurrencyExchangeRequest.java
index 5264636..c999dc5 100644
--- a/src/main/java/eu/ztsh/wymiana/web/model/CurrencyExchangeRequest.java
+++ b/src/main/java/eu/ztsh/wymiana/web/model/CurrencyExchangeRequest.java
@@ -1,5 +1,6 @@
package eu.ztsh.wymiana.web.model;
+import eu.ztsh.wymiana.model.Symbol;
import eu.ztsh.wymiana.validation.ValidExchangeRequest;
import jakarta.validation.constraints.Min;
import jakarta.validation.constraints.NotNull;
@@ -12,8 +13,8 @@ import java.math.BigDecimal;
@ValidExchangeRequest
public record CurrencyExchangeRequest(
@NotNull @PESEL String pesel,
- @NotNull String from,
- @NotNull String to,
+ @NotNull Symbol from,
+ @NotNull Symbol to,
@Min(0) BigDecimal toBuy,
@Min(0) BigDecimal toSell
) {
diff --git a/src/main/resources/application.yaml b/src/main/resources/application.yaml
index 47b720c..84ae7b8 100644
--- a/src/main/resources/application.yaml
+++ b/src/main/resources/application.yaml
@@ -4,6 +4,8 @@ hsqldb:
nbp:
baseurl: "http://api.nbp.pl"
+currency:
+ initial: PLN
spring:
datasource:
@@ -14,6 +16,9 @@ spring:
jpa:
hibernate:
ddl-auto: create
+ jackson:
+ mapper:
+ ACCEPT_CASE_INSENSITIVE_ENUMS: true
management:
endpoints:
diff --git a/src/test/java/eu/ztsh/wymiana/EntityCreator.java b/src/test/java/eu/ztsh/wymiana/EntityCreator.java
index 6535f11..0f3b662 100644
--- a/src/test/java/eu/ztsh/wymiana/EntityCreator.java
+++ b/src/test/java/eu/ztsh/wymiana/EntityCreator.java
@@ -5,6 +5,7 @@ import eu.ztsh.wymiana.data.entity.UserEntity;
import eu.ztsh.wymiana.model.Currency;
import eu.ztsh.wymiana.model.Rate;
import eu.ztsh.wymiana.model.Rates;
+import eu.ztsh.wymiana.model.Symbol;
import eu.ztsh.wymiana.model.User;
import eu.ztsh.wymiana.web.model.CurrencyExchangeRequest;
import eu.ztsh.wymiana.web.model.UserCreateRequest;
@@ -29,8 +30,6 @@ public class EntityCreator {
public static BigDecimal PLN = createScaled(20.10, 2);
public static BigDecimal USD_SELL = createScaled(5.18, 2);
public static BigDecimal USD_BUY = createScaled(5.08, 2);
- public static String PLN_SYMBOL = "PLN";
- public static String USD_SYMBOL = "USD";
public static BigDecimal BUY_RATE = createScaled(3.8804, 4);
public static BigDecimal SELL_RATE = createScaled(3.9572, 4);
@@ -45,12 +44,12 @@ public class EntityCreator {
}
public static User user(BigDecimal pln, BigDecimal usd) {
- Map currencies = new HashMap<>();
+ Map currencies = new HashMap<>();
if (pln.signum() > 0) {
- currencies.put("PLN", new Currency("PLN", pln));
+ currencies.put(Symbol.PLN, new Currency(Symbol.PLN, pln));
}
if (usd.signum() > 0) {
- currencies.put("USD", new Currency("USD", usd));
+ currencies.put(Symbol.USD, new Currency(Symbol.USD, usd));
}
return new User(Constants.NAME, Constants.SURNAME, Constants.PESEL, currencies);
}
@@ -74,7 +73,7 @@ public class EntityCreator {
var rates = new Rates();
rates.setTable("C");
rates.setCurrency("dolar amerykański");
- rates.setCode("USD");
+ rates.setCode(Symbol.USD.toString());
var rate = new Rate();
rate.setNo("096/C/NBP/2024");
rate.setEffectiveDate(date);
@@ -129,13 +128,13 @@ public class EntityCreator {
var nonnulPesel = Optional.ofNullable(pesel).orElse(Constants.PESEL);
List currencies = new ArrayList<>();
if (pln.signum() > -1) {
- currencies.add(new CurrencyEntity(nonnulPesel, "PLN", pln));
+ currencies.add(new CurrencyEntity(nonnulPesel, Symbol.PLN, pln));
}
if (usd.signum() > -1) {
- currencies.add(new CurrencyEntity(nonnulPesel, "USD", usd));
+ currencies.add(new CurrencyEntity(nonnulPesel, Symbol.USD, usd));
}
if (currencies.isEmpty()) {
- currencies.add(new CurrencyEntity(nonnulPesel, "PLN", Constants.PLN));
+ currencies.add(new CurrencyEntity(nonnulPesel, Symbol.PLN, Constants.PLN));
}
return new UserEntity(
nonnulPesel,
diff --git a/src/test/java/eu/ztsh/wymiana/RepositoryBasedTest.java b/src/test/java/eu/ztsh/wymiana/RepositoryBasedTest.java
index cd0ffcf..5e0bc54 100644
--- a/src/test/java/eu/ztsh/wymiana/RepositoryBasedTest.java
+++ b/src/test/java/eu/ztsh/wymiana/RepositoryBasedTest.java
@@ -29,6 +29,7 @@ public abstract class RepositoryBasedTest {
.isNotEmpty()
.get()
.usingRecursiveComparison()
+ .ignoringCollectionOrder()
.isEqualTo(entity);
}
diff --git a/src/test/java/eu/ztsh/wymiana/service/CurrencyServiceTest.java b/src/test/java/eu/ztsh/wymiana/service/CurrencyServiceTest.java
index 474f11f..14f7ea3 100644
--- a/src/test/java/eu/ztsh/wymiana/service/CurrencyServiceTest.java
+++ b/src/test/java/eu/ztsh/wymiana/service/CurrencyServiceTest.java
@@ -2,10 +2,11 @@ package eu.ztsh.wymiana.service;
import eu.ztsh.wymiana.EntityCreator;
import eu.ztsh.wymiana.RepositoryBasedTest;
+import eu.ztsh.wymiana.config.CurrencyProperties;
import eu.ztsh.wymiana.data.repository.UserRepository;
-import eu.ztsh.wymiana.exception.ExchangeFailedException;
import eu.ztsh.wymiana.exception.InsufficientFundsException;
import eu.ztsh.wymiana.exception.UserNotFoundException;
+import eu.ztsh.wymiana.model.Symbol;
import eu.ztsh.wymiana.validation.InstanceValidator;
import eu.ztsh.wymiana.validation.ValidationFailedException;
import jakarta.transaction.Transactional;
@@ -29,12 +30,14 @@ class CurrencyServiceTest extends RepositoryBasedTest {
private final CurrencyService currencyService;
@Autowired
- public CurrencyServiceTest(UserRepository userRepository, InstanceValidator instanceValidator) {
+ public CurrencyServiceTest(UserRepository userRepository, InstanceValidator instanceValidator,
+ CurrencyProperties currencyProperties) {
super(userRepository);
var nbp = Mockito.mock(NbpService.class);
- Mockito.when(nbp.getSellRate("USD")).thenReturn(SELL_RATE);
- Mockito.when(nbp.getBuyRate("USD")).thenReturn(BUY_RATE);
- currencyService = new CurrencyService(new UserService(userRepository, instanceValidator), nbp, instanceValidator);
+ Mockito.when(nbp.getSellRate(Symbol.USD)).thenReturn(SELL_RATE);
+ Mockito.when(nbp.getBuyRate(Symbol.USD)).thenReturn(BUY_RATE);
+ currencyService = new CurrencyService(new UserService(userRepository, instanceValidator, currencyProperties),
+ nbp, instanceValidator);
}
@Transactional
@@ -43,12 +46,12 @@ class CurrencyServiceTest extends RepositoryBasedTest {
var entity = EntityCreator.userEntity().build();
userRepository.save(entity);
var result = currencyService.exchange(EntityCreator.exchangeRequest()
- .from(PLN_SYMBOL)
- .to(USD_SYMBOL)
+ .from(Symbol.PLN)
+ .to(Symbol.USD)
.toSell(PLN)
.build());
assertThat(result.currencies())
- .matches(map -> map.get(PLN_SYMBOL).amount().signum() == 0 && Objects.equals(map.get(USD_SYMBOL).amount(), USD_BUY), "USD 5.08");
+ .matches(map -> map.get(Symbol.PLN).amount().signum() == 0 && Objects.equals(map.get(Symbol.USD).amount(), USD_BUY), "USD 5.08");
var expected = EntityCreator.userEntity().pln(0).usd(USD_BUY).build();
expect(expected);
}
@@ -59,12 +62,12 @@ class CurrencyServiceTest extends RepositoryBasedTest {
var entity = EntityCreator.userEntity().build();
userRepository.save(entity);
var result = currencyService.exchange(EntityCreator.exchangeRequest()
- .from(PLN_SYMBOL)
- .to(USD_SYMBOL)
+ .from(Symbol.PLN)
+ .to(Symbol.USD)
.toBuy(USD_BUY)
.build());
assertThat(result.currencies())
- .matches(map -> map.get(PLN_SYMBOL).amount().signum() == 0 && Objects.equals(map.get(USD_SYMBOL).amount(), USD_BUY));
+ .matches(map -> map.get(Symbol.PLN).amount().signum() == 0 && Objects.equals(map.get(Symbol.USD).amount(), USD_BUY));
var expected = EntityCreator.userEntity().pln(0).usd(USD_BUY).build();
expect(expected);
}
@@ -75,12 +78,12 @@ class CurrencyServiceTest extends RepositoryBasedTest {
var entity = EntityCreator.userEntity().pln(-1).usd(USD_SELL).build();
userRepository.save(entity);
var result = currencyService.exchange(EntityCreator.exchangeRequest()
- .from(USD_SYMBOL)
- .to(PLN_SYMBOL)
+ .from(Symbol.USD)
+ .to(Symbol.PLN)
.toSell(USD_SELL)
.build());
assertThat(result.currencies())
- .matches(map -> Objects.equals(map.get(PLN_SYMBOL).amount(), PLN) && map.get(USD_SYMBOL).amount().signum() == 0, "PLN 20.10");
+ .matches(map -> Objects.equals(map.get(Symbol.PLN).amount(), PLN) && map.get(Symbol.USD).amount().signum() == 0, "PLN 20.10");
var expected = EntityCreator.userEntity().pln(PLN).usd(0).build();
expect(expected);
}
@@ -91,12 +94,12 @@ class CurrencyServiceTest extends RepositoryBasedTest {
var entity = EntityCreator.userEntity().pln(-1).usd(USD_SELL).build();
userRepository.save(entity);
var result = currencyService.exchange(EntityCreator.exchangeRequest()
- .from(USD_SYMBOL)
- .to(PLN_SYMBOL)
+ .from(Symbol.USD)
+ .to(Symbol.PLN)
.toBuy(PLN)
.build());
assertThat(result.currencies())
- .matches(map -> Objects.equals(map.get(PLN_SYMBOL).amount(), PLN) && map.get(USD_SYMBOL).amount().signum() == 0, "PLN 20.10");
+ .matches(map -> Objects.equals(map.get(Symbol.PLN).amount(), PLN) && map.get(Symbol.USD).amount().signum() == 0, "PLN 20.10");
var expected = EntityCreator.userEntity().pln(PLN).usd(0).build();
expect(expected);
}
@@ -107,8 +110,8 @@ class CurrencyServiceTest extends RepositoryBasedTest {
var entity = EntityCreator.userEntity().build();
userRepository.save(entity);
var request = EntityCreator.exchangeRequest()
- .from(USD_SYMBOL)
- .to(PLN_SYMBOL)
+ .from(Symbol.USD)
+ .to(Symbol.PLN)
.toBuy(PLN)
.build();
assertThatThrownBy(() -> currencyService.exchange(request))
@@ -121,14 +124,14 @@ class CurrencyServiceTest extends RepositoryBasedTest {
var initialValue = BigDecimal.valueOf(100);
var entity = EntityCreator.userEntity().pln(initialValue).build();
userRepository.save(entity);
- var result1 = currencyService.exchange(EntityCreator.exchangeRequest()
- .from(PLN_SYMBOL)
- .to(USD_SYMBOL)
+ currencyService.exchange(EntityCreator.exchangeRequest()
+ .from(Symbol.PLN)
+ .to(Symbol.USD)
.toBuy(USD_BUY)
.build());
- var result2 = currencyService.exchange(EntityCreator.exchangeRequest()
- .from(USD_SYMBOL)
- .to(PLN_SYMBOL)
+ currencyService.exchange(EntityCreator.exchangeRequest()
+ .from(Symbol.USD)
+ .to(Symbol.PLN)
.toSell(USD_BUY)
.build());
var resultOptional = userRepository.findById(entity.getPesel());
@@ -137,7 +140,7 @@ class CurrencyServiceTest extends RepositoryBasedTest {
var resultEntity = resultOptional.get();
assertThat(resultEntity.getCurrencies()
.stream()
- .filter(c -> c.getSymbol().equalsIgnoreCase("PLN"))
+ .filter(c -> c.getSymbol().equals(Symbol.PLN))
.findFirst()).isNotEmpty().get().matches(currencyEntity -> currencyEntity.getAmount().compareTo(initialValue) < 0);
}
@@ -147,8 +150,8 @@ class CurrencyServiceTest extends RepositoryBasedTest {
var entity = EntityCreator.userEntity().build();
userRepository.save(entity);
var request = EntityCreator.exchangeRequest()
- .from(PLN_SYMBOL)
- .to(USD_SYMBOL)
+ .from(Symbol.PLN)
+ .to(Symbol.USD)
.toBuy(PLN)
.build();
assertThatThrownBy(() -> currencyService.exchange(request))
@@ -161,8 +164,8 @@ class CurrencyServiceTest extends RepositoryBasedTest {
void invalidPeselTest(String pesel) {
var entity = EntityCreator.exchangeRequest()
.pesel(pesel)
- .from(PLN_SYMBOL)
- .to(USD_SYMBOL)
+ .from(Symbol.PLN)
+ .to(Symbol.USD)
.toSell(USD_SELL)
.build();
assertThatThrownBy(() -> currencyService.exchange(entity))
@@ -173,8 +176,8 @@ class CurrencyServiceTest extends RepositoryBasedTest {
@Test
void notExistingUserTest() {
var entity = EntityCreator.exchangeRequest()
- .from(PLN_SYMBOL)
- .to(USD_SYMBOL)
+ .from(Symbol.PLN)
+ .to(Symbol.USD)
.toSell(USD_SELL)
.build();
assertThatThrownBy(() -> currencyService.exchange(entity))
@@ -185,7 +188,7 @@ class CurrencyServiceTest extends RepositoryBasedTest {
@DisplayName("Empty 'from' value")
void emptyFromTest() {
var entity = EntityCreator.exchangeRequest()
- .to(USD_SYMBOL)
+ .to(Symbol.USD)
.toSell(USD_SELL)
.build();
assertThatThrownBy(() -> currencyService.exchange(entity))
@@ -197,7 +200,7 @@ class CurrencyServiceTest extends RepositoryBasedTest {
@DisplayName("Empty 'to' value")
void emptyToTest() {
var entity = EntityCreator.exchangeRequest()
- .from(PLN_SYMBOL)
+ .from(Symbol.PLN)
.toSell(USD_SELL)
.build();
assertThatThrownBy(() -> currencyService.exchange(entity))
diff --git a/src/test/java/eu/ztsh/wymiana/service/NbpServiceTest.java b/src/test/java/eu/ztsh/wymiana/service/NbpServiceTest.java
index 7424fbe..0ec2838 100644
--- a/src/test/java/eu/ztsh/wymiana/service/NbpServiceTest.java
+++ b/src/test/java/eu/ztsh/wymiana/service/NbpServiceTest.java
@@ -5,6 +5,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
import eu.ztsh.wymiana.EntityCreator;
import eu.ztsh.wymiana.WireMockExtension;
import eu.ztsh.wymiana.exception.NoDataException;
+import eu.ztsh.wymiana.model.Symbol;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.DisplayName;
@@ -79,7 +80,7 @@ class NbpServiceTest {
var url = "/api/exchangerates/rates/c/usd/%s/".formatted(date);
WireMockExtension.response(url, 200, new ObjectMapper().writeValueAsString(EntityCreator.rates(date)));
try {
- assertThat(nbpService.getSellRate(EntityCreator.Constants.USD_SYMBOL)).isEqualTo(EntityCreator.Constants.SELL_RATE);
+ assertThat(nbpService.getSellRate(Symbol.USD)).isEqualTo(EntityCreator.Constants.SELL_RATE);
} finally {
WireMockExtension.verifyGet(1, url);
}
@@ -92,9 +93,9 @@ class NbpServiceTest {
var url = "/api/exchangerates/rates/c/usd/%s/".formatted(date);
WireMockExtension.response(url, 200, new ObjectMapper().writeValueAsString(EntityCreator.rates(date)));
// save to cache
- assertThat(nbpService.getSellRate(EntityCreator.Constants.USD_SYMBOL)).isEqualTo(EntityCreator.Constants.SELL_RATE);
+ assertThat(nbpService.getSellRate(Symbol.USD)).isEqualTo(EntityCreator.Constants.SELL_RATE);
// get from cache
- assertThat(nbpService.getBuyRate(EntityCreator.Constants.USD_SYMBOL)).isEqualTo(EntityCreator.Constants.BUY_RATE);
+ assertThat(nbpService.getBuyRate(Symbol.USD)).isEqualTo(EntityCreator.Constants.BUY_RATE);
WireMockExtension.verifyGet(1, url);
}
@@ -102,9 +103,9 @@ class NbpServiceTest {
@Test
void getInvalidCurrencyTest() {
var date = dtf.format(updateClock(DayOfWeek.FRIDAY));
- var url = "/api/exchangerates/rates/c/usb/%s/".formatted(date);
+ var url = "/api/exchangerates/rates/c/usd/%s/".formatted(date);
WireMockExtension.response(url, 404, "404 NotFound - Not Found - Brak danych");
- assertThatThrownBy(() -> nbpService.getSellRate("usb")).isInstanceOf(NoDataException.class);
+ assertThatThrownBy(() -> nbpService.getSellRate(Symbol.USD)).isInstanceOf(NoDataException.class);
WireMockExtension.verifyGet(1, url);
}
diff --git a/src/test/java/eu/ztsh/wymiana/service/UserServiceTest.java b/src/test/java/eu/ztsh/wymiana/service/UserServiceTest.java
index fef02b9..33ea330 100644
--- a/src/test/java/eu/ztsh/wymiana/service/UserServiceTest.java
+++ b/src/test/java/eu/ztsh/wymiana/service/UserServiceTest.java
@@ -2,6 +2,7 @@ package eu.ztsh.wymiana.service;
import eu.ztsh.wymiana.EntityCreator;
import eu.ztsh.wymiana.RepositoryBasedTest;
+import eu.ztsh.wymiana.config.CurrencyProperties;
import eu.ztsh.wymiana.data.repository.UserRepository;
import eu.ztsh.wymiana.exception.UserAlreadyExistsException;
import eu.ztsh.wymiana.util.UserMapper;
@@ -21,9 +22,10 @@ class UserServiceTest extends RepositoryBasedTest {
private final UserService userService;
@Autowired
- public UserServiceTest(UserRepository userRepository, InstanceValidator instanceValidator) {
+ public UserServiceTest(UserRepository userRepository, InstanceValidator instanceValidator,
+ CurrencyProperties currencyProperties) {
super(userRepository);
- userService = new UserService(userRepository, instanceValidator);
+ userService = new UserService(userRepository, instanceValidator, currencyProperties);
}
@Test
@@ -42,8 +44,8 @@ class UserServiceTest extends RepositoryBasedTest {
var second = EntityCreator.userRequest().build();
userService.create(first);
assertThatThrownBy(() -> userService.create(second))
- .isInstanceOf(UserAlreadyExistsException.class)
- .hasMessage("User with PESEL %s already exists".formatted(EntityCreator.Constants.PESEL));
+ .isInstanceOf(UserAlreadyExistsException.class)
+ .hasMessage("User with PESEL %s already exists".formatted(EntityCreator.Constants.PESEL));
}
@Test
@@ -51,13 +53,13 @@ class UserServiceTest extends RepositoryBasedTest {
void createDuplicatedPeselTest() {
var first = EntityCreator.userRequest().build();
var second = EntityCreator.userRequest(30.30)
- .name("Jan")
- .surname("Kowalski")
- .build();
+ .name("Jan")
+ .surname("Kowalski")
+ .build();
userService.create(first);
assertThatThrownBy(() -> userService.create(second))
- .isInstanceOf(UserAlreadyExistsException.class)
- .hasMessage("User with PESEL %s already exists".formatted(EntityCreator.Constants.PESEL));
+ .isInstanceOf(UserAlreadyExistsException.class)
+ .hasMessage("User with PESEL %s already exists".formatted(EntityCreator.Constants.PESEL));
}
@Test
@@ -65,8 +67,8 @@ class UserServiceTest extends RepositoryBasedTest {
void youngUserTest() {
var request = EntityCreator.userRequest().pesel("").build();
assertThatThrownBy(() -> userService.create(request))
- .isInstanceOf(ValidationFailedException.class)
- .hasMessageContaining(Adult.MESSAGE);
+ .isInstanceOf(ValidationFailedException.class)
+ .hasMessageContaining(Adult.MESSAGE);
}
@Test
@@ -78,10 +80,10 @@ class UserServiceTest extends RepositoryBasedTest {
var userOptional = userService.get(EntityCreator.Constants.PESEL);
var expected = UserMapper.entityToPojo(entity);
assertThat(userOptional)
- .isNotEmpty()
- .get()
- .usingRecursiveComparison()
- .isEqualTo(expected);
+ .isNotEmpty()
+ .get()
+ .usingRecursiveComparison()
+ .isEqualTo(expected);
}
@Test
diff --git a/src/test/java/eu/ztsh/wymiana/util/UserMapperTest.java b/src/test/java/eu/ztsh/wymiana/util/UserMapperTest.java
index 11503aa..121c03d 100644
--- a/src/test/java/eu/ztsh/wymiana/util/UserMapperTest.java
+++ b/src/test/java/eu/ztsh/wymiana/util/UserMapperTest.java
@@ -1,12 +1,10 @@
package eu.ztsh.wymiana.util;
import eu.ztsh.wymiana.EntityCreator;
-import eu.ztsh.wymiana.model.Currency;
-import eu.ztsh.wymiana.model.User;
+import eu.ztsh.wymiana.model.Symbol;
+import eu.ztsh.wymiana.model.UserCreateRequestConfiguredWrapper;
import org.junit.jupiter.api.Test;
-import java.util.Map;
-
import static org.assertj.core.api.Assertions.assertThat;
class UserMapperTest {
@@ -31,7 +29,9 @@ class UserMapperTest {
@Test
void requestToEntityTest() {
- var request = EntityCreator.userRequest().build();
+ var request = UserCreateRequestConfiguredWrapper.wrap(EntityCreator.userRequest().build())
+ .withInitial(Symbol.PLN)
+ .build() ;
var expected = EntityCreator.userEntity().build();
assertThat(UserMapper.requestToEntity(request))
.usingRecursiveComparison()
diff --git a/src/test/java/eu/ztsh/wymiana/validation/ValidExchangeRequestValidatorTest.java b/src/test/java/eu/ztsh/wymiana/validation/ValidExchangeRequestValidatorTest.java
index e8ef550..4edd903 100644
--- a/src/test/java/eu/ztsh/wymiana/validation/ValidExchangeRequestValidatorTest.java
+++ b/src/test/java/eu/ztsh/wymiana/validation/ValidExchangeRequestValidatorTest.java
@@ -1,16 +1,15 @@
package eu.ztsh.wymiana.validation;
import eu.ztsh.wymiana.EntityCreator;
+import eu.ztsh.wymiana.model.Symbol;
import eu.ztsh.wymiana.web.model.CurrencyExchangeRequest;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
import java.math.BigDecimal;
-import static eu.ztsh.wymiana.EntityCreator.Constants.PLN_SYMBOL;
import static eu.ztsh.wymiana.EntityCreator.Constants.USD_BUY;
import static eu.ztsh.wymiana.EntityCreator.Constants.USD_SELL;
-import static eu.ztsh.wymiana.EntityCreator.Constants.USD_SYMBOL;
class ValidExchangeRequestValidatorTest extends ValidatorTest {
@@ -22,8 +21,8 @@ class ValidExchangeRequestValidatorTest extends ValidatorTest