Persoenliche Mediazentrale
blame | history | patch | commit | commitdiff | show whitespace
ulrich
2021-04-20 d769f3445ed4779715b5c2570731b4bb73d8d2aa 
 src/de/uhilger/mediaz/api/StorageHandler.java


@@ -24,11 +24,34 @@


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 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


@@ -77,7 +100,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)));


@@ -86,7 +109,41 @@


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


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


        logger.fine(type);


        if(type.equalsIgnoreCase(ST_GERAET)) {


          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);


            }


          }


          list = newList;


        } else {        


        list = fs.list(type);


        }


        if(type.equalsIgnoreCase(ST_ABLAGEORT)) {


          list.add("Livestreams");


        }


@@ -105,7 +162,12 @@


  


  @Override


  public String get(HttpExchange e) {


    try {


    return lesen(e);


    } catch (IOException | InterruptedException ex) {


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


      return ex.getLocalizedMessage();


    }


  }




  @Override