From dfb7d34f88efbb3eb7632ae628ccfd4576824477 Mon Sep 17 00:00:00 2001 From: ulrich Date: Thu, 08 Apr 2021 10:37:10 +0000 Subject: [PATCH] REST-Konformitaet des StorageHandler verbessert --- src/de/uhilger/mediaz/api/StorageHandler.java | 115 +++++++++++++++++++++++++++++++++++++++++++++++---------- 1 files changed, 94 insertions(+), 21 deletions(-) diff --git a/src/de/uhilger/mediaz/api/StorageHandler.java b/src/de/uhilger/mediaz/api/StorageHandler.java index 5899bef..255380f 100644 --- a/src/de/uhilger/mediaz/api/StorageHandler.java +++ b/src/de/uhilger/mediaz/api/StorageHandler.java @@ -21,12 +21,12 @@ import com.sun.net.httpserver.HttpExchange; import com.sun.net.httpserver.HttpHandler; import de.uhilger.mediaz.App; +import static de.uhilger.mediaz.App.RB_EP_LISTE; import de.uhilger.mediaz.Server; import static de.uhilger.mediaz.Server.RB_SLASH; import de.uhilger.mediaz.store.FileStorage; import de.uhilger.mediaz.entity.Entity; import java.io.BufferedReader; -import java.io.File; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; @@ -47,31 +47,46 @@ /* + + PUT Die angegebene Ressource wird angelegt. Wenn die Ressource bereits + existiert, wird sie geändert. + Das REST-Muster sieht je Entitaet fuenf Faelle vor (Beispiel Ablageort): - 1. HTTP GET Ablageort/[Name]: Liefere den Ablageort als JSON - 2. HTTP GET Ablageort/: Liefere einer Liste von Ablageorten als JSON - 3. HTTP PUT: schreibe einen neuen Ablageort auf die Platte - 4. HTTP POST: schreibe Aenderungen auf die Platte - 5. HTTP DELETE: loesche den Ablageort + 1. HTTP GET Ablageort/[Name] - Liefere den Ablageort namens [Name] als JSON + 2. HTTP GET Ablageort/liste/ - Liefere eine Liste mit Namen aller Ablageorte + Es duerfen also keine Elemente namens "liste" angelegt werden + 3. HTTP GET Ablageort/ - Liefere eine Liste aller Ablageort-Objekte als JSON + 4. HTTP PUT Ablageort/[Name] - Die angegebene Ressource wird angelegt. Wenn die Ressource + bereits existiert, wird sie geändert. + 5. HTTP DELETE - loesche den Ablageort + + + + falsch: + 1. HTTP GET Ablageort/[Name] - Liefere den Ablageort namens [Name] als JSON + 2. HTTP GET Ablageort/liste/ - Liefere eine Liste mit Namen aller Ablageorte + 2. HTTP GET Ablageort/ - Liefere eine Liste aller Ablageort-Objekte als JSON + 3. HTTP PUT - schreibe einen neuen Ablageort auf die Platte + 4. HTTP POST - schreibe Aenderungen auf die Platte + 5. HTTP DELETE - loesche den Ablageort Beispiele: HTTP GET an /mz/api/store/Ablageort/ + liefert alle Ablageort-Objekte + + HTTP GET an /mz/api/store/Ablageort/liste/ liefert eine Liste der Namen vorhandener Ablageorte - HTTP GET an /mz/api/store/Ablageort/Katalog - liest den Ablageort namens "Katalog" + HTTP GET an /mz/api/store/Ablageort/[Name] + liest den Ablageort namens [Name] - HTTP POST an /mz/api/store/Ablageort - schreibt den neuen Ablageort im Body der Anfrage (Neu) + HTTP PUT an /mz/api/store/Ablageort/[Name] + wenn [Name] existiert: Aenderung, sonst neu anlegen - HTTP PUT an /mz/api/store/Ablageort - sucht den Ablageort mit dem Namen laut Body der Anfrage - und schreibt den Inhalt aus der Anfrage in die Datei (Aenderung) - - HTTP DELETE an /mz/api/store/Ablageort/Katalog - löscht den Ablageort namens "Katalog" + HTTP DELETE an /mz/api/store/Ablageort/[Name] + löscht den Ablageort namens [Name] */ @@ -86,6 +101,8 @@ /** Name der HTTP Methode DELETE */ public static final String HTTP_DELETE = "DELETE"; + + public static final String EP_LISTE = "liste/"; @Override public void handle(HttpExchange e) throws IOException { @@ -104,11 +121,12 @@ break; case HTTP_PUT: - response = aendern(e); + response = put(e); break; case HTTP_POST: - response = neu(e); + response = "nicht unterstuertzt."; + code = 404; break; case HTTP_DELETE: @@ -127,6 +145,51 @@ os.close(); } + private String put(HttpExchange e) throws IOException { + String path = e.getRequestURI().toString(); + String[] elems = path.split(App.getRs(Server.RB_SLASH)); + String type = elems[elems.length - 2]; + String elemName = elems[elems.length - 1]; // alter Name, wenn Aenderung + if(!elemName.equalsIgnoreCase(App.getRs(RB_EP_LISTE))) { + FileStorage fs = new FileStorage(App.getInitParameter(App.getRs(App.RB_AP_CONF))); + Gson gson = new Gson(); + logger.log(Level.FINE, "type: {0}, token: {1}", new Object[]{type, fs.typeFromName(type).getType().getTypeName()}); + Object o = gson.fromJson(bodyLesen(e), fs.typeFromName(type).getType()); + if(o instanceof Entity) { + Entity entity = (Entity) o; + if(fs.exists(type, elemName)) { + fs.delete(type, elemName); + fs.write(entity, true); + } else { + fs.write(entity, false); + } + return type + App.getRs(Server.RB_SLASH) + entity.getName(); + } else { + return "Ungueltiges Objekt im Body."; + } + } else { + return "Ungueltiger Elementname: " + App.getRs(RB_EP_LISTE); + } + } + + /* + private String schreiben(FileStorage fs, String typ, String name, String body, boolean overwrite) { + Gson gson = new Gson(); + logger.log(Level.FINE, "type: {0}, token: {1}", new Object[]{typ, fs.typeFromName(typ).getType().getTypeName()}); + Object o = gson.fromJson(body, fs.typeFromName(typ).getType()); + if(o instanceof Entity) { + Object antwortObjekt = fs.write((Entity) o, overwrite); + if(antwortObjekt instanceof File) { + File file = (File) antwortObjekt; + logger.log(Level.FINE, "Datei {0} geschrieben.", file.getAbsolutePath()); + String filename = file.getName(); + return typ + FileHandler.STR_BLANK + filename; + } + } + return typ + FileHandler.STR_BLANK + " etwas Seltsames ist passiert."; + } + */ + /* private String neu(HttpExchange e) throws IOException { return schreiben(e, false); } @@ -134,7 +197,9 @@ private String aendern(HttpExchange e) throws IOException { return schreiben(e, true); } + */ + /* private String schreiben(HttpExchange e, boolean overwrite) throws IOException { String path = e.getRequestURI().toString(); String[] elems = path.split(App.getRs(Server.RB_SLASH)); @@ -156,6 +221,7 @@ } return type + FileHandler.STR_BLANK + " Operation 'neu' fuer bereits existierende Entitaet."; } + */ /* private String aendern(HttpExchange e) throws IOException { @@ -177,9 +243,16 @@ String[] elems = path.split(App.getRs(Server.RB_SLASH)); FileStorage fs = new FileStorage(App.getInitParameter(App.getRs(App.RB_AP_CONF))); if(path.endsWith(App.getRs(RB_SLASH))) { - String type = elems[elems.length - 1]; - logger.fine(type); - List list = fs.list(type); + List list = null; + if(elems[elems.length - 1].equalsIgnoreCase(App.getRs(RB_EP_LISTE))) { + String type = elems[elems.length - 2]; + logger.fine(type); + list = fs.list(type); + } else { + String type = elems[elems.length - 1]; + logger.fine(type); + list = fs.listObjects(type); + } return jsonWithEnclosingType(list); } else { String type = elems[elems.length - 2]; -- Gitblit v1.9.3