Enhance AddBone and AddCluster handlers with improved validation and error handling; implement new GetIDCluster route and handler; add SyncEngine for peer synchronization; introduce PeerTable in DatabaseService for managing peer URLs

Author: Sandro642

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

@@ -1,6 +1,7 @@
 package io.nodelink.server.app.cluster;
 
 import io.javalin.Javalin;
+import io.javalin.plugin.bundled.CorsPluginConfig;
 import io.nodelink.server.NodeLink;
 import io.nodelink.server.app.infra.RouteHandler;
 import org.slf4j.LoggerFactory;
@@ -26,6 +27,10 @@ public void startServer() {
                     app = Javalin.create(config -> {
                         config.showJavalinBanner = false;
                         config.router.contextPath = "/cluster";
+
+                        config.bundledPlugins.enableCors(cors -> {
+                            cors.addRule(CorsPluginConfig.CorsRule::anyHost);
+                        });
                     }).start(8080);
 
                     RouteHandler.registerAllRoutes(app, "io.nodelink.server.app.cluster.api.routes");

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

@@ -2,6 +2,7 @@
 
 import io.javalin.http.HandlerType;
 import io.javalin.http.Context;
+import io.nodelink.server.app.cluster.api.routes.v1.handler.AddClusterH;
 import io.nodelink.server.app.infra.RouteDefinition;
 
 public class AddCluster implements RouteDefinition {
@@ -16,6 +17,6 @@ public class AddCluster implements RouteDefinition {
 
     @Override
     public void handle(Context ctx) throws Exception {
-        new AddCluster().handle(ctx);
+        new AddClusterH().handle(ctx);
     }
 }

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

@@ -0,0 +1,17 @@
+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.infra.RouteDefinition;
+import io.nodelink.server.app.node.api.routes.v1.handler.GetIDH;
+
+public class GetIDCluster implements RouteDefinition {
+    @Override public HandlerType method() { return HandlerType.GET; }
+    @Override public String path() { return "/getId"; }
+    @Override public boolean enabled() { return true; }
+
+    @Override
+    public void handle(Context ctx) throws Exception {
+        new GetIDH().handle(ctx);
+    }
+}

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

@@ -1,67 +1,70 @@
 package io.nodelink.server.app.cluster.api.routes.v1.handler;
 
-import io.javalin.http.Context;
+import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.node.ObjectNode;
+import io.javalin.http.Context;
 import io.nodelink.server.app.data.BONE_LOCATION;
 import io.nodelink.server.app.data.CLUSTER_LOCATION;
 import io.nodelink.server.app.infra.ApiHandler;
 import io.nodelink.server.app.infra.DatabaseService;
 
-import java.util.Random;
-
 public class AddClusterH implements ApiHandler {
     private final ObjectMapper mapper = new ObjectMapper();
-    private final Random random = new Random();
 
     @Override
     public void handle(Context ctx) throws Exception {
-        ObjectNode requestBody = (ObjectNode) mapper.readTree(ctx.body());
-
-        // 1. Validation de la localisation du Cluster (ex: "NBG_DE_EU_CLUSTER")
-        String locParam = requestBody.get("location").asText();
-        CLUSTER_LOCATION loc;
         try {
-            loc = CLUSTER_LOCATION.valueOf(locParam);
-        } catch (IllegalArgumentException e) {
-            ctx.status(400).result("Erreur : CLUSTER_LOCATION invalide.");
-            return;
-        }
+            // 1. Lecture du JSON entrant
+            JsonNode requestBody = mapper.readTree(ctx.body());
 
-        // 2. Validation du Bone Parent (ex: "EUROPE_WEST")
-        String boneParam = requestBody.get("parentBone").asText();
-        BONE_LOCATION boneLoc;
-        try {
-            boneLoc = BONE_LOCATION.valueOf(boneParam);
-        } catch (IllegalArgumentException e) {
-            ctx.status(400).result("Erreur : BONE_LOCATION parent invalide.");
-            return;
-        }
+            // 2. Vérification des champs obligatoires
+            if (requestBody == null || !requestBody.has("id") || !requestBody.has("location") || !requestBody.has("parentBone")) {
+                ctx.status(400).result("Erreur : Les champs 'id', 'location' et 'parentBone' sont requis.");
+                return;
+            }
+
+            // 3. Extraction et formatage
+            String rawId = requestBody.get("id").asText();
+            String clusterId = "C" + rawId;
+
+            // Validation des enums (lance une IllegalArgumentException si invalide)
+            CLUSTER_LOCATION loc = CLUSTER_LOCATION.valueOf(requestBody.get("location").asText().toUpperCase());
+            BONE_LOCATION boneLoc = BONE_LOCATION.valueOf(requestBody.get("parentBone").asText().toUpperCase());
 
-        // 3. Génération ID "C" + random
-        String clusterId = "C" + random.nextInt(10000);
+            // 4. Préparation de l'objet final à stocker
+            String finalUrl = String.format("http://%s.%s.nodelinkapp.xyz", rawId, loc.getLocationCluster());
 
-        // 4. Construction de l'objet final
-        ObjectNode clusterData = mapper.createObjectNode();
-        clusterData.put("id", clusterId);
-        clusterData.put("type", "Cluster");
-        clusterData.put("name", loc.getNameCluster());
-        clusterData.put("url", loc.getLocationCluster());
+            ObjectNode clusterData = mapper.createObjectNode();
+            clusterData.put("id", clusterId);
+            clusterData.put("type", "Cluster");
+            clusterData.put("name", loc.getNameCluster());
+            clusterData.put("url", finalUrl);
+            clusterData.put("parentBone", boneLoc.getLocation());
 
-        // On récupère ici la propriété "locationBone" (ex: west.eu.bone)
-        clusterData.put("parentBone", boneLoc.getLocation());
+            clusterData.putArray("coords")
+                    .add(loc.getLatitude())
+                    .add(loc.getLongitude());
 
-        // Coordonnées auto depuis l'Enum Cluster
-        clusterData.putArray("coords")
-                .add(loc.getLatitude())
-                .add(loc.getLongitude());
+            String link = requestBody.has("link") ? requestBody.get("link").asText() : "NONE";
+            clusterData.put("link", link);
 
-        // Le lien technique (souvent l'ID du Bone ou d'un autre Cluster)
-        clusterData.put("link", requestBody.get("link").asText());
+            // 5. Appel du SAVE LOCAL (Simple SQLite)
+            // On utilise saveCluster qui est déjà défini dans ton DatabaseService
+            DatabaseService.saveCluster(clusterId, clusterData.toString());
 
-        // 5. Sauvegarde
-        DatabaseService.saveCluster(clusterId, clusterData.toString());
+            System.out.println("[INFO] Cluster " + clusterId + " sauvegardé localement.");
 
-        ctx.status(201).json(clusterData);
+            // 6. Réponse au client
+            ctx.status(201).json(clusterData);
+
+        } catch (IllegalArgumentException e) {
+            ctx.status(400).result("Erreur : Localisation invalide.");
+        } catch (Exception e) {
+            System.err.println("--- CRASH SERVEUR ---");
+            System.err.println("Cause : " + e.getMessage());
+            e.printStackTrace(); // <--- C'est cette ligne qui va te dire la ligne exacte du bug
+            ctx.status(500).result("Erreur : " + e.getMessage());
+        }
     }
 }

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

@@ -0,0 +1,22 @@
+package io.nodelink.server.app.cluster.api.routes.v1.handler;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import io.javalin.http.Context;
+import io.nodelink.server.app.infra.ApiHandler;
+
+import java.util.Random;
+
+public class GetIDClusterH implements ApiHandler {
+    private final Random random = new Random();
+
+    @Override
+    public void handle(Context ctx) throws Exception {
+        int idNumber = random.nextInt(10000);
+
+        ObjectNode response = new ObjectMapper().createObjectNode();
+        response.put("id", idNumber);
+
+        ctx.json(response);
+    }
+}