diff --git a/Back-end/src/main/java/com/example/starter/MainVerticle.java b/Back-end/src/main/java/com/example/starter/MainVerticle.java
index 988c70e..90f9bee 100644
--- a/Back-end/src/main/java/com/example/starter/MainVerticle.java
+++ b/Back-end/src/main/java/com/example/starter/MainVerticle.java
@@ -44,6 +44,7 @@ public class MainVerticle extends AbstractVerticle {
setObjects.setUserHandler(setUser);
queryObjects.setUserHandler(setUser);
setWeatherData.setUserHandler(setUser);
+ QueryDeleteObject RequestDeleteObject = new QueryDeleteObject(databaseService);
// Déclaration des routes
@@ -66,6 +67,9 @@ public class MainVerticle extends AbstractVerticle {
router.get("/getCategories").handler(queryObjects::getCategories);
router.post("/addCategories").handler(setObjects::newCategorie);
router.post("/deleteCategories").handler(setObjects::deleteCategories);
+ router.post("/requestDeleteObject").handler(RequestDeleteObject::deleteObject);
+
+
// Routes d'authentification
router.post("/signup").handler(authHandler::handleSignup);
diff --git a/Back-end/src/main/java/com/example/starter/QueryDeleteObject.java b/Back-end/src/main/java/com/example/starter/QueryDeleteObject.java
new file mode 100644
index 0000000..a9e21d2
--- /dev/null
+++ b/Back-end/src/main/java/com/example/starter/QueryDeleteObject.java
@@ -0,0 +1,64 @@
+package com.example.starter;
+
+import io.vertx.core.json.JsonObject;
+import io.vertx.ext.web.RoutingContext;
+import io.vertx.sqlclient.Tuple;
+
+public class QueryDeleteObject {
+ private DatabaseService databaseService;
+
+ public QueryDeleteObject(DatabaseService dtbS) {
+ this.databaseService = dtbS;
+ }
+
+ public void deleteObject(RoutingContext context) {
+ JsonObject body = context.body().asJsonObject();
+
+ if (body == null) {
+ context.response().setStatusCode(400).end(new JsonObject().put("error", "Requête invalide").encode());
+ return;
+ }
+
+ // Lecture des paramètres
+ Integer objectId = body.getInteger("object_id");
+ Integer userId = body.getInteger("requested_by");
+
+ System.out.println("Body reçu : " + body.encode());
+ System.out.println("objectId = " + objectId + ", userId = " + userId);
+
+ if (objectId == null || userId == null) {
+ context.response().setStatusCode(400).end(new JsonObject().put("error", "Champs manquants").encode());
+ return;
+ }
+
+ // Vérification si l'objet existe
+ String checkQuery = "SELECT id FROM weather_objects WHERE id = ?";
+
+ databaseService.pool.preparedQuery(checkQuery).execute(Tuple.of(objectId), res -> {
+ if (res.failed()) {
+ res.cause().printStackTrace(); // Affiche l'erreur SQL s'il y en a une
+ context.response().setStatusCode(500).end(new JsonObject().put("error", "Erreur base de données").encode());
+ return;
+ }
+
+ if (res.result().rowCount() == 0) {
+ context.response().setStatusCode(404).end(new JsonObject().put("error", "Objet non trouvé").encode());
+ return;
+ }
+
+ // Insertion simple (pas de vérif doublon pour l’instant)
+ String checkDuplicate = "SELECT 1 FROM deletion_requests WHERE object_id = ? AND requested_by = ?";
+ String insertQuery = "INSERT INTO deletion_requests (object_id, requested_by) VALUES (?, ?)";
+
+ databaseService.pool.preparedQuery(insertQuery).execute(Tuple.of(objectId, userId), insertRes -> {
+ if (insertRes.succeeded()) {
+ context.response().setStatusCode(200).end(new JsonObject().put("message", "Demande envoyée").encode());
+ } else {
+ insertRes.cause().printStackTrace(); // Pour voir l'erreur en console
+ context.response().setStatusCode(500).end(new JsonObject().put("error", "Erreur insertion").encode());
+ }
+ });
+ });
+}
+
+}
diff --git a/Front-end/src/pages/Gestion/ObjectManagement.jsx b/Front-end/src/pages/Gestion/ObjectManagement.jsx
index 3daf55d..de0d447 100644
--- a/Front-end/src/pages/Gestion/ObjectManagement.jsx
+++ b/Front-end/src/pages/Gestion/ObjectManagement.jsx
@@ -1,5 +1,5 @@
import React from "react";
-import { Search, ArrowRight, RadioTower, Plus } from "lucide-react";
+import { Search, ArrowRight, RadioTower, Plus, Trash } from "lucide-react";
import { useEffect, useState } from "react";
import axios from "axios";
import { API_BASE_URL } from "../../config";
@@ -32,6 +32,41 @@ function ObjectManagement() {
setObjects(response.data);
});
}, []);
+
+ const handleRequestDeletion = async (objectId) => {
+ console.log("Demande de suppression pour l'objet", objectId);
+
+ try {
+ // Log des données envoyées
+ console.log("Envoi de la requête:", {
+ object_id: objectId,
+ requested_by: user.id,
+ });
+
+ const response = await axios.post(
+ `${API_BASE_URL}/requestDeleteObject`,
+ {
+ object_id: objectId,
+ requested_by: user.id,
+ },
+ {
+ headers: {
+ "Content-Type": "application/json", // Pas d'Authorization
+ },
+ }
+ );
+
+ console.log("Réponse du serveur:", response.data);
+ alert("Demande de suppression envoyée à l'administrateur.");
+ } catch (error) {
+ console.error("Erreur lors de la requête :", error.response?.data || error.message);
+ alert("Erreur lors de la demande.");
+ }
+ };
+
+
+
+
return (
@@ -141,12 +176,23 @@ function ObjectManagement() {
{object.name}
{object.description}
-
- Plus d'infos
-
+
+
+ Plus d'infos
+
+ {user?.role !== "user" && (
+
+ )}
+