Persoenliche Mediazentrale
ulrich
2021-04-08 8d7d357497e80b87f1d3be2357cb9cb2e853e582
src/de/uhilger/mediaz/api/StorageHandler.java
@@ -19,18 +19,13 @@
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.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;
@@ -41,69 +36,57 @@
 * @author Ulrich Hilger
 * @version 1, 5.4.2021
 */
public class StorageHandler extends AbstractHandler implements HttpHandler {
public class StorageHandler extends AbstractHandler {
  
  private static final Logger logger = Logger.getLogger(StorageHandler.class.getName());
  
  /*
    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):
  /*
    Das REST-Muster fuer die Mediazentrale (Beispiel Ablageort):
    
    1. HTTP GET Ablageort/[Name]  - Liefere den Ablageort namens [Name] als JSON
    1. HTTP GET Ablageort/[Name]  - Liefere den Ablageort namens [Name]
    2. HTTP GET Ablageort/liste/  - Liefere eine Liste mit Namen aller Ablageorte
                                     Es duerfen also keine Elemente namens "liste" angelegt werden
                                     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]  - Die angegebene Ressource wird angelegt. Wenn die Ressource
                                     bereits existiert, wird sie geändert.
    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
    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/
    HTTP GET /mz/api/store/Ablageort/
    liefert alle Ablageort-Objekte
  
    HTTP GET an /mz/api/store/Ablageort/liste/
    HTTP GET /mz/api/store/Ablageort/liste/
    liefert eine Liste der Namen vorhandener Ablageorte
  
    HTTP GET an /mz/api/store/Ablageort/[Name]
    HTTP GET /mz/api/store/Ablageort/[Name]
    liest den Ablageort namens [Name]
  
    HTTP PUT an /mz/api/store/Ablageort/[Name]
    HTTP PUT /mz/api/store/Ablageort/[Name]
    wenn [Name] existiert: Aenderung, sonst neu anlegen
  
    HTTP DELETE an /mz/api/store/Ablageort/[Name]
    HTTP DELETE /mz/api/store/Ablageort/[Name]
    löscht den Ablageort namens [Name]
  
  */
  
  /** Name der HTTP Methode GET */
  public static final String HTTP_GET = "GET";
  //public static final String HTTP_GET = "GET";
  
  /** Name der HTTP Methode PUT */
  public static final String HTTP_PUT = "PUT";
  //public static final String HTTP_PUT = "PUT";
  
  /** Name der HTTP Methode POST */
  public static final String HTTP_POST = "POST";
  //public static final String HTTP_POST = "POST";
  
  /** Name der HTTP Methode DELETE */
  public static final String HTTP_DELETE = "DELETE";
  //public static final String HTTP_DELETE = "DELETE";
  
  public static final String EP_LISTE = "liste/";
  //public static final String EP_LISTE = "liste/";
  /*
  @Override
  public void handle(HttpExchange e) throws IOException {
    String method = e.getRequestMethod();
@@ -144,8 +127,10 @@
    os.write(response.getBytes());
    os.close();        
  }
  */
  
  private String put(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 - 2];
@@ -171,63 +156,6 @@
      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);
  }
  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];
    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.FINE, "type: {0}, token: {1}", new Object[]{type, fs.typeFromName(type).getType().getTypeName()});
    Object o = gson.fromJson(body, fs.typeFromName(type).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());
        filename = file.getName();
        return type + FileHandler.STR_BLANK + filename;
      }
    }
    return type + FileHandler.STR_BLANK + " Operation 'neu' fuer bereits existierende Entitaet.";
  }
  */
  /*
  private String aendern(HttpExchange e) throws IOException {
    return neu(e); // einstweilen wird einfach ueberschrieben
  }
  */
  
  private boolean loeschen(HttpExchange e) {
    String path = e.getRequestURI().toString();
@@ -261,18 +189,18 @@
    }
  }
  
  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();
    }
    r.close();
    String json = sb.toString();
    logger.log(Level.FINE, "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);
  }
}