nouveau serveur ftp python de test + suppression dossiers

README.md

@@ -29,6 +29,10 @@ mvn clean package
 java -jar target/FlopBox.jar
 ```
 
+`python3 serveur_ftp.py` anonymous/anonymous ou user/password
+
+ou ftp.ubuntu.com
+
 ### Exécuter les tests
 
 Pour exécuter uniquement les tests il faut lancer la commande suivante :
@@ -61,6 +65,7 @@ Puis ouvrir le fichier `target/site/apidocs/index.html`
 
 ## Fonctionnalités
 
+`python3 serveur_ftp.py` anonymous/anonymous ou user/password
 
 **Note < 10 si le code fourni ne compile pas et ne peut pas être exécuté en suivant les instructions:**
 
@@ -118,4 +123,13 @@ fabio.vandewaeter.etu@b10p21:~/M1/SR2/TEMPO$ curl -X GET -H "Content-Type: appli
 
 **Note comprise entre 14 et 15 si—en plus—le proxy FlopBox, permet de créer, supprimer, renommer une ressource directement sur l'un des serveurs FTP gérés (fichier ou répertoire):**
 
+
+```shell
+> curl -X DELETE -H "Authorization: Bearer valid-token-1" -H "X-FTP-User: user" -H "X-FTP-Pass: password" http://localhost:8080/ftps/mon-ftp/dir
+```
+
+```shell
+> curl -X POST -H "Authorization: Bearer valid-token-1" -H "X-FTP-User: user" -H "X-FTP-Pass: password" -H "Content-Type: text/plain" -d "nouveau_chemin" http://localhost:8080/ftps/mon-ftp/test/rename
+```
+
 **Note comprise entre 15 et 16 si—en plus—le proxy FlopBox, permet de chercher des fichiers/répertoires stockés dans plusieurs serveurs FTP (le proxy retourne la liste des URLs pour chaque fichier trouvé):**

serveur_ftp.py

+from pyftpdlib.authorizers import DummyAuthorizer
+from pyftpdlib.handlers import FTPHandler
+from pyftpdlib.servers import FTPServer
+
+# Créer un authorizer
+authorizer = DummyAuthorizer()
+
+# Ajouter un utilisateur anonyme (lecture seule)
+authorizer.add_anonymous("dossier_serveur_ftp", perm="elr")
+
+# Ajouter un utilisateur personnalisé avec des permissions d'écriture
+authorizer.add_user("user", "password",
+                    "dossier_serveur_ftp", perm="elradfmw")
+
+# Configurer le handler
+handler = FTPHandler
+handler.authorizer = authorizer
+
+# Démarrer le serveur FTP
+server = FTPServer(("127.0.0.1", 2121), handler)
+server.serve_forever()

src/main/java/fil/sr2/flopbox/FTPResource.java

@@ -3,10 +3,8 @@ package fil.sr2.flopbox;
 import jakarta.ws.rs.*;
 import jakarta.ws.rs.core.*;
 
-import java.io.Closeable;
 import java.io.IOException;
 import java.io.InputStream;
-import java.io.OutputStream;
 import java.net.SocketException;
 import java.net.URI;
 import java.util.List;
@@ -120,8 +118,7 @@ public class FTPResource {
         System.out.println("addFTPServer()");
         boolean created = FTPServerRepository.getInstance().addServer(config);
         if (!created) {
-            return Response.status(Response.Status.CONFLICT)
-                    .entity("Alias déjà utilisé").build();
+            return Response.status(Response.Status.CONFLICT).entity("Alias déjà utilisé").build();
         }
         UriBuilder builder = uriInfo.getAbsolutePathBuilder();
         builder.path(config.getAlias());
@@ -145,34 +142,6 @@ public class FTPResource {
         return updated ? Response.ok(newConfig).build() : Response.status(Response.Status.NOT_FOUND).build();
     }
 
-    // Classe utilitaire pour gérer le flux et fermer les ressources
-    private static class InputStreamResource implements StreamingOutput {
-        private final InputStream inputStream;
-        private final FTPClient ftpClient;
-
-        public InputStreamResource(InputStream inputStream, FTPClient ftpClient) {
-            this.inputStream = inputStream;
-            this.ftpClient = ftpClient;
-        }
-
-        @Override
-        public void write(OutputStream output) throws IOException, WebApplicationException {
-            try (inputStream) {
-                byte[] buffer = new byte[4096];
-                int bytesRead;
-                while ((bytesRead = inputStream.read(buffer)) != -1) {
-                    output.write(buffer, 0, bytesRead);
-                }
-            } finally {
-                if (ftpClient.isConnected()) {
-                    ftpClient.completePendingCommand();
-                    ftpClient.logout();
-                    ftpClient.disconnect();
-                }
-            }
-        }
-    }
-
     @PUT
     @Path("/{alias}/{path: .+}")
     @Consumes(MediaType.APPLICATION_OCTET_STREAM)
@@ -233,22 +202,94 @@ public class FTPResource {
         }
     }
 
+    // delete the file or the content of a folder recursively
     @DELETE
     @Path("/{alias}/{path: .+}")
-    public Response deleteDirectory(
+    public Response deleteResource(
             @PathParam("alias") String alias,
             @PathParam("path") String path,
             @HeaderParam("X-FTP-User") String user,
-            @HeaderParam("X-FTP-Pass") String pass) throws SocketException, IOException {
+            @HeaderParam("X-FTP-Pass") String pass) {
 
-        System.out.println("deleteDirectory()");
         FTPClient ftp = new FTPClient();
         try {
             FTPServerConfig config = FTPServerRepository.getInstance().getServer(alias);
             ftp.connect(config.getHost(), config.getPort());
             ftp.login(user, pass);
-            return ftp.removeDirectory(path) ? Response.noContent().build()
-                    : Response.status(Response.Status.NOT_FOUND).build();
+
+            // Appel à la méthode récursive pour supprimer la ressource
+            boolean deleted = deleteRecursive(ftp, path);
+
+            return deleted
+                    ? Response.noContent().build()
+                    : Response.status(Response.Status.NOT_FOUND).entity("Ressource non trouvée").build();
+
+        } catch (IOException e) {
+            return Response.serverError().entity("Erreur FTP : " + e.getMessage()).build();
+        } finally {
+            try {
+                if (ftp.isConnected()) {
+                    ftp.logout();
+                    ftp.disconnect();
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    /**
+     * Méthode récursive pour supprimer un répertoire et son contenu.
+     */
+    private boolean deleteRecursive(FTPClient ftp, String path) throws IOException {
+        // Vérifie si le chemin est un répertoire
+        FTPFile[] files = ftp.listFiles(path);
+        if (files != null && files.length > 0) {
+            // Parcours des fichiers et sous-répertoires
+            for (FTPFile file : files) {
+                String fullPath = path + "/" + file.getName();
+                if (file.isDirectory()) {
+                    // Suppression récursive des sous-répertoires
+                    if (!deleteRecursive(ftp, fullPath)) {
+                        return false;
+                    }
+                } else {
+                    // Suppression des fichiers
+                    if (!ftp.deleteFile(fullPath)) {
+                        return false;
+                    }
+                }
+            }
+        }
+
+        // Suppression du répertoire lui-même
+        return ftp.removeDirectory(path);
+    }
+
+    @POST
+    @Path("/{alias}/{path: .+}/rename")
+    @Consumes(MediaType.TEXT_PLAIN)
+    public Response renameResource(
+            @PathParam("alias") String alias,
+            @PathParam("path") String oldPath,
+            @HeaderParam("X-FTP-User") String user,
+            @HeaderParam("X-FTP-Pass") String pass,
+            String newPath) {
+
+        System.out.println("renameResource()");
+        FTPClient ftp = new FTPClient();
+        try {
+            FTPServerConfig config = FTPServerRepository.getInstance().getServer(alias);
+            ftp.connect(config.getHost(), config.getPort());
+            ftp.login(user, pass);
+
+            System.out.print(oldPath + " " + newPath);
+            boolean success = ftp.rename(oldPath, newPath);
+            return success
+                    ? Response.ok().build()
+                    : Response.status(Response.Status.BAD_REQUEST).entity("Échec du renommage").build();
+        } catch (IOException e) {
+            return Response.serverError().entity("Erreur FTP : " + e.getMessage()).build();
         } finally {
             try {
                 if (ftp.isConnected()) {