Persoenliche Mediazentrale
view | history | commit | commitdiff
ulrich
2021-04-26 34c03f5eff6aa63917b3ab74cc69ce80691e8f41
commit | author | age
b56bb3 1 /*
94b1c2 2   Tango - Personal Media Center
b56bb3 3   Copyright (C) 2021  Ulrich Hilger
U 4
5   This program is free software: you can redistribute it and/or modify
6   it under the terms of the GNU Affero General Public License as
7   published by the Free Software Foundation, either version 3 of the
8   License, or (at your option) any later version.
9
10   This program is distributed in the hope that it will be useful,
11   but WITHOUT ANY WARRANTY; without even the implied warranty of
12   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13   GNU Affero General Public License for more details.
14
15   You should have received a copy of the GNU Affero General Public License
16   along with this program.  If not, see <https://www.gnu.org/licenses/>.
17  */
94b1c2 18 package de.uhilger.tango.api;
b56bb3 19
1c5fa4 20 import com.google.gson.Gson;
b56bb3 21 import com.sun.net.httpserver.HttpExchange;
94b1c2 22 import de.uhilger.tango.App;
U 23 import de.uhilger.tango.Server;
24 import de.uhilger.tango.entity.Abspielvorgang;
25 import de.uhilger.tango.entity.Abspieler;
26 import de.uhilger.tango.entity.Abspielliste;
27 import de.uhilger.tango.entity.Einstellung;
28 import de.uhilger.tango.entity.Entity;
29 import de.uhilger.tango.entity.Livestream;
30 import de.uhilger.tango.entity.Titel;
31 import de.uhilger.tango.store.FileStorage;
32 import de.uhilger.tango.store.Storage;
005d7a 33 import java.io.IOException;
U 34 import java.net.HttpURLConnection;
35 import java.net.URL;
b56bb3 36 import java.util.HashMap;
U 37 import java.util.Map;
0e9cd3 38 import java.util.logging.Level;
b56bb3 39 import java.util.logging.Logger;
U 40
41 /**
0e9cd3 42  * Die MediaSteuerung verarbeitet HTTP-Signale zur Steuerung von Media-Operationen wie z.B. dem
U 43  * Spielen einer Abspielliste oder dem Starten oder Stoppen eines Videos auf einem entfernten
44  * Abspielgeraet.
45  *
46  * HTTP GET /mz/api/strg/abspieler/play/liste/[name] 
47  * HTTP GET /mz/api/strg/abspieler/ende
48  *
d027b5 49  * HTTP POST /mz/api/strg/abspieler/play/titel mit dem Titel im Body
U 50  * HTTP POST /mz/api/strg/abspieler/play/stream mit dem Livestream im Body (nur Name gefuellt)
c6fdc4 51  * 
U 52  * HTTP POST /mz/api/strg/abspieler/weiter/titel mit dem Titel im Body
0e9cd3 53  *
589850 54  * HTTP GET /mz/api/strg/abspieler/pause 
U 55  * HTTP GET /mz/api/strg/abspieler/stop 
b56bb3 56  * 
0e9cd3 57  * Faustregel: Anzahl Elemente eines URL plus 1 ist die Anzahl der Elemente des 
U 58  * Ergebnisses von String.split.
59  *
60  *
b56bb3 61  * @author Ulrich Hilger
U 62  * @version 1, 9.4.2021
63  */
64 public class MediaSteuerung extends AbstractHandler {
65
66   private static final Logger logger = Logger.getLogger(MediaSteuerung.class.getName());
0e9cd3 67
f9f819 68   public static final String PL_CMD_PLAY = "play";
0e9cd3 69   public static final String PL_DEFAULT_PARAMS = "?titel=";
005d7a 70   public static final String PL_PARAM_RUECK = "&r=";
U 71   public static final String PL_API_STRG = "/api/strg/"; 
0e9cd3 72   public static final String PL_CMD_ENDE = "ende";
589850 73   public static final String PL_CMD_STOP = "stop";
U 74   public static final String PL_CMD_PAUSE = "pause";
c6fdc4 75   public static final String PL_CMD_PLAYON = "weiter";
f9f819 76   public static final String PL_CMD_CALYPSO_STOP = "stop";
U 77   public static final String PL_CMD_CALYPSO_PAUSE = "pause";
78   public static final String PL_CMD_CALYPSO_PLAYON = "playon";
005d7a 79   public static final String DEFAULT_HOST = "http://localhost:9090";
0e9cd3 80
U 81   private final Map spielt = new HashMap();
b56bb3 82
U 83   @Override
84   protected String get(HttpExchange e) {
0e9cd3 85     String response;
b56bb3 86     String path = e.getRequestURI().toString();
0e9cd3 87     String[] elems = path.split(Server.SLASH);
U 88     FileStorage fs = new FileStorage(App.getInitParameter(App.getRs(App.RB_AP_CONF)));
589850 89     logger.fine(path);
0e9cd3 90     
U 91     // Faustregel: Anzahl Elemente eines URL plus 1 ist die Anzahl der Elemente des 
92     // Ergebnisses von String.split.
93     switch (elems.length) {
94       case 6:
95         if (elems[5].equalsIgnoreCase(PL_CMD_ENDE)) {
96           response = naechsterTitel(fs, elems[4]);
589850 97         } else if(elems[5].equalsIgnoreCase(PL_CMD_STOP)) {
d12f6e 98           spielt.remove(elems[4]);
4bbb9f 99           response = kommandoSenden(fs, elems[4], PL_CMD_CALYPSO_STOP);
589850 100         } else if(elems[5].equalsIgnoreCase(PL_CMD_PAUSE)) {
4bbb9f 101           response = kommandoSenden(fs, elems[4], PL_CMD_CALYPSO_PAUSE);
c6fdc4 102         //} else if(elems[5].equalsIgnoreCase(PL_CMD_PLAYON)) {
U 103         //  response = kommandoSenden(fs, elems[4], PL_CMD_CALYPSO_PLAYON);
0e9cd3 104         } else {
U 105           response = meldung("Ungueltiges Kommando: " + elems[5], AbstractHandler.RTC_NOT_FOUND);
106         }
107         break;
b56bb3 108       case 8:
1c5fa4 109         response = ersterTitel(fs, elems[4], elems[7]);
0e9cd3 110         break;
U 111       default:
112         response = "Ungueltiger URL";
b56bb3 113         break;
U 114     }
115     return response;
589850 116   }
1c5fa4 117
U 118   @Override
119   protected String post(HttpExchange e) {
120     String response;
c6fdc4 121     String abspielerKmd = PL_CMD_PLAY;
U 122     String path = e.getRequestURI().toString();
123     String[] elems = path.split(Server.SLASH);
124     logger.info(elems[5]);
125     if(elems[5].equalsIgnoreCase(PL_CMD_PLAYON)) {
126       abspielerKmd = PL_CMD_CALYPSO_PLAYON;
127     } else if(elems[5].equalsIgnoreCase(PL_CMD_PLAY)){
128       abspielerKmd = PL_CMD_PLAY;
129     }
1c5fa4 130     try {
c6fdc4 131       return urlAbspielen(e, abspielerKmd);
1c5fa4 132     } catch (IOException ex) {
U 133       logger.log(Level.SEVERE, null, ex);
134       return meldung(ex.getLocalizedMessage(), 404);
135     }
136   }
589850 137   
1c5fa4 138   // titel.katalogUrl + titel.pfad + titel.name
c6fdc4 139   private String urlAbspielen(HttpExchange e, String abspielerKmd) throws IOException {
1c5fa4 140     String path = e.getRequestURI().toString();
U 141     String[] elems = path.split(Server.SLASH);
142     FileStorage fs = new FileStorage(App.getInitParameter(App.getRs(App.RB_AP_CONF)));
c6fdc4 143     if(elems[6].equalsIgnoreCase("titel")) {
d027b5 144       String titelJson = bodyLesen(e);
U 145       Gson gson = new Gson();
146       Object o = gson.fromJson(titelJson, fs.typeFromName(Titel.class.getSimpleName()).getType());
147       if(o instanceof Titel) {
148         Titel titel = (Titel) o;
149         String titelUrl = titel.getKatalogUrl() + titel.getPfad() + titel.getName();
150         Entity entity = fs.read(FileStorage.ST_ABSPIELER, elems[4]);
151         if (entity instanceof Abspieler) {
152           Abspieler abspieler = (Abspieler) entity;
153           String server = getEinstellung(fs, App.getRs(App.RB_HOST), DEFAULT_HOST);
c6fdc4 154           String signal = abspielKommando(fs, abspieler, server, titelUrl, abspielerKmd).toString();
d027b5 155           abspielerKommandoSenden(signal);
U 156           return signal + "gesendet.";
157         } else {
158           return meldung("Ungueltiger Abspieler.", 404);
159         }
1c5fa4 160       } else {
d027b5 161         return meldung("Ungueltiger Titel.", 404);
1c5fa4 162       }
c6fdc4 163     } else if(elems[6].equalsIgnoreCase("stream")) {
d027b5 164       String streamJson = bodyLesen(e);
U 165       Gson gson = new Gson();
166       Object o = gson.fromJson(streamJson, fs.typeFromName(Livestream.class.getSimpleName()).getType());
167       if(o instanceof Livestream) {
168         Entity entity = fs.read(FileStorage.ST_LIVESTREAM, ((Livestream) o).getName());
169         if(entity instanceof Livestream) {
170           Livestream stream = (Livestream) entity;
171           entity = fs.read(FileStorage.ST_ABSPIELER, elems[4]);
172           if (entity instanceof Abspieler) {
173             Abspieler abspieler = (Abspieler) entity;
174             String server = "";
c6fdc4 175             String signal = abspielKommando(fs, abspieler, server, stream.getUrl(), PL_CMD_PLAY).toString();
d027b5 176             abspielerKommandoSenden(signal);
U 177             return signal + "gesendet.";
178           } else {
179             return meldung("Ungueltiger Abspieler.", 404);
180           }
181         } else {
182           return meldung("Ungueltiger Livestream.", 404); 
183         }
184       } else {
185        return meldung("Ungueltiger Livestream.", 404); 
186       }      
1c5fa4 187     } else {
d027b5 188       return meldung("Ungueltiger URL.", 404);
658c14 189     }
U 190   }
191   
c6fdc4 192   
589850 193   private String kommandoSenden(Storage s, String aName, String kommando) {
U 194     Entity entity = s.read(FileStorage.ST_ABSPIELER, aName);
195     if (entity instanceof Abspieler) {
196       Abspieler abspieler = (Abspieler) entity;
197       StringBuilder kmd = new StringBuilder();
198       kmd.append(abspieler.getUrl());
199       kmd.append(kommando);
9e14ef 200       String signal = kmd.toString();
c6fdc4 201       //String server = getEinstellung(s, App.getRs(App.RB_HOST), DEFAULT_HOST);
U 202       //String signal = abspielKommando(s, abspieler, server, stream.getUrl(), PL_CMD_PLAY).toString();
9e14ef 203       abspielerKommandoSenden(signal);
U 204       return signal + " gesendet.";
589850 205     } else {
U 206       return meldung("Abspielliste nicht gefunden.", AbstractHandler.RTC_NOT_FOUND);
207     }
b56bb3 208   }
c6fdc4 209   
b56bb3 210   
5f7e0b 211   private String ersterTitel(Storage s, String aName, String lName) {
U 212     String response;
213     Entity entity = s.read(FileStorage.ST_ABSPIELLISTE, lName);
214     if (entity instanceof Abspielliste) {
215       Abspielliste liste = (Abspielliste) entity;
216       response = listentitelSpielen(s, aName, liste, 0);
217     } else {
218       response = meldung("Abspielliste nicht gefunden.", AbstractHandler.RTC_NOT_FOUND);
219     }
220     return response;
0e9cd3 221   }
U 222
223   private String naechsterTitel(Storage s, String abspielerName) {
224     String response;
225     Object o = spielt.get(abspielerName);
226     if (o instanceof Abspielvorgang) {
227       Abspielvorgang av = (Abspielvorgang) o;
228       Entity entity = s.read(FileStorage.ST_ABSPIELLISTE, av.getListe());
229       if (entity instanceof Abspielliste) {
b56bb3 230         Abspielliste liste = (Abspielliste) entity;
0e9cd3 231         int titelNr = av.getTitelNr();
U 232         if (liste.getTitel().size() > ++titelNr) {
005d7a 233           response = listentitelSpielen(s, abspielerName, liste, titelNr);
0e9cd3 234         } else {
U 235           response = "Liste " + liste.getName() + " ist zuende gespielt.";
589850 236           logger.info(response);
0e9cd3 237         }
U 238       } else {
239         response = meldung("Abspielliste nicht gefunden.", AbstractHandler.RTC_NOT_FOUND);
b56bb3 240       }
0e9cd3 241       //response = listenTitelSpielen(e, elems[4]);
U 242     } else {
243       response = meldung("Abspielvorgang fuer Abspieler " + abspielerName, AbstractHandler.RTC_NOT_FOUND);
b56bb3 244     }
U 245     return response;
246   }
0e9cd3 247
005d7a 248   private String listentitelSpielen(Storage s, String aName, Abspielliste liste, int titelNr) {
0e9cd3 249     String response;
U 250     Entity entity = s.read(FileStorage.ST_ABSPIELER, aName);
251     if (entity instanceof Abspieler) {
252       Abspieler abspieler = (Abspieler) entity;
253       String kommando = kommandoFuerTitel(s, liste, abspieler, titelNr);
254       //String kommando = kmd.toString();
255       logger.info(kommando);
5f7e0b 256       abspielerKommandoSenden(kommando);
0e9cd3 257       response = "Abspielen der Liste " + liste.getName() + " auf Abspieler " + aName + " gestartet.";
U 258     } else {
259       response = meldung("Abspieler nicht gefunden.", AbstractHandler.RTC_NOT_FOUND);
260     }
261     return response;
262   }
263
264   /**
265    * Das Kommando zum Abspielen fuer den Titel einer Abspielliste und einen bestimmten Abspieler
266    * ermitteln.
267    *
268    * @param s die Ablage, in der Abspieler und Abspiellisten zu finden sind
269    * @param liste Name der Liste, die den gewuenschten Titel enthaelt
270    * @param abspieler Name des Abspielers, der zum Abspielen dienen soll
271    * @param titelNr Nummer des Titels in der Liste
272    * @return das Kommando zum Abspielen (ein URL)
273    */
274   private String kommandoFuerTitel(Storage s, Abspielliste liste, Abspieler abspieler, int titelNr) {
275     // ersten Titel aus Liste holen
276     Titel titel = liste.getTitel().get(titelNr);
277
278     // URL des Titels ermitteln
279     String titelUrl = titel.getKatalogUrl() + titel.getPfad() + titel.getName();
280     logger.log(Level.INFO, "abspielen von {0} auf {1}", new Object[]{titelUrl, abspieler.getUrl()});
281
282     // Titel als 'spielt' vermerken
283     Abspielvorgang vorgang = new Abspielvorgang();
284     vorgang.setAbspieler(abspieler.getName());
285     vorgang.setListe(liste.getName());
286     vorgang.setTitelNr(titelNr);
287     spielt.put(abspieler.getName(), vorgang);
005d7a 288     
U 289     String server = getEinstellung(s, App.getRs(App.RB_HOST), DEFAULT_HOST);
0e9cd3 290
1c5fa4 291     /*
U 292
0e9cd3 293     // Kommando an den Abspieler zusammenbauen
U 294     StringBuilder kmd = new StringBuilder();
295     kmd.append(abspieler.getUrl());
296     kmd.append(PL_CMD_PLAY);
297     // Parameter fuer den Abspieler holen
005d7a 298     kmd.append(getEinstellung(s, App.getRs(App.RB_PLAYERPARAMS), PL_DEFAULT_PARAMS));
U 299     kmd.append(server);
0e9cd3 300     kmd.append(titelUrl);
1c5fa4 301     */
c6fdc4 302     StringBuilder kmd = abspielKommando(s, abspieler, server, titelUrl, PL_CMD_PLAY);
005d7a 303     kmd.append(PL_PARAM_RUECK);
U 304     kmd.append(server);
305     kmd.append(PL_API_STRG);
306     kmd.append(abspieler.getName());
307     kmd.append("/ende");
0e9cd3 308
U 309     return kmd.toString();
310   }
1c5fa4 311
c6fdc4 312   private StringBuilder abspielKommando(Storage s, Abspieler abspieler, String server, String titelUrl, String abspielKmd) {
1c5fa4 313     
U 314     // Kommando an den Abspieler zusammenbauen
315     StringBuilder kmd = new StringBuilder();
316     kmd.append(abspieler.getUrl());
c6fdc4 317     //kmd.append(PL_CMD_PLAY);
U 318     kmd.append(abspielKmd);
1c5fa4 319     // Parameter fuer den Abspieler holen
U 320     kmd.append(getEinstellung(s, App.getRs(App.RB_PLAYERPARAMS), PL_DEFAULT_PARAMS));
321     kmd.append(server);
322     kmd.append(titelUrl);
323
324     return kmd;    
325   }
005d7a 326   
U 327   private String getEinstellung(Storage s, String key, String standardWert) {
328     Entity entity = s.read(Einstellung.class.getSimpleName(), key);
329     if (entity instanceof Einstellung) {
330       Einstellung einstellung = (Einstellung) entity;
331       Object o = einstellung.getValue();
332       if(o instanceof String) {
333         return o.toString();
334       } else {
335         return standardWert;
336       }
337     } else {
338       return standardWert;
339     }
340   }
341   
342   private void abspielerKommandoSenden(String kommando) {
343     /*
344       TODO hier evtl. mit mehreren Versuchen ausgleichen, 
345       dass ein einzelner Versuch nicht 'durchkommt'...
346     */
347     logger.info(kommando);
348     try {
349       HttpURLConnection conn = (HttpURLConnection) new URL(kommando).openConnection();
350       conn.setRequestMethod("GET");
351       conn.connect();
352       int status = conn.getResponseCode();
353       String msg = conn.getResponseMessage();
354       logger.log(Level.INFO, "Kommando {0} mit Status {1} {2} gesendet.", new Object[]{kommando, status, msg});
355     } catch(IOException ex) {
356       logger.log(Level.INFO, ex.getMessage(), ex);
357     }
358   }
359   
5f7e0b 360   private String meldung(String text, int code) {
U 361     setReturnCode(code);
362     return text;
363   }
b56bb3 364 }