Merge branch 'main' into user-input-dev

4 files changed, 211 insertions, 4 deletions

diff --git a/src/main/java/design/persistence/CSVMasterDatabase.java b/src/main/java/design/persistence/CSVMasterDatabase.java
new file mode 100644
index 0000000..fe89191
--- /dev/null
+++ b/src/main/java/design/persistence/CSVMasterDatabase.java
@@ -0,0 +1,83 @@
+package design.persistence;
+
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.databind.DeserializationContext;
+import com.fasterxml.jackson.databind.JsonDeserializer;
+import com.fasterxml.jackson.databind.MappingIterator;
+import com.fasterxml.jackson.databind.module.SimpleModule;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import com.fasterxml.jackson.dataformat.csv.CsvMapper;
+import com.fasterxml.jackson.dataformat.csv.CsvSchema;
+import design.model.Course;
+import design.model.Hole;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+
+public class CSVMasterDatabase implements MasterDatabase {
+
+    private final List<Course> cache;
+    private final CsvMapper mapper;
+    private final File file;
+
+    public CSVMasterDatabase(String filename) {
+        this.cache = new ArrayList<>();
+        this.mapper = new CsvMapper();
+        this.file = new File(filename);
+
+        SimpleModule module = new SimpleModule();
+        module.addDeserializer(Course.class, new CourseDeserializer());
+        mapper.registerModule(module);
+
+        try {
+            load();
+        } catch (IOException ex) {
+            throw new RuntimeException(ex);
+        }
+    }
+
+    public void load() throws IOException {
+        MappingIterator<Course> it = mapper
+                .readerFor(Course.class)
+                .with(CsvSchema.emptySchema().withHeader())
+                .readValues(file);
+
+        cache.addAll(it.readAll());
+    }
+
+    @Override
+    public Course[] getCourses() {
+        return cache.toArray(Course[]::new);
+    }
+
+    @Override
+    public Course getCourse(int id) {
+        return cache.get(id);
+    }
+
+    private static class CourseDeserializer extends JsonDeserializer<Course> {
+        int curID = 0;
+
+        @Override
+        public Course deserialize(JsonParser p, DeserializationContext ctxt) throws IOException {
+            ObjectNode node = p.getCodec().readTree(p);
+
+            int id = curID++;
+            String name = node.get("Course Name").asText();
+            double difficulty = node.get("Difficulty Rating").asDouble();
+            String location = node.get("Location").asText();
+            int holes = node.get("Number of Holes").asInt();
+            int totalPar = node.get("Total Par").asInt();
+
+            String[] parValues = node.get("Par Per Hole").asText().split(";");
+            List<Hole> holeList = new ArrayList<>();
+            for (int i = 0; i < parValues.length; i++) {
+                holeList.add(new Hole(i + 1, Integer.parseInt(parValues[i].trim())));
+            }
+
+            return new Course(id, name, (int) difficulty, location, holes, totalPar, holeList);
+        }
+    }
+}
diff --git a/src/main/java/design/persistence/JSONPersonalDatabase.java b/src/main/java/design/persistence/JSONPersonalDatabase.java
new file mode 100644
index 0000000..0efa362
--- /dev/null
+++ b/src/main/java/design/persistence/JSONPersonalDatabase.java
@@ -0,0 +1,118 @@
+package design.persistence;
+
+import com.fasterxml.jackson.annotation.JsonAutoDetect;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.PropertyAccessor;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.core.util.DefaultIndenter;
+import com.fasterxml.jackson.core.util.DefaultPrettyPrinter;
+import com.fasterxml.jackson.databind.*;
+import com.fasterxml.jackson.databind.module.SimpleModule;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+import com.fasterxml.jackson.module.paramnames.ParameterNamesModule;
+import design.model.Course;
+import design.model.Golfer;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+
+public class JSONPersonalDatabase implements PersonalDatabase {
+
+    private final Map<String, Golfer> cache;
+    private final ObjectMapper mapper;
+    private final File file;
+
+    public JSONPersonalDatabase(String filename) {
+        this.file = new File(filename);
+        this.cache = new HashMap<>();
+        this.mapper = new ObjectMapper();
+
+        SimpleModule module = new SimpleModule();
+        module.addDeserializer(Course.class, new CourseIdDeserializer());
+        module.addSerializer(Course.class, new CourseIdSerializer());
+        mapper.registerModule(module);
+        mapper.setVisibility(PropertyAccessor.FIELD, JsonAutoDetect.Visibility.ANY);
+        mapper.registerModule(new ParameterNamesModule(JsonCreator.Mode.PROPERTIES));
+        mapper.registerModule(new JavaTimeModule());
+
+        try {
+            load();
+        } catch (IOException ex) {
+            throw new RuntimeException(ex);
+        }
+    }
+
+    private void load() throws IOException {
+        Golfer[] data = mapper.readValue(file, Golfer[].class);
+        cache.clear();
+        for (Golfer i : data) {
+            cache.put(i.getUsername(), i);
+        }
+    }
+
+    private void save() throws IOException {
+        Golfer[] data = cache.values().toArray(Golfer[]::new);
+        mapper.writer(new CustomPrettyPrinter()).writeValue(file, data);
+    }
+
+    @Override
+    public Golfer[] getGolfers() {
+        return new Golfer[0];
+    }
+
+    @Override
+    public Golfer getGolfer(String username) {
+        return cache.get(username);
+    }
+
+    @Override
+    public void addGolfer(Golfer golfer) throws IOException {
+        cache.put(golfer.getUsername(), golfer);
+        save();
+    }
+
+    @Override
+    public void removeGolfer(Golfer golfer) throws IOException {
+        cache.remove(golfer.getUsername());
+        save();
+    }
+
+    @Override
+    public void updateGolfer(Golfer golfer) throws IOException {
+        cache.put(golfer.getUsername(), golfer);
+        save();
+    }
+
+    private static class CourseIdSerializer extends JsonSerializer<Course> {
+        @Override
+        public void serialize(Course course, JsonGenerator gen, SerializerProvider serializers) throws IOException {
+            gen.writeNumber(course.getId());
+        }
+    }
+
+    private static class CourseIdDeserializer extends JsonDeserializer<Course> {
+        MasterDatabase masterDB = MasterDatabase.INSTANCE;
+
+        @Override
+        public Course deserialize(JsonParser p, DeserializationContext context) throws IOException {
+            int id = p.getValueAsInt();
+            return masterDB.getCourse(id);
+        }
+    }
+
+    private static class CustomPrettyPrinter extends DefaultPrettyPrinter {
+        public CustomPrettyPrinter() {
+            super._arrayIndenter = new DefaultIndenter();
+            super._objectFieldValueSeparatorWithSpaces = _separators.getObjectFieldValueSeparator() + " ";
+            super._arrayEmptySeparator = "";
+        }
+
+        @Override
+        public CustomPrettyPrinter createInstance() {
+            return new CustomPrettyPrinter();
+        }
+    }
+}
diff --git a/src/main/java/design/persistence/MasterDatabase.java b/src/main/java/design/persistence/MasterDatabase.java
index 9dcfc1f..ddc0434 100644
--- a/src/main/java/design/persistence/MasterDatabase.java
+++ b/src/main/java/design/persistence/MasterDatabase.java
@@ -3,6 +3,8 @@ package design.persistence;
 import design.model.Course;
 
 public interface MasterDatabase {
+    MasterDatabase INSTANCE = new CSVMasterDatabase("data/golf_courses_1000.csv");
+
     Course[] getCourses();
-    Course getCourse(String name);
+    Course getCourse(int id);
 }
diff --git a/src/main/java/design/persistence/PersonalDatabase.java b/src/main/java/design/persistence/PersonalDatabase.java
index e1023cf..a045d59 100644
--- a/src/main/java/design/persistence/PersonalDatabase.java
+++ b/src/main/java/design/persistence/PersonalDatabase.java
@@ -2,10 +2,14 @@ package design.persistence;
 
 import design.model.Golfer;
 
+import java.io.IOException;
+
 public interface PersonalDatabase {
+    PersonalDatabase INSTANCE = new JSONPersonalDatabase("data/personaldb.json");
+
     Golfer[] getGolfers();
     Golfer getGolfer(String name);
-    void addGolfer(Golfer golfer);
-    void removeGolfer(Golfer golfer);
-    void updateGolfer(Golfer golfer);
+    void addGolfer(Golfer golfer) throws IOException;
+    void removeGolfer(Golfer golfer) throws IOException;
+    void updateGolfer(Golfer golfer) throws IOException;
 }