From e44ed0d9811b0c53b3288c54d15e2f68b8d650ed Mon Sep 17 00:00:00 2001 From: ulrich Date: Fri, 09 Apr 2021 14:09:45 +0000 Subject: [PATCH] Entitaetslisten vereinheitlicht --- src/de/uhilger/mediaz/api/StorageHandler.java | 182 +++++++++++++++++++++++++++----------------- 1 files changed, 111 insertions(+), 71 deletions(-) diff --git a/src/de/uhilger/mediaz/api/StorageHandler.java b/src/de/uhilger/mediaz/api/StorageHandler.java index 22d9de0..aea2ffc 100644 --- a/src/de/uhilger/mediaz/api/StorageHandler.java +++ b/src/de/uhilger/mediaz/api/StorageHandler.java @@ -19,60 +19,74 @@ import com.google.gson.Gson; 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; -import java.io.OutputStream; +import java.util.List; import java.util.logging.Level; import java.util.logging.Logger; /** - * HttpHandler fuer die Ablage von Entitaeten der Mediazentrale + * HttpHandler fuer die Verwaltung von Entitaeten der Mediazentrale * * @author Ulrich Hilger * @version 1, 5.4.2021 */ -public class StorageHandler implements HttpHandler { +public class StorageHandler extends AbstractHandler { private static final Logger logger = Logger.getLogger(StorageHandler.class.getName()); - /* - - HTTP GET: lies einen Ablageort und schreibe JSON - HTTP PUT: schreibe einen neuen Ablageort auf die Platte - HTTP POST: schreibe Aenderungen auf die Platte - HTTP DELETE: loesche den Ablageort + /* + Das REST-Muster fuer die Mediazentrale (Beispiel Ablageort): + + 1. HTTP GET Ablageort/[Name] - Liefere den Ablageort namens [Name] + 2. HTTP GET Ablageort/liste/ - Liefere eine Liste mit Namen aller Ablageorte + Es duerfen keine Elemente namens "liste" angelegt werden + 3. HTTP GET Ablageort/ - Liefere eine Liste aller Ablageort-Objekte als JSON + 4. HTTP PUT Ablageort/[Name] - Der Ablageort wird angelegt. Wenn er bereits existiert, + wird er geändert. (im Falle einer Aenderung des Namens + muss der alte Name im URL stehen und im Body die Aenderung) + 5. HTTP DELETE - loesche den Ablageort Beispiele: - HTTP GET an /mz/api/store/Ablageort/Katalog - liest den Ablageort namens "Katalog" + HTTP GET /mz/api/store/Ablageort/ + liefert alle Ablageort-Objekte - HTTP POST an /mz/api/store/Ablageort - schreibt den neuen Ablageort im Body der Anfrage (Neu) + HTTP GET /mz/api/store/Ablageort/liste/ + liefert eine Liste der Namen vorhandener Ablageorte - 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 GET /mz/api/store/Ablageort/[Name] + liest den Ablageort namens [Name] - HTTP DELETE an /mz/api/store/Ablageort/Katalog - löscht den Ablageort namens "Katalog" + HTTP PUT /mz/api/store/Ablageort/[Name] + wenn [Name] existiert: Aenderung, sonst neu anlegen + + HTTP DELETE /mz/api/store/Ablageort/[Name] + löscht den Ablageort namens [Name] */ - public static final String HTTP_GET = "GET"; - public static final String HTTP_PUT = "PUT"; - public static final String HTTP_POST = "POST"; - public static final String HTTP_DELETE = "DELETE"; + /** Name der HTTP Methode GET */ + //public static final String HTTP_GET = "GET"; + + /** Name der HTTP Methode PUT */ + //public static final String HTTP_PUT = "PUT"; + + /** Name der HTTP Methode POST */ + //public static final String HTTP_POST = "POST"; + + /** 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 { String method = e.getRequestMethod(); @@ -90,77 +104,103 @@ break; case HTTP_PUT: - response = "PUT noch bauen."; + response = put(e); break; case HTTP_POST: - response = neu(e); + response = "nicht unterstuertzt."; + code = 404; break; case HTTP_DELETE: - response = "DELETE noch bauen."; + boolean geloescht = loeschen(e); + if(geloescht) { + response = "geloescht"; + } else { + response = "nicht geloescht"; + } break; } - logger.info(response); + logger.fine(response); e.sendResponseHeaders(code, response.length()); OutputStream os = e.getResponseBody(); os.write(response.getBytes()); os.close(); } + */ - private String neu(HttpExchange e) throws IOException { + @Override + protected 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 - 1]; - String body = bodyLesen(e); - String filename = ""; - FileStorage fs = new FileStorage(App.getInitParameter(App.getRs(App.RB_AP_CONF))); - Gson gson = new Gson(); - logger.log(Level.INFO, "type: {0}", type); - Object o = gson.fromJson(body, fs.typeFromName(type).getType()); - if(o instanceof Entity) { - Object antwortObjekt = fs.write((Entity) o); - if(antwortObjekt instanceof File) { - File file = (File) antwortObjekt; - logger.log(Level.INFO, "Datei {0} geschrieben.", file.getAbsolutePath()); - filename = file.getName(); + 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); } - return type + FileHandler.STR_BLANK + filename; } - private void aendern() { - - } - - private void loeschen() { - - } - - private String lesen(HttpExchange e) { + private boolean loeschen(HttpExchange e) { 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]; FileStorage fs = new FileStorage(App.getInitParameter(App.getRs(App.RB_AP_CONF))); - //Entity entity = fs.read(type, elemName); - //return entity; - return fs.readJson(type, elemName); + return fs.delete(type, elemName); } - - private String bodyLesen(HttpExchange e) throws IOException { - InputStream is = e.getRequestBody(); - BufferedReader r = new BufferedReader(new InputStreamReader(is)); - StringBuilder sb = new StringBuilder(); - String line = r.readLine(); - while(line != null) { - sb.append(line); - line = r.readLine(); + private String lesen(HttpExchange e) { + String path = e.getRequestURI().toString(); + 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))) { + 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]; + String elemName = elems[elems.length - 1]; + return fs.readJson(type, elemName); } - r.close(); - String json = sb.toString(); - logger.log(Level.INFO, "json: {0}", json); - return json; + } + + @Override + public String get(HttpExchange e) { + return lesen(e); + } + + @Override + public String post(HttpExchange e) { + return "nicht unterstuetzt"; + } + + @Override + public boolean delete(HttpExchange e) { + return loeschen(e); } } -- Gitblit v1.9.3