| | |
| | | */ |
| | | package de.uhilger.mediaz.api; |
| | | |
| | | import com.google.gson.Gson; |
| | | import com.sun.net.httpserver.HttpExchange; |
| | | import de.uhilger.mediaz.App; |
| | | import de.uhilger.mediaz.Server; |
| | |
| | | * HTTP GET /mz/api/strg/abspieler/play/liste/[name] |
| | | * HTTP GET /mz/api/strg/abspieler/ende |
| | | * |
| | | * HTTP GET /mz/api/strg/abspieler/play/[url] |
| | | * HTTP POST /mz/api/strg/abspieler/play mit dem Titel im Body |
| | | * |
| | | * HTTP GET /mz/api/strg/abspieler/pause |
| | | * HTTP GET /mz/api/strg/abspieler/stop |
| | |
| | | if (elems[5].equalsIgnoreCase(PL_CMD_ENDE)) { |
| | | response = naechsterTitel(fs, elems[4]); |
| | | } else if(elems[5].equalsIgnoreCase(PL_CMD_STOP)) { |
| | | spielt.remove(elems[4]); |
| | | response = kommandoSenden(fs, elems[4], PL_CMD_AVD_STOP); |
| | | } else if(elems[5].equalsIgnoreCase(PL_CMD_PAUSE)) { |
| | | response = kommandoSenden(fs, elems[4], PL_CMD_AVD_PAUSE); |
| | |
| | | break; |
| | | } |
| | | return response; |
| | | } |
| | | |
| | | @Override |
| | | protected String post(HttpExchange e) { |
| | | String response; |
| | | try { |
| | | return urlAbspielen(e); |
| | | } catch (IOException ex) { |
| | | logger.log(Level.SEVERE, null, ex); |
| | | return meldung(ex.getLocalizedMessage(), 404); |
| | | } |
| | | } |
| | | |
| | | // titel.katalogUrl + titel.pfad + titel.name |
| | | private String urlAbspielen(HttpExchange e) throws IOException { |
| | | String path = e.getRequestURI().toString(); |
| | | String[] elems = path.split(Server.SLASH); |
| | | FileStorage fs = new FileStorage(App.getInitParameter(App.getRs(App.RB_AP_CONF))); |
| | | |
| | | String titelJson = bodyLesen(e); |
| | | Gson gson = new Gson(); |
| | | Object o = gson.fromJson(titelJson, fs.typeFromName(Titel.class.getSimpleName()).getType()); |
| | | if(o instanceof Titel) { |
| | | Titel titel = (Titel) o; |
| | | String titelUrl = titel.getKatalogUrl() + titel.getPfad() + titel.getName(); |
| | | Entity entity = fs.read(FileStorage.ST_ABSPIELER, elems[4]); |
| | | if (entity instanceof Abspieler) { |
| | | Abspieler abspieler = (Abspieler) entity; |
| | | String server = getEinstellung(fs, App.getRs(App.RB_HOST), DEFAULT_HOST); |
| | | String signal = abspielKommando(fs, abspieler, server, titelUrl).toString(); |
| | | abspielerKommandoSenden(signal); |
| | | return signal + "gesendet."; |
| | | } else { |
| | | return meldung("Ungueltiger Abspieler.", 404); |
| | | } |
| | | } else { |
| | | return meldung("Ungueltiger Titel.", 404); |
| | | } |
| | | } |
| | | |
| | | private String kommandoSenden(Storage s, String aName, String kommando) { |
| | |
| | | |
| | | String server = getEinstellung(s, App.getRs(App.RB_HOST), DEFAULT_HOST); |
| | | |
| | | /* |
| | | |
| | | // Kommando an den Abspieler zusammenbauen |
| | | StringBuilder kmd = new StringBuilder(); |
| | | kmd.append(abspieler.getUrl()); |
| | |
| | | kmd.append(getEinstellung(s, App.getRs(App.RB_PLAYERPARAMS), PL_DEFAULT_PARAMS)); |
| | | kmd.append(server); |
| | | kmd.append(titelUrl); |
| | | */ |
| | | StringBuilder kmd = abspielKommando(s, abspieler, server, titelUrl); |
| | | kmd.append(PL_PARAM_RUECK); |
| | | kmd.append(server); |
| | | kmd.append(PL_API_STRG); |
| | |
| | | |
| | | return kmd.toString(); |
| | | } |
| | | |
| | | private StringBuilder abspielKommando(Storage s, Abspieler abspieler, String server, String titelUrl) { |
| | | |
| | | // Kommando an den Abspieler zusammenbauen |
| | | StringBuilder kmd = new StringBuilder(); |
| | | kmd.append(abspieler.getUrl()); |
| | | kmd.append(PL_CMD_PLAY); |
| | | // Parameter fuer den Abspieler holen |
| | | kmd.append(getEinstellung(s, App.getRs(App.RB_PLAYERPARAMS), PL_DEFAULT_PARAMS)); |
| | | kmd.append(server); |
| | | kmd.append(titelUrl); |
| | | |
| | | return kmd; |
| | | } |
| | | |
| | | private String getEinstellung(Storage s, String key, String standardWert) { |
| | | Entity entity = s.read(Einstellung.class.getSimpleName(), key); |