Move mapper/provider infra into v1 packages, add repository write methods

Correct Mapper's generic parameter order to <TModel, TDomain> and stub
addEvent/addUser on the Event/User repositories.

8 files changed, 82 insertions, 17 deletions

diff --git a/service/src/main/java/market/guess/service/infrastructure/mapper/Mapper.java b/service/src/main/java/market/guess/service/infrastructure/mapper/Mapper.java
index 44e192b..e3c77bf 100644
--- a/service/src/main/java/market/guess/service/infrastructure/mapper/Mapper.java
+++ b/service/src/main/java/market/guess/service/infrastructure/mapper/Mapper.java
@@ -1,5 +1,5 @@
 package market.guess.service.infrastructure.mapper;
 
-public interface Mapper<TDomain, TModel> {
+public interface Mapper<TModel, TDomain> {
   TDomain toDomain(TModel source);
 }
diff --git a/service/src/main/java/market/guess/service/infrastructure/mapper/EventMapperV1.java b/service/src/main/java/market/guess/service/infrastructure/mapper/v1/EventMapperV1.java
index 33c38e3..f61820a 100644
--- a/service/src/main/java/market/guess/service/infrastructure/mapper/EventMapperV1.java
+++ b/service/src/main/java/market/guess/service/infrastructure/mapper/v1/EventMapperV1.java
@@ -1,4 +1,4 @@
-package market.guess.service.infrastructure.mapper;
+package market.guess.service.infrastructure.mapper.v1;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -6,10 +6,11 @@ import market.guess.api.CommissionTiming;
 import market.guess.api.EventStatus;
 import market.guess.service.domain.Event;
 import market.guess.service.domain.Option;
+import market.guess.service.infrastructure.mapper.Mapper;
 import market.guess.service.mechanism.LmsrTradingMechanism;
 import market.guess.service.model.v1.GMEvent;
 
-public final class EventMapperV1 implements Mapper<Event, GMEvent> {
+public final class EventMapperV1 implements Mapper<GMEvent, Event> {
 
   @Override
   public Event toDomain(GMEvent source) {
diff --git a/service/src/main/java/market/guess/service/infrastructure/provider/XMLLoader.java b/service/src/main/java/market/guess/service/infrastructure/provider/XMLLoader.java
deleted file mode 100644
index 443cd87..0000000
--- a/service/src/main/java/market/guess/service/infrastructure/provider/XMLLoader.java
+++ /dev/null
@@ -1,13 +0,0 @@
-package market.guess.service.infrastructure.provider;
-
-import java.nio.file.Path;
-import market.guess.api.LoadResultDTO;
-
-public final class XMLLoader implements Loader {
-
-  @Override
-  public LoadResultDTO load(Path path) {
-    // TODO Auto-generated method stub
-    throw new UnsupportedOperationException("Unimplemented method 'load'");
-  }
-}
diff --git a/service/src/main/java/market/guess/service/infrastructure/provider/v1/XMLLoader.java b/service/src/main/java/market/guess/service/infrastructure/provider/v1/XMLLoader.java
new file mode 100644
index 0000000..9333350
--- /dev/null
+++ b/service/src/main/java/market/guess/service/infrastructure/provider/v1/XMLLoader.java
@@ -0,0 +1,60 @@
+package market.guess.service.infrastructure.provider.v1;
+
+import jakarta.xml.bind.JAXBContext;
+import jakarta.xml.bind.JAXBException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.util.List;
+import market.guess.api.LoadResultDTO;
+import market.guess.service.domain.BigDecimalOptions;
+import market.guess.service.domain.Event;
+import market.guess.service.infrastructure.mapper.Mapper;
+import market.guess.service.infrastructure.provider.Loader;
+import market.guess.service.model.v1.GMEvent;
+import market.guess.service.model.v1.GuessMarket;
+import market.guess.service.repository.EventRepository;
+import market.guess.service.repository.UserRepository;
+
+public final class XMLLoader implements Loader {
+  private final JAXBContext context;
+
+  private final EventRepository eventRepository;
+  private final UserRepository userRepository;
+  private final Mapper<GMEvent, Event> mapper;
+
+  public XMLLoader(
+      EventRepository eventRepository,
+      UserRepository userRepository,
+      Mapper<GMEvent, Event> mapper) {
+    super();
+    this.eventRepository = eventRepository;
+    this.userRepository = userRepository;
+    this.mapper = mapper;
+    try {
+      context = JAXBContext.newInstance(GuessMarket.class);
+    } catch (JAXBException e) {
+      throw new IllegalStateException();
+    }
+  }
+
+  @Override
+  public LoadResultDTO load(Path path) {
+
+    try (var stream = Files.newInputStream(path)) {
+
+      var doc = (GuessMarket) context.createUnmarshaller().unmarshal(stream);
+
+      for (var event : doc.getGMEvents().getGMEvent()) {
+        eventRepository.addEvent(mapper.toDomain(event));
+      }
+
+      userRepository.addUser("Tester", BigDecimalOptions.toMoney(9_999_999));
+
+      return LoadResultDTO.success("udk", 1);
+    } catch (Exception e) {
+
+    }
+
+    return LoadResultDTO.failure(path.toFile().getName(), List.of());
+  }
+}
diff --git a/service/src/main/java/market/guess/service/repository/EventRepository.java b/service/src/main/java/market/guess/service/repository/EventRepository.java
index f532793..94999cb 100644
--- a/service/src/main/java/market/guess/service/repository/EventRepository.java
+++ b/service/src/main/java/market/guess/service/repository/EventRepository.java
@@ -7,4 +7,6 @@ public interface EventRepository {
   Event getEvent(String id);
 
   List<Event> getAllEvents();
+
+  void addEvent(Event event);
 }
diff --git a/service/src/main/java/market/guess/service/repository/InMemoryEventRepository.java b/service/src/main/java/market/guess/service/repository/InMemoryEventRepository.java
index dad1055..81eba74 100644
--- a/service/src/main/java/market/guess/service/repository/InMemoryEventRepository.java
+++ b/service/src/main/java/market/guess/service/repository/InMemoryEventRepository.java
@@ -16,4 +16,10 @@ public final class InMemoryEventRepository implements EventRepository {
     // TODO Auto-generated method stub
     throw new UnsupportedOperationException("Unimplemented method 'getAllEvents'");
   }
+
+  @Override
+  public void addEvent(Event event) {
+    // TODO Auto-generated method stub
+    throw new UnsupportedOperationException("Unimplemented method 'addEvent'");
+  }
 }
diff --git a/service/src/main/java/market/guess/service/repository/InMemoryUserRepository.java b/service/src/main/java/market/guess/service/repository/InMemoryUserRepository.java
index e71c94c..951dea8 100644
--- a/service/src/main/java/market/guess/service/repository/InMemoryUserRepository.java
+++ b/service/src/main/java/market/guess/service/repository/InMemoryUserRepository.java
@@ -1,6 +1,6 @@
 package market.guess.service.repository;
 
-
+import java.math.BigDecimal;
 import market.guess.service.domain.User;
 
 public final class InMemoryUserRepository implements UserRepository {
@@ -10,4 +10,10 @@ public final class InMemoryUserRepository implements UserRepository {
     // TODO Auto-generated method stub
     throw new UnsupportedOperationException("Unimplemented method 'getUser'");
   }
+
+  @Override
+  public void addUser(String name, BigDecimal initialBalance) {
+    // TODO Auto-generated method stub
+    throw new UnsupportedOperationException("Unimplemented method 'addUser'");
+  }
 }
diff --git a/service/src/main/java/market/guess/service/repository/UserRepository.java b/service/src/main/java/market/guess/service/repository/UserRepository.java
index aafdc98..78d620d 100644
--- a/service/src/main/java/market/guess/service/repository/UserRepository.java
+++ b/service/src/main/java/market/guess/service/repository/UserRepository.java
@@ -1,8 +1,11 @@
 package market.guess.service.repository;
 
+import java.math.BigDecimal;
 import market.guess.service.domain.User;
 
 public interface UserRepository {
 
   User getUser(String name);
+
+  void addUser(String name, BigDecimal initialBalance);
 }