| | |
| | | import com.sun.net.httpserver.HttpHandler; |
| | | import java.io.IOException; |
| | | import java.io.OutputStream; |
| | | import java.util.HashMap; |
| | | import java.util.Set; |
| | | import java.util.Map; |
| | | import java.util.logging.Level; |
| | | import java.util.logging.Logger; |
| | | |
| | | /** |
| | | * Es koennen mehrere Varianten beim Abspielen verwendet werden. |
| | | * |
| | | * Abspielen eines Titels |
| | | * abspielenMitParameternUndRueckmeldung(urlStr, null, null, 1) |
| | | * |
| | | * Abspielen eines Titels mit Rueckmeldung (z.B. fuer Playlisten) |
| | | * abspielenMitParameternUndRueckmeldung(urlStr, null, meldeUrlStr, 1) |
| | | * |
| | | * Abspielen mit Parametern |
| | | * abspielenMitParameternUndRueckmeldung(urlStr, parameter, null, 1) |
| | | * |
| | | * Abspielen mit Parametern und Rueckmeldung |
| | | * abspielenMitParameternUndRueckmeldung(urlStr, parameter, meldeUrlStr, 1) |
| | | * |
| | | * Token wird zur Zeit nicht genutzt, hier kann einfach eine beliebige |
| | | * Zahl uebergeben werden. |
| | | * |
| | | * Die drei Parameter t, p, r werden als Query im URL erwartet. Beispiele: |
| | | * t = titel |
| | | * p = parameter |
| | | * r = url fuer rueckmeldung |
| | | * |
| | | * |
| | | * /avd/play?t=/Pfad/zum/Titel.mp3 |
| | | * /avd/play?t=/Pfad/zum/Titel.mp3&p=-o=local%20-timeout=60 |
| | | * /avd/play?t=/Pfad/zum/Titel.mp3&r=http:/uhilger.de/rueckmelde/pfad |
| | | * /avd/play?t=/Pfad/zum/Titel.mp3&p=-o=local%20-timeout=60&r=http:/uhilger.de/rueckmelde/pfad |
| | | * |
| | | * String urlStr, String parameter, String meldeUrlStr, String token |
| | | * |
| | | * |
| | | * |
| | | * |
| | | * |
| | | * @author ulrich |
| | | */ |
| | | public class PlayHandler extends OMXPlayer implements HttpHandler { |
| | | |
| | | private static final Logger logger = Logger.getLogger(PlayHandler.class.getName()); |
| | | |
| | | /* |
| | | rpi4-az:9090/avd/play?titel=/Filme/S/sound_city.m4v&th=60&ti=60&o=local |
| | | |
| | | OMXPlayer.abspielenMitParameternUndRueckmeldung( |
| | | String urlStr, String parameter, String meldeUrlStr, String token) |
| | | |
| | | Parameter des Aufrufs play als query (th threshold, ti timeout) |
| | | |
| | | ?titel=/Filme/S/sound_city.m4v |
| | | &ti=60 |
| | | &th=60 |
| | | &o=local|hdmi|both |
| | | &r=http://uhilger.de/mc/api/usw |
| | | |
| | | r muss ganz wegbleiben, wenn keine Rueckmeldung gewuescht ist |
| | | |
| | | */ |
| | | @Override |
| | | public void handle(HttpExchange t) throws IOException { |
| | | logger.log(Level.INFO, "RequestURI.getPath: {0}", t.getRequestURI().getPath()); |
| | | logger.log(Level.FINE, "RequestURI: {0}", t.getRequestURI().toString()); |
| | | |
| | | String path = t.getRequestURI().getPath(); |
| | | String[] parts = path.split("/"); |
| | | for (String part : parts) { |
| | | logger.log(Level.INFO, "part: {0}", part); |
| | | } |
| | | //logger.log(Level.INFO, "query: {0}", t.getRequestURI().getQuery()); |
| | | |
| | | HashMap map = new HashMap(); |
| | | String query = t.getRequestURI().getQuery(); |
| | | if(query != null && query.length() > 0) { |
| | | String qParts[] = query.split("&"); |
| | | for(String qPart : qParts) { |
| | | //logger.info("qPart: " + qPart); |
| | | String pParts[] = qPart.split("="); |
| | | map.put(pParts[0], pParts[1]); |
| | | } |
| | | } |
| | | Set keys = map.keySet(); |
| | | keys.forEach(key -> { |
| | | logger.info("key " + key + " value " + map.get(key)); |
| | | }); |
| | | Map map = getQueryMap(t); |
| | | StringBuilder params = new StringBuilder(); |
| | | params.append("-o "); |
| | | params.append(getParam(map, "o")); |
| | | params.append(" --threshold "); |
| | | params.append(getParam(map, "th")); |
| | | params.append(" --timeout "); |
| | | params.append(getParam(map, "ti")); |
| | | |
| | | |
| | | String response = "play"; |
| | | String antwort = abspielenMitParameternUndRueckmeldung( |
| | | getParam(map, "titel"), params.toString(), getParam(map, "r"), "1"); |
| | | |
| | | String response = getResponseString(map, "play", antwort); |
| | | t.sendResponseHeaders(200, response.length()); |
| | | OutputStream os = t.getResponseBody(); |
| | | os.write(response.getBytes()); |
| | | os.close(); |
| | | |
| | | } |
| | | |
| | | |
| | | |
| | | } |