Merge pull request #8 from ifydev/feature/backends

Feature/backends

Author: Innectic

API/src/main/java/me/ifydev/dimensify/api/DimensifyAPI.java

@@ -25,7 +25,11 @@
 package me.ifydev.dimensify.api;
 
 import lombok.Getter;
+import me.ifydev.dimensify.api.backend.AbstractDataHandler;
+import me.ifydev.dimensify.api.backend.BackendType;
+import me.ifydev.dimensify.api.backend.ConnectionInformation;
 
+import java.lang.reflect.InvocationTargetException;
 import java.util.Optional;
 
 /**
@@ -36,9 +40,31 @@
  */
 public class DimensifyAPI {
 
-    @Getter private Optional<DimensifyAPI> api;
+    private static Optional<DimensifyAPI> api;
 
-    public void intialize() {
+    @Getter private Optional<AbstractDataHandler> databaseHandler;
+
+    public void initialize(Class<? extends AbstractDataHandler> handler, BackendType backendType, Optional<ConnectionInformation> connectionInformation) throws Exception {
         api = Optional.of(this);
+
+        try {
+            // If we don't have a database handler, then we default to the flat-file handler.
+            Class<? extends AbstractDataHandler> clazz = backendType.getHandler().orElse(handler);
+            databaseHandler = Optional.of(clazz.getConstructor(ConnectionInformation.class).newInstance(connectionInformation.orElse(null)));
+        } catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
+            e.printStackTrace();
+        }
+        if (!databaseHandler.isPresent()) throw new Exception("No data handler present.");
+
+        databaseHandler.ifPresent(h -> {
+            h.initialize();
+            h.reload();
+            if (h.connect()) System.out.println("Connected to database!");
+            else System.out.println("Unable to connect to database!");
+        });
+    }
+
+    public static Optional<DimensifyAPI> get() {
+        return api;
     }
 }

API/src/main/java/me/ifydev/dimensify/api/DimensifyConstants.java

@@ -38,17 +38,17 @@ public class DimensifyConstants {
 
     // Not enough arguments responses
     private static final String NOT_ENOUGH_ARGUMENTS_BASE = DIMENSIFY_PREFIX + "&c&lNot enough arguments: ";
-    public static final String NOT_ENOUGH_ARGUMENTS_CREATE_WORLD = NOT_ENOUGH_ARGUMENTS_BASE + "/dimensify create [dimension_type] [world_name]";
-    public static final String NOT_ENOUGH_ARGUMENTS_SEND_PLAYER = NOT_ENOUGH_ARGUMENTS_BASE + "/dimensify send [player] [world_name]";
-    public static final String NOT_ENOUGH_ARGUMENTS_GO = NOT_ENOUGH_ARGUMENTS_BASE + "/dimensify go [world_name]";
-    public static final String NOT_ENOUGH_ARGUMENTS_DELETE = NOT_ENOUGH_ARGUMENTS_BASE + "/dimensify delete [world_name]";
+    public static final String NOT_ENOUGH_ARGUMENTS_CREATE_WORLD = NOT_ENOUGH_ARGUMENTS_BASE + "/dimensify create <dimension_type> <world_name>";
+    public static final String NOT_ENOUGH_ARGUMENTS_SEND_PLAYER = NOT_ENOUGH_ARGUMENTS_BASE + "/dimensify send <player> <dimension>";
+    public static final String NOT_ENOUGH_ARGUMENTS_GO = NOT_ENOUGH_ARGUMENTS_BASE + "/dimensify go <dimension>";
+    public static final String NOT_ENOUGH_ARGUMENTS_DELETE = NOT_ENOUGH_ARGUMENTS_BASE + "/dimensify delete <dimension>";
     public static final String NOT_ENOUGH_ARGUMENTS_PORTAL = NOT_ENOUGH_ARGUMENTS_BASE + "/dimensify <create|delete|link> [args...]";
-    public static final String NOT_ENOUGH_ARGUMENTS_PORTAL_LINK = NOT_ENOUGH_ARGUMENTS_BASE + "/dimensify link <source_portal> <destination_portal>";
+    public static final String NOT_ENOUGH_ARGUMENTS_PORTAL_LINK = NOT_ENOUGH_ARGUMENTS_BASE + "/dimensify link <source_portal> <destination_dimension>";
     public static final String NOT_ENOUGH_ARGUMENTS_PORTAL_CREATE = NOT_ENOUGH_ARGUMENTS_BASE + "/dimensify portal create <name>";
     public static final String NOT_ENOUGH_ARGUMENTS_PORTAL_DELETE = NOT_ENOUGH_ARGUMENTS_BASE + "/dimensify portal delete <name>";
 
     // General errors
-    public static final String PLUGIN_NOT_PRESENT = DIMENSIFY_PREFIX + "&c&lUnable to continue: Plugin not present?!";
+    public static final String DATABASE_HANDLER_NOT_PRESENT = DIMENSIFY_PREFIX + "&c&lUnable to continue: Database handler not present?!";
     public static final String WORLD_EXISTS = DIMENSIFY_PREFIX + "&c&lWorld '<WORLD>' already exists!";
     public static final String INVALID_WORLD = DIMENSIFY_PREFIX + "&c&lWorld '<WORLD>' doesn't exist.";
     public static final String INVALID_DIMENSION_TYPE = DIMENSIFY_PREFIX + "&c&lDimension type '<TYPE>' is invalid.";
@@ -66,12 +66,13 @@ public class DimensifyConstants {
     // General success
     public static final String CREATING_WORLD = DIMENSIFY_PREFIX + "World '<WORLD>' is being created...";
     public static final String WORLD_CREATED = DIMENSIFY_PREFIX + "World '<WORLD>' created!";
-    public static final String WHOOSH = DIMENSIFY_PREFIX + "Whoosh!";
+    public static final String WHOOSH = "&a&lWhoosh!";
     public static final String WORLD_DELETED = DIMENSIFY_PREFIX + "World '<WORLD>' has been deleted!";
     public static final String YOU_HAVE_BEEN_SENT = DIMENSIFY_PREFIX + "You have been sent to <WORLD>!";
     public static final String PLAYER_HAS_BEEN_SENT = DIMENSIFY_PREFIX + "<PLAYER> has been sent to <WORLD>!";
     public static final String PORTALS_LINKED = DIMENSIFY_PREFIX + "Portals have been linked!";
     public static final String PORTAL_CREATED = DIMENSIFY_PREFIX + "Portal '<PORTAL>' created!";
+    public static final String PORTAL_DELETED = DIMENSIFY_PREFIX + "Portal '<PORTAL>' has been deleted!";
 
     // Help response
     // TODO: This should automatically paginate.
@@ -85,7 +86,7 @@ public class DimensifyConstants {
                     "&a&l/dimensify delete <world_name>",
                     "&a&l/dimensify default [world_name]",
                     "&a&l/dimensify list",
-                    "&a&l/dimensify link <source_portal> <destination_portal>"
+                    "&a&l/dimensify link <source_portal> <destination_dimension>"
             )
     );
 }

API/src/main/java/me/ifydev/dimensify/api/backend/AbstractDataHandler.java

@@ -0,0 +1,57 @@
+package me.ifydev.dimensify.api.backend;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+import me.ifydev.dimensify.api.dimensions.Dimension;
+import me.ifydev.dimensify.api.portal.PortalMeta;
+
+import java.util.*;
+
+/**
+ * @author Innectic
+ * @since 06/26/2018
+ */
+@RequiredArgsConstructor
+public abstract class AbstractDataHandler {
+
+    protected List<Dimension> dimensions = new ArrayList<>();
+    protected List<PortalMeta> portals = new ArrayList<>();
+    protected Map<String, String> destinations = new HashMap<>();
+    @Getter protected final ConnectionInformation connectionInformation;
+
+    /**
+     * Setup anything that's needed before we can connect.
+     */
+    public abstract void initialize();
+
+    /**
+     * Connect to whatever kind of handler we're going for.
+     *
+     * @return if it was successful.
+     */
+    public abstract boolean connect();
+
+    /**
+     * Force all data within the cache to be reloaded.
+     */
+    public abstract void reload();
+
+    /**
+     * Drop all values from the cache.
+     */
+    public abstract void drop();
+
+    public abstract boolean createPortal(PortalMeta meta);
+    public abstract boolean removePortal(String name);
+    public abstract List<PortalMeta> getPortals();
+
+    public abstract void setPortalDestination(String portal, String destination);
+
+    public abstract boolean createDimension(Dimension dimension);
+    public abstract boolean removeDimension(String name);
+    public abstract List<Dimension> getDimensions();
+
+    public abstract Optional<Dimension> getDimension(String name);
+    public abstract Optional<PortalMeta> getPortal(String name);
+    public abstract Optional<String> getDestinationForPortal(String portalName);
+}

API/src/main/java/me/ifydev/dimensify/api/backend/BackendType.java

@@ -0,0 +1,27 @@
+package me.ifydev.dimensify.api.backend;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import me.ifydev.dimensify.api.backend.impl.SQLHandler;
+
+import java.util.Arrays;
+import java.util.Optional;
+
+/**
+ * @author Innectic
+ * @since 06/26/2018
+ */
+@AllArgsConstructor
+@Getter
+public enum BackendType {
+    FLAT_FILE(Optional.empty(), "FlatFile"),
+    MYSQL(Optional.of(SQLHandler.class), "MySQL"),
+    SQLITE(Optional.of(SQLHandler.class), "SQLite");
+
+    private Optional<Class<? extends AbstractDataHandler>> handler;
+    private String displayName;
+
+    public static Optional<BackendType> getHandlerForType(String type) {
+        return Arrays.stream(values()).filter(handler -> handler.getDisplayName().equalsIgnoreCase(type)).findFirst();
+    }
+}

API/src/main/java/me/ifydev/dimensify/api/backend/ConnectionError.java

@@ -0,0 +1,17 @@
+package me.ifydev.dimensify.api.backend;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * @author Innectic
+ * @since 06/26/2018
+ */
+@AllArgsConstructor
+public enum ConnectionError {
+
+    REJECTED("Connection to the database server rejected."),
+    DATABASE_EXPECTION("Exception in the database handler.");
+
+    @Getter private String display;
+}

API/src/main/java/me/ifydev/dimensify/api/backend/ConnectionInformation.java

@@ -0,0 +1,22 @@
+package me.ifydev.dimensify.api.backend;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+import java.util.Map;
+
+/**
+ * @author Innectic
+ * @since 06/26/2018
+ */
+@AllArgsConstructor
+@Getter
+public class ConnectionInformation {
+    // TODO: This was copy-pasted from Permissify. This should be generified into some-kind of a core plugin.
+    private String url;
+    private String database;
+    private int port;
+    private String username;
+    private String password;
+    private Map<String, Object> meta;
+}