Add API debugging class, route definition, and example handler; update build dependencies

Author: Sandro642

build.gradle

@@ -70,6 +70,12 @@ dependencies {
     implementation 'io.projectreactor:reactor-core:3.8.1'
     implementation 'io.projectreactor.netty:reactor-netty-core'
     implementation 'io.projectreactor.netty:reactor-netty-http'
+    implementation 'io.javalin:javalin:6.7.0'
+
+    implementation 'ch.qos.logback:logback-classic:1.4.14'
+    implementation 'com.fasterxml.jackson.core:jackson-databind:2.17.2'
+
+    implementation 'org.reflections:reflections:0.10.2'
 }
 
 test {

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

@@ -1,5 +1,6 @@
 package io.nodelink.server;
 
+import io.nodelink.server.app.node.api.NodeStarter;
 import io.nodelink.server.log.Logger;
 import io.nodelink.server.update.Updater;
 
@@ -52,5 +53,9 @@ public Updater getUpdater() {
         return Updater.getUpdaterSingleton();
     }
 
+    public NodeStarter getNodeStarter() {
+        return NodeStarter.getNodeStarterSingleton();
+    }
+
 }
 

src/main/java/io/nodelink/server/app/APIDebug.java

@@ -0,0 +1,18 @@
+package io.nodelink.server.app;
+
+import io.nodelink.server.NodeLink;
+
+public class APIDebug {
+
+    static void main(String[] args) {
+        System.out.println("API Debugging...");
+
+        NodeLink.getInstance().getNodeStarter().startServer();
+
+        try {
+            Thread.sleep(50000);
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+    }
+}

src/main/java/io/nodelink/server/app/config/ApiHandler.java

@@ -0,0 +1,8 @@
+package io.nodelink.server.app.config;
+
+import io.javalin.http.Context;
+
+@FunctionalInterface
+public interface ApiHandler {
+    void handle(Context ctx) throws Exception;
+}

src/main/java/io/nodelink/server/app/config/RouteDefinition.java

@@ -0,0 +1,11 @@
+package io.nodelink.server.app.config;
+
+import io.javalin.http.Context;
+import io.javalin.http.HandlerType;
+
+public interface RouteDefinition {
+    HandlerType method();    // GET, POST, etc.
+    String path();          // /example
+    boolean enabled();      // Activé ou non
+    void handle(Context ctx); // La logique (le handler)
+}

src/main/java/io/nodelink/server/app/config/RouteHandler.java

@@ -0,0 +1,38 @@
+package io.nodelink.server.app.config;
+
+import io.javalin.Javalin;
+import org.reflections.Reflections;
+import java.util.Set;
+
+public class RouteHandler {
+    public static void registerAllRoutes(Javalin app, String basePackage) {
+        Reflections reflections = new Reflections(basePackage);
+        Set<Class<? extends RouteDefinition>> routeClasses = reflections.getSubTypesOf(RouteDefinition.class);
+
+        for (Class<? extends RouteDefinition> routeClass : routeClasses) {
+            try {
+                RouteDefinition route = routeClass.getDeclaredConstructor().newInstance();
+
+                if (route.enabled()) {
+                    String pkg = routeClass.getPackageName();
+                    String[] parts = pkg.split("\\.");
+                    String version = "v1";
+
+                    for (String part : parts) {
+                        if (part.matches("v\\d+")) {
+                            version = part;
+                            break;
+                        }
+                    }
+
+                    String fullPath = "/api/" + version + route.path();
+
+                    app.addHttpHandler(route.method(), fullPath, route::handle);
+                }
+            } catch (Exception e) {
+                System.err.println("[ERROR] Could not register route: " + routeClass.getName());
+                e.printStackTrace();
+            }
+        }
+    }
+}

src/main/java/io/nodelink/server/app/node/api/NodeStarter.java

@@ -0,0 +1,46 @@
+package io.nodelink.server.app.node.api;
+
+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 NodeStarter {
+
+    private static final NodeStarter INSTANCE = new NodeStarter();
+    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 = "/bone";
+                    }).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 NodeStarter getNodeStarterSingleton() {
+        return INSTANCE;
+    }
+}

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

@@ -0,0 +1,23 @@
+package io.nodelink.server.app.node.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/node/api/routes/v1/handler/ExampleHandler.java

@@ -0,0 +1,13 @@
+package io.nodelink.server.app.node.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/command/CommandDispatcher.java

@@ -3,10 +3,6 @@
 import java.util.*;
 import java.util.function.Consumer;
 
-/**
- * Dispatcher simple : associe un Enum (handler key) à une action (Consumer<String[]>).
- * Lors de l'exécution, on trouve le noeud le plus profond et on invoque le handler enregistré pour son owner.
- */
 public class CommandDispatcher {
 
     private final CommandRegistry registry;