Persoenliche Mediazentrale
blame | history | patch | commit | commitdiff | ignore whitespace
ulrich
2021-04-21 757acef98231fb7b5923befbe0498924874ebd32 
 src/de/uhilger/mediaz/api/StorageHandler.java


@@ -24,10 +24,35 @@


import de.uhilger.mediaz.Server;


import de.uhilger.mediaz.store.FileStorage;


import de.uhilger.mediaz.entity.Entity;


import de.uhilger.mediaz.entity.Geraet;


import static de.uhilger.mediaz.store.FileStorage.ST_ABLAGEORT;


import static de.uhilger.mediaz.store.FileStorage.ST_GERAET;


import de.uhilger.mediaz.store.Storage;


import java.io.BufferedReader;


import java.io.IOException;


import java.io.InputStream;


import java.io.InputStreamReader;


import java.net.Authenticator;


import java.net.HttpURLConnection;


import java.net.InetSocketAddress;


import java.net.ProxySelector;


import java.net.URI;


import java.net.URL;


import java.util.Iterator;


import java.util.List;


import java.util.logging.Level;


import java.util.logging.Logger;




import java.net.http.HttpClient;


import java.net.http.HttpClient.Version;


import java.net.http.HttpClient.Redirect;


import java.net.http.HttpClient.Builder;


import java.net.http.HttpRequest;


import java.net.http.HttpResponse;


import java.net.http.HttpResponse.BodyHandlers;


import java.time.Duration;


import java.util.ArrayList;






/**


 * HttpHandler fuer die Verwaltung von Entitaeten der Mediazentrale


@@ -76,7 +101,7 @@


    return fs.delete(type, elemName);


  }


  


  private String lesen(HttpExchange e) {


  private String lesen(HttpExchange e) throws IOException, InterruptedException {


    String path = e.getRequestURI().toString();


    String[] elems = path.split(Server.SLASH);


    FileStorage fs = new FileStorage(App.getInitParameter(App.getRs(App.RB_AP_CONF)));


@@ -85,7 +110,17 @@


      if(elems[elems.length - 1].equalsIgnoreCase(App.getRs(RB_EP_LISTE))) {


        String type = elems[elems.length - 2];


        logger.fine(type);


        list = fs.list(type);


        if(type.equalsIgnoreCase(ST_GERAET)) {


          list = collectDeviceStatus(fs, type);


          Gson gson = new Gson();


          Object o = gson.fromJson(bodyLesen(e), fs.typeFromName(type).getType());


          return gson.toJson(list);


        } else {        


          list = fs.list(type);


        }


        if(type.equalsIgnoreCase(ST_ABLAGEORT)) {


          list.add("Livestreams");


        }


      } else {


        String type = elems[elems.length - 1];


        logger.fine(type);


@@ -101,7 +136,12 @@


  


  @Override


  public String get(HttpExchange e) {


    return lesen(e);


    try {


      return lesen(e);


    } catch (IOException | InterruptedException ex) {


      Logger.getLogger(StorageHandler.class.getName()).log(Level.SEVERE, null, ex);


      return ex.getLocalizedMessage();


    }


  }




  @Override


@@ -113,4 +153,38 @@


  public boolean delete(HttpExchange e) {


    return loeschen(e);


  }


  


  private List collectDeviceStatus(Storage fs, String type) throws IOException, InterruptedException {


    List list = fs.listObjects(type);


    List<Geraet> newList = new ArrayList();


    Iterator<Entity> i = list.iterator();


    while (i.hasNext()) {


      Entity entity = i.next();


      if (entity instanceof Geraet) {


        Geraet g = (Geraet) entity;


        String statusurl = g.getStatusUrl();


        logger.info(statusurl);




        HttpRequest request = HttpRequest.newBuilder()


                .uri(URI.create(statusurl))


                .build();


        HttpClient client = HttpClient.newBuilder()


                .version(Version.HTTP_1_1)


                .followRedirects(Redirect.NORMAL)


                .connectTimeout(Duration.ofSeconds(20))


                //.proxy(ProxySelector.of(new InetSocketAddress("proxy.example.com", 80)))


                //.authenticator(Authenticator.getDefault())


                .build();


        HttpResponse<String> response = client.send(request, BodyHandlers.ofString());


        logger.finer(Integer.toString(response.statusCode()));


        logger.finer(response.body());


        // {"ison":false,"has_timer":false,"overpower":false}


        String[] parts = response.body().split(",")[0].split(":");


        logger.finer("ison: " + parts[1]);


        g.setStatus(parts[1]);


        newList.add(g);


      }


    }


    return newList;


  }


}