Ablageorte bearbeiten fertig

ulrich

2021-04-06 2597cdc3863be2c566c6bba8fe985eaff4a87df6

 src/de/uhilger/mediaz/api/StorageHandler.java

@@ -22,6 +22,7 @@
import com.sun.net.httpserver.HttpHandler;
import de.uhilger.mediaz.App;
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;
@@ -30,11 +31,12 @@
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
@@ -45,13 +47,18 @@

  
  /*
  
    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 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
  
    Beispiele:
  
    HTTP GET an /mz/api/store/Ablageort/
    liefert eine Liste der Namen vorhandener Ablageorte
  
    HTTP GET an /mz/api/store/Ablageort/Katalog
    liest den Ablageort namens "Katalog"
@@ -68,9 +75,16 @@
  
  */
  
  /** 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";

  @Override
@@ -90,7 +104,7 @@
        break;
        
      case HTTP_PUT:
        response = "PUT noch bauen.";
        response = aendern(e);
        break;
        
      case HTTP_POST:
@@ -98,7 +112,12 @@
        break;
        
      case HTTP_DELETE:
        response = "DELETE noch bauen.";
        boolean geloescht = loeschen(e);
        if(geloescht) {
          response = "geloescht";
        } else {
          response = "nicht geloescht";
        }
        break;
    }
    logger.info(response);
@@ -109,6 +128,14 @@
  }
  
  private String neu(HttpExchange e) throws IOException {
    return schreiben(e, false);
  }
  
  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));
    String type = elems[elems.length - 1];
@@ -119,35 +146,58 @@
    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);
      Object antwortObjekt = fs.write((Entity) o, overwrite);
      if(antwortObjekt instanceof File) {
        File file = (File) antwortObjekt;
        logger.log(Level.INFO, "Datei {0} geschrieben.", file.getAbsolutePath());
        filename = file.getName();
        return type + FileHandler.STR_BLANK + filename;
      }
    }
    return type + FileHandler.STR_BLANK + filename;
    return type + FileHandler.STR_BLANK + " Operation 'neu' fuer bereits existierende Entitaet.";
  }
  
  private void aendern() {
    
  /*
  private String aendern(HttpExchange e) throws IOException {
    return neu(e); // einstweilen wird einfach ueberschrieben
  }
  */
  
  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 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))) {
      String type = elems[elems.length - 1];
      logger.info(type);
      List list = fs.list(type);
      return jsonWithEnclosingType(list);
    } else {
      String type = elems[elems.length - 2];
      String elemName = elems[elems.length - 1];
      return fs.readJson(type, elemName);
    }
  }
  
  private String jsonWithEnclosingType(Object o) {
    StringBuilder sb = new StringBuilder();
    sb.append("{\"");
    sb.append(o.getClass().getSimpleName());
    sb.append("\": ");
    Gson gson = new Gson();
    sb.append(gson.toJson(o));
    sb.append("}");
    return sb.toString();
  }
  
  private String bodyLesen(HttpExchange e) throws IOException {
    InputStream is = e.getRequestBody();