Add BONE_LOCATION and CLUSTER_LOCATION enums; implement location handling in CommandLogics

Author: Sandro642

src/main/java/io/nodelink/server/NodeLink.java

@@ -1,8 +1,9 @@
 package io.nodelink.server;
 
-import io.nodelink.server.app.node.api.NodeStarter;
+import io.nodelink.server.app.node.NodeStarter;
 import io.nodelink.server.log.Logger;
 import io.nodelink.server.update.Updater;
+import io.nodelink.server.utils.StoreData;
 
 import java.io.File;
 
@@ -57,5 +58,9 @@ public NodeStarter getNodeStarter() {
         return NodeStarter.getNodeStarterSingleton();
     }
 
+    public StoreData getStoreData() {
+        return StoreData.getStoreDataSingleton();
+    }
+
 }
 

src/main/java/io/nodelink/server/NodeLinkHelper.java

@@ -174,6 +174,12 @@ private void drawStaticInterface(Terminal terminal) {
         terminal.writer().println(GREEN + "  ● Status: " + RESET + YELLOW + PRODUCT + RESET);
         terminal.writer().println(GREEN + "  ● Version: " + RESET + Version.VERSION);
 
+//        if ((boolean) NodeLink.getInstance().getStoreData().get(NodeLink.getInstance().getStoreData().WHICH_TYPE)) {
+//            terminal.writer().println(GREEN + "  ● Region: " + RESET + "Cluster");
+//        } else {
+//            terminal.writer().println(GREEN + "  ● LOCATION: " + RESET + "Bone");
+//        }
+
         int currentLine = logoHeight + 4;
         for (int i = currentLine; i < RESERVED_ROWS - 1; i++) {
             terminal.writer().println("");

src/main/java/io/nodelink/server/app/cluster/ClusterStarter.java

@@ -0,0 +1,46 @@
+package io.nodelink.server.app.cluster;
+
+import io.javalin.Javalin;
+import io.nodelink.server.NodeLink;
+import io.nodelink.server.app.config.RouteHandler;
+import org.slf4j.LoggerFactory;
+import ch.qos.logback.classic.Level;
+import ch.qos.logback.classic.LoggerContext;
+import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Schedulers;
+
+public class ClusterStarter {
+
+    private static final ClusterStarter INSTANCE = new ClusterStarter();
+    private Javalin app;
+
+    static {
+        LoggerContext loggerContext = (LoggerContext) LoggerFactory.getILoggerFactory();
+        loggerContext.getLogger("io.javalin").setLevel(Level.OFF);
+        loggerContext.getLogger("org.eclipse.jetty").setLevel(Level.OFF);
+        loggerContext.getLogger("reactor").setLevel(Level.OFF);
+    }
+
+    public void startServer() {
+        Mono.fromRunnable(() -> {
+                    app = Javalin.create(config -> {
+                        config.showJavalinBanner = false;
+                        config.router.contextPath = "/cluster";
+                    }).start(8080);
+
+                    RouteHandler.registerAllRoutes(app, "io.nodelink.server.app.node.api.routes");
+
+                    NodeLink.getInstance().getLogger().SUCCESS("Node API Server started");
+                })
+                .subscribeOn(Schedulers.boundedElastic())
+                .subscribe();
+    }
+
+    public Javalin getApp() {
+        return app;
+    }
+
+    public static ClusterStarter getNodeStarterSingleton() {
+        return INSTANCE;
+    }
+}

src/main/java/io/nodelink/server/app/cluster/api/routes/v1/definition/ExampleDef.java

@@ -0,0 +1,23 @@
+package io.nodelink.server.app.cluster.api.routes.v1.definition;
+
+import io.javalin.http.Context;
+import io.javalin.http.HandlerType;
+import io.nodelink.server.app.config.RouteDefinition;
+import io.nodelink.server.app.node.api.routes.v1.handler.ExampleHandler;
+
+public class ExampleDef implements RouteDefinition {
+
+    @Override
+    public HandlerType method() { return HandlerType.GET; }
+
+    @Override
+    public String path() { return "/status"; }
+
+    @Override
+    public boolean enabled() { return true; }
+
+    @Override
+    public void handle(Context ctx) {
+        new ExampleHandler().handle(ctx);
+    }
+}

src/main/java/io/nodelink/server/app/cluster/api/routes/v1/handler/ExampleHandler.java

@@ -0,0 +1,13 @@
+package io.nodelink.server.app.cluster.api.routes.v1.handler;
+
+import io.javalin.http.Context;
+import io.nodelink.server.app.config.ApiHandler;
+
+import java.util.Map;
+
+public class ExampleHandler implements ApiHandler {
+    @Override
+    public void handle(Context ctx) {
+        ctx.json(Map.of("status", "Operational..."));
+    }
+}

src/main/java/io/nodelink/server/app/cluster/enums/DE_EU.java

@@ -0,0 +1,50 @@
+package io.nodelink.server.app.data;
+
+public enum BONE_LOCATION {
+
+    ///
+
+    EUROPE_WEST("west.eu.bone"),
+    EUROPE_EAST("east.eu.bone"),
+    EUROPE_NORTH("north.eu.bone"),
+    EUROPE_SOUTH("south.eu.bone"),
+
+    ///
+
+    NORTH_AMERICA_WEST("west.na.bone"),
+    NORTH_AMERICA_EAST("east.na.bone"),
+    NORTH_AMERICA_NORTH("north.na.bone"),
+    NORTH_AMERICA_SOUTH("south.na.bone"),
+
+    LATAM_AMERICA("latam.la.bone"),
+
+    ///
+
+    ASIA_EAST("east.asia.bone"),
+    ASIA_SOUTH("south.asia.bone"),
+    ASIA_NORTH("north.asia.bone"),
+    ASIA_WEST("west.asia.bone"),
+
+    OCEANIA("oceania.bone"),
+
+    ///
+
+    MIDDLE_EAST("me.bone"),
+    AFRICA_NORTH("north.africa.bone"),
+    AFRICA_SOUTH("south.africa.bone"),
+
+    ///
+
+    ;
+
+    private final String locationBone;
+
+    BONE_LOCATION(String locationBone) {
+        this.locationBone = locationBone;
+    }
+
+    public String getLocation() {
+        return this.locationBone;
+    }
+
+}

src/main/java/io/nodelink/server/app/data/BONE_LOCATION.java

@@ -0,0 +1,20 @@
+package io.nodelink.server.app.data;
+
+public enum CLUSTER_LOCATION {
+
+    NBG_DE_EU_CLUSTER("nbg.de.eu.cluster"),
+    ;
+
+    ///
+
+    private final String locationCluster;
+
+    CLUSTER_LOCATION(String locationCluster) {
+        this.locationCluster = locationCluster;
+    }
+
+    public String getLocation() {
+        return this.locationCluster;
+    }
+
+}

src/main/java/io/nodelink/server/app/data/CLUSTER_LOCATION.java

@@ -1,4 +1,4 @@
-package io.nodelink.server.app.node.api;
+package io.nodelink.server.app.node;
 
 import io.javalin.Javalin;
 import io.nodelink.server.NodeLink;