From ec716e23ea8d827d4401ced8f34d533e30209d55 Mon Sep 17 00:00:00 2001
From: Kostya <mail@sartin.in>
Date: Fri, 14 Aug 2026 13:29:40 +0000
Subject: 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.
---
 .../infrastructure/mapper/EventMapperV1.java       | 52 -------------------
 .../service/infrastructure/mapper/Mapper.java      |  2 +-
 .../infrastructure/mapper/v1/EventMapperV1.java    | 53 +++++++++++++++++++
 .../service/infrastructure/provider/XMLLoader.java | 13 -----
 .../infrastructure/provider/v1/XMLLoader.java      | 60 ++++++++++++++++++++++
 .../guess/service/repository/EventRepository.java  |  2 +
 .../repository/InMemoryEventRepository.java        |  6 +++
 .../service/repository/InMemoryUserRepository.java |  8 ++-
 .../guess/service/repository/UserRepository.java   |  3 ++
 9 files changed, 132 insertions(+), 67 deletions(-)
 delete mode 100644 service/src/main/java/market/guess/service/infrastructure/mapper/EventMapperV1.java
 create mode 100644 service/src/main/java/market/guess/service/infrastructure/mapper/v1/EventMapperV1.java
 delete mode 100644 service/src/main/java/market/guess/service/infrastructure/provider/XMLLoader.java
 create mode 100644 service/src/main/java/market/guess/service/infrastructure/provider/v1/XMLLoader.java

(limited to 'service/src')

diff --git a/service/src/main/java/market/guess/service/infrastructure/mapper/EventMapperV1.java b/service/src/main/java/market/guess/service/infrastructure/mapper/EventMapperV1.java
deleted file mode 100644
index 33c38e3..0000000
--- a/service/src/main/java/market/guess/service/infrastructure/mapper/EventMapperV1.java
+++ /dev/null
@@ -1,52 +0,0 @@
-package market.guess.service.infrastructure.mapper;
-
-import java.util.ArrayList;
-import java.util.List;
-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.mechanism.LmsrTradingMechanism;
-import market.guess.service.model.v1.GMEvent;
-
-public final class EventMapperV1 implements Mapper<Event, GMEvent> {
-
-  @Override
-  public Event toDomain(GMEvent source) {
-    return new Event(
-        getEventKey(source),
-        source.getId(),
-        joinName(source.getName()),
-        source.getDescription(),
-        source.getComision().getValue(),
-        getTiming(source.getComision().getType()),
-        new LmsrTradingMechanism(source.getGMMethod().getGMLMSR().getB()),
-        EventStatus.ACTIVE,
-        getOptions(source),
-        "");
-  }
-
-  private static String getEventKey(GMEvent event) {
-    return String.valueOf(event.getId());
-  }
-
-  private static String joinName(List<String> tokens) {
-    return tokens == null ? "" : String.join(" ", tokens);
-  }
-
-  private static CommissionTiming getTiming(String type) throws IllegalArgumentException {
-    return switch (type) {
-      case "on-close" -> CommissionTiming.ON_CLOSE;
-      case "on-purchase" -> CommissionTiming.ON_PURCHASE;
-      default -> throw new IllegalArgumentException("Unknown comision type: " + type);
-    };
-  }
-
-  private static List<Option> getOptions(GMEvent x) {
-    var ret = new ArrayList<Option>(x.getGMOptions().getGMOption().size());
-    for (var i = 0; i < x.getGMOptions().getGMOption().size(); i++) {
-      ret.add(new Option(getEventKey(x) + ":" + i, x.getGMOptions().getGMOption().get(i)));
-    }
-    return ret;
-  }
-}
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/v1/EventMapperV1.java b/service/src/main/java/market/guess/service/infrastructure/mapper/v1/EventMapperV1.java
new file mode 100644
index 0000000..f61820a
--- /dev/null
+++ b/service/src/main/java/market/guess/service/infrastructure/mapper/v1/EventMapperV1.java
@@ -0,0 +1,53 @@
+package market.guess.service.infrastructure.mapper.v1;
+
+import java.util.ArrayList;
+import java.util.List;
+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<GMEvent, Event> {
+
+  @Override
+  public Event toDomain(GMEvent source) {
+    return new Event(
+        getEventKey(source),
+        source.getId(),
+        joinName(source.getName()),
+        source.getDescription(),
+        source.getComision().getValue(),
+        getTiming(source.getComision().getType()),
+        new LmsrTradingMechanism(source.getGMMethod().getGMLMSR().getB()),
+        EventStatus.ACTIVE,
+        getOptions(source),
+        "");
+  }
+
+  private static String getEventKey(GMEvent event) {
+    return String.valueOf(event.getId());
+  }
+
+  private static String joinName(List<String> tokens) {
+    return tokens == null ? "" : String.join(" ", tokens);
+  }
+
+  private static CommissionTiming getTiming(String type) throws IllegalArgumentException {
+    return switch (type) {
+      case "on-close" -> CommissionTiming.ON_CLOSE;
+      case "on-purchase" -> CommissionTiming.ON_PURCHASE;
+      default -> throw new IllegalArgumentException("Unknown comision type: " + type);
+    };
+  }
+
+  private static List<Option> getOptions(GMEvent x) {
+    var ret = new ArrayList<Option>(x.getGMOptions().getGMOption().size());
+    for (var i = 0; i < x.getGMOptions().getGMOption().size(); i++) {
+      ret.add(new Option(getEventKey(x) + ":" + i, x.getGMOptions().getGMOption().get(i)));
+    }
+    return ret;
+  }
+}
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);
 }
-- 
cgit v1.2.3