Persoenliche Mediazentrale
view | history | commit | commitdiff
ulrich
2021-05-06 f70acbb491c6421623cca57292a75f1820efad4d
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=";
960359 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();
f70acb 82   
U 83   private String conf;
84   
85   public MediaSteuerung(String conf) {
86     this.conf = conf;
87   }
b56bb3 88
U 89   @Override
90   protected String get(HttpExchange e) {
0e9cd3 91     String response;
b56bb3 92     String path = e.getRequestURI().toString();
0e9cd3 93     String[] elems = path.split(Server.SLASH);
f70acb 94     FileStorage fs = new FileStorage(conf);
589850 95     logger.fine(path);
0e9cd3 96     
U 97     // Faustregel: Anzahl Elemente eines URL plus 1 ist die Anzahl der Elemente des 
98     // Ergebnisses von String.split.
99     switch (elems.length) {
100       case 6:
101         if (elems[5].equalsIgnoreCase(PL_CMD_ENDE)) {
102           response = naechsterTitel(fs, elems[4]);
589850 103         } else if(elems[5].equalsIgnoreCase(PL_CMD_STOP)) {
d12f6e 104           spielt.remove(elems[4]);
4bbb9f 105           response = kommandoSenden(fs, elems[4], PL_CMD_CALYPSO_STOP);
589850 106         } else if(elems[5].equalsIgnoreCase(PL_CMD_PAUSE)) {
4bbb9f 107           response = kommandoSenden(fs, elems[4], PL_CMD_CALYPSO_PAUSE);
c6fdc4 108         //} else if(elems[5].equalsIgnoreCase(PL_CMD_PLAYON)) {
U 109         //  response = kommandoSenden(fs, elems[4], PL_CMD_CALYPSO_PLAYON);
0e9cd3 110         } else {
U 111           response = meldung("Ungueltiges Kommando: " + elems[5], AbstractHandler.RTC_NOT_FOUND);
112         }
113         break;
b56bb3 114       case 8:
1c5fa4 115         response = ersterTitel(fs, elems[4], elems[7]);
0e9cd3 116         break;
U 117       default:
118         response = "Ungueltiger URL";
b56bb3 119         break;
U 120     }
121     return response;
589850 122   }
1c5fa4 123
U 124   @Override
125   protected String post(HttpExchange e) {
126     String response;
c6fdc4 127     String abspielerKmd = PL_CMD_PLAY;
U 128     String path = e.getRequestURI().toString();
129     String[] elems = path.split(Server.SLASH);
130     logger.info(elems[5]);
131     if(elems[5].equalsIgnoreCase(PL_CMD_PLAYON)) {
132       abspielerKmd = PL_CMD_CALYPSO_PLAYON;
133     } else if(elems[5].equalsIgnoreCase(PL_CMD_PLAY)){
134       abspielerKmd = PL_CMD_PLAY;
135     }
1c5fa4 136     try {
c6fdc4 137       return urlAbspielen(e, abspielerKmd);
1c5fa4 138     } catch (IOException ex) {
U 139       logger.log(Level.SEVERE, null, ex);
140       return meldung(ex.getLocalizedMessage(), 404);
141     }
142   }
589850 143   
1c5fa4 144   // titel.katalogUrl + titel.pfad + titel.name
c6fdc4 145   private String urlAbspielen(HttpExchange e, String abspielerKmd) throws IOException {
1c5fa4 146     String path = e.getRequestURI().toString();
U 147     String[] elems = path.split(Server.SLASH);
f70acb 148     FileStorage fs = new FileStorage(conf);
c6fdc4 149     if(elems[6].equalsIgnoreCase("titel")) {
d027b5 150       String titelJson = bodyLesen(e);
U 151       Gson gson = new Gson();
152       Object o = gson.fromJson(titelJson, fs.typeFromName(Titel.class.getSimpleName()).getType());
153       if(o instanceof Titel) {
154         Titel titel = (Titel) o;
155         String titelUrl = titel.getKatalogUrl() + titel.getPfad() + titel.getName();
156         Entity entity = fs.read(FileStorage.ST_ABSPIELER, elems[4]);
157         if (entity instanceof Abspieler) {
158           Abspieler abspieler = (Abspieler) entity;
f70acb 159           String server = getEinstellung(fs, getResString(App.RB_HOST), DEFAULT_HOST);
c6fdc4 160           String signal = abspielKommando(fs, abspieler, server, titelUrl, abspielerKmd).toString();
d027b5 161           abspielerKommandoSenden(signal);
U 162           return signal + "gesendet.";
163         } else {
164           return meldung("Ungueltiger Abspieler.", 404);
165         }
1c5fa4 166       } else {
d027b5 167         return meldung("Ungueltiger Titel.", 404);
1c5fa4 168       }
c6fdc4 169     } else if(elems[6].equalsIgnoreCase("stream")) {
d027b5 170       String streamJson = bodyLesen(e);
U 171       Gson gson = new Gson();
172       Object o = gson.fromJson(streamJson, fs.typeFromName(Livestream.class.getSimpleName()).getType());
173       if(o instanceof Livestream) {
174         Entity entity = fs.read(FileStorage.ST_LIVESTREAM, ((Livestream) o).getName());
175         if(entity instanceof Livestream) {
176           Livestream stream = (Livestream) entity;
177           entity = fs.read(FileStorage.ST_ABSPIELER, elems[4]);
178           if (entity instanceof Abspieler) {
179             Abspieler abspieler = (Abspieler) entity;
180             String server = "";
c6fdc4 181             String signal = abspielKommando(fs, abspieler, server, stream.getUrl(), PL_CMD_PLAY).toString();
d027b5 182             abspielerKommandoSenden(signal);
U 183             return signal + "gesendet.";
184           } else {
185             return meldung("Ungueltiger Abspieler.", 404);
186           }
187         } else {
188           return meldung("Ungueltiger Livestream.", 404); 
189         }
190       } else {
191        return meldung("Ungueltiger Livestream.", 404); 
192       }      
1c5fa4 193     } else {
d027b5 194       return meldung("Ungueltiger URL.", 404);
658c14 195     }
U 196   }
197   
c6fdc4 198   
589850 199   private String kommandoSenden(Storage s, String aName, String kommando) {
U 200     Entity entity = s.read(FileStorage.ST_ABSPIELER, aName);
201     if (entity instanceof Abspieler) {
202       Abspieler abspieler = (Abspieler) entity;
203       StringBuilder kmd = new StringBuilder();
204       kmd.append(abspieler.getUrl());
205       kmd.append(kommando);
9e14ef 206       String signal = kmd.toString();
c6fdc4 207       //String server = getEinstellung(s, App.getRs(App.RB_HOST), DEFAULT_HOST);
U 208       //String signal = abspielKommando(s, abspieler, server, stream.getUrl(), PL_CMD_PLAY).toString();
9e14ef 209       abspielerKommandoSenden(signal);
U 210       return signal + " gesendet.";
589850 211     } else {
U 212       return meldung("Abspielliste nicht gefunden.", AbstractHandler.RTC_NOT_FOUND);
213     }
b56bb3 214   }
c6fdc4 215   
b56bb3 216   
5f7e0b 217   private String ersterTitel(Storage s, String aName, String lName) {
U 218     String response;
219     Entity entity = s.read(FileStorage.ST_ABSPIELLISTE, lName);
220     if (entity instanceof Abspielliste) {
221       Abspielliste liste = (Abspielliste) entity;
222       response = listentitelSpielen(s, aName, liste, 0);
223     } else {
224       response = meldung("Abspielliste nicht gefunden.", AbstractHandler.RTC_NOT_FOUND);
225     }
226     return response;
0e9cd3 227   }
U 228
229   private String naechsterTitel(Storage s, String abspielerName) {
230     String response;
231     Object o = spielt.get(abspielerName);
232     if (o instanceof Abspielvorgang) {
233       Abspielvorgang av = (Abspielvorgang) o;
234       Entity entity = s.read(FileStorage.ST_ABSPIELLISTE, av.getListe());
235       if (entity instanceof Abspielliste) {
b56bb3 236         Abspielliste liste = (Abspielliste) entity;
0e9cd3 237         int titelNr = av.getTitelNr();
U 238         if (liste.getTitel().size() > ++titelNr) {
005d7a 239           response = listentitelSpielen(s, abspielerName, liste, titelNr);
0e9cd3 240         } else {
U 241           response = "Liste " + liste.getName() + " ist zuende gespielt.";
589850 242           logger.info(response);
0e9cd3 243         }
U 244       } else {
245         response = meldung("Abspielliste nicht gefunden.", AbstractHandler.RTC_NOT_FOUND);
b56bb3 246       }
0e9cd3 247       //response = listenTitelSpielen(e, elems[4]);
U 248     } else {
249       response = meldung("Abspielvorgang fuer Abspieler " + abspielerName, AbstractHandler.RTC_NOT_FOUND);
b56bb3 250     }
U 251     return response;
252   }
0e9cd3 253
005d7a 254   private String listentitelSpielen(Storage s, String aName, Abspielliste liste, int titelNr) {
0e9cd3 255     String response;
U 256     Entity entity = s.read(FileStorage.ST_ABSPIELER, aName);
257     if (entity instanceof Abspieler) {
258       Abspieler abspieler = (Abspieler) entity;
259       String kommando = kommandoFuerTitel(s, liste, abspieler, titelNr);
260       //String kommando = kmd.toString();
261       logger.info(kommando);
5f7e0b 262       abspielerKommandoSenden(kommando);
0e9cd3 263       response = "Abspielen der Liste " + liste.getName() + " auf Abspieler " + aName + " gestartet.";
U 264     } else {
265       response = meldung("Abspieler nicht gefunden.", AbstractHandler.RTC_NOT_FOUND);
266     }
267     return response;
268   }
269
270   /**
271    * Das Kommando zum Abspielen fuer den Titel einer Abspielliste und einen bestimmten Abspieler
272    * ermitteln.
273    *
274    * @param s die Ablage, in der Abspieler und Abspiellisten zu finden sind
275    * @param liste Name der Liste, die den gewuenschten Titel enthaelt
276    * @param abspieler Name des Abspielers, der zum Abspielen dienen soll
277    * @param titelNr Nummer des Titels in der Liste
278    * @return das Kommando zum Abspielen (ein URL)
279    */
280   private String kommandoFuerTitel(Storage s, Abspielliste liste, Abspieler abspieler, int titelNr) {
281     // ersten Titel aus Liste holen
282     Titel titel = liste.getTitel().get(titelNr);
283
284     // URL des Titels ermitteln
285     String titelUrl = titel.getKatalogUrl() + titel.getPfad() + titel.getName();
286     logger.log(Level.INFO, "abspielen von {0} auf {1}", new Object[]{titelUrl, abspieler.getUrl()});
287
288     // Titel als 'spielt' vermerken
289     Abspielvorgang vorgang = new Abspielvorgang();
290     vorgang.setAbspieler(abspieler.getName());
291     vorgang.setListe(liste.getName());
292     vorgang.setTitelNr(titelNr);
293     spielt.put(abspieler.getName(), vorgang);
005d7a 294     
f70acb 295     String server = getEinstellung(s, getResString(App.RB_HOST), DEFAULT_HOST);
0e9cd3 296
1c5fa4 297     /*
U 298
0e9cd3 299     // Kommando an den Abspieler zusammenbauen
U 300     StringBuilder kmd = new StringBuilder();
301     kmd.append(abspieler.getUrl());
302     kmd.append(PL_CMD_PLAY);
303     // Parameter fuer den Abspieler holen
005d7a 304     kmd.append(getEinstellung(s, App.getRs(App.RB_PLAYERPARAMS), PL_DEFAULT_PARAMS));
U 305     kmd.append(server);
0e9cd3 306     kmd.append(titelUrl);
1c5fa4 307     */
c6fdc4 308     StringBuilder kmd = abspielKommando(s, abspieler, server, titelUrl, PL_CMD_PLAY);
005d7a 309     kmd.append(PL_PARAM_RUECK);
U 310     kmd.append(server);
3a0556 311     if(!server.endsWith(Server.SLASH)) {
U 312       kmd.append(Server.SLASH);
313     }
005d7a 314     kmd.append(PL_API_STRG);
U 315     kmd.append(abspieler.getName());
316     kmd.append("/ende");
0e9cd3 317
U 318     return kmd.toString();
319   }
1c5fa4 320
c6fdc4 321   private StringBuilder abspielKommando(Storage s, Abspieler abspieler, String server, String titelUrl, String abspielKmd) {
1c5fa4 322     
U 323     // Kommando an den Abspieler zusammenbauen
324     StringBuilder kmd = new StringBuilder();
325     kmd.append(abspieler.getUrl());
c6fdc4 326     //kmd.append(PL_CMD_PLAY);
U 327     kmd.append(abspielKmd);
1c5fa4 328     // Parameter fuer den Abspieler holen
f70acb 329     kmd.append(getEinstellung(s, getResString(App.RB_PLAYERPARAMS), PL_DEFAULT_PARAMS));
1c5fa4 330     kmd.append(server);
U 331     kmd.append(titelUrl);
332
333     return kmd;    
334   }
005d7a 335   
U 336   private String getEinstellung(Storage s, String key, String standardWert) {
337     Entity entity = s.read(Einstellung.class.getSimpleName(), key);
338     if (entity instanceof Einstellung) {
339       Einstellung einstellung = (Einstellung) entity;
340       Object o = einstellung.getValue();
341       if(o instanceof String) {
342         return o.toString();
343       } else {
344         return standardWert;
345       }
346     } else {
347       return standardWert;
348     }
349   }
350   
351   private void abspielerKommandoSenden(String kommando) {
352     /*
353       TODO hier evtl. mit mehreren Versuchen ausgleichen, 
354       dass ein einzelner Versuch nicht 'durchkommt'...
355     */
356     logger.info(kommando);
357     try {
358       HttpURLConnection conn = (HttpURLConnection) new URL(kommando).openConnection();
359       conn.setRequestMethod("GET");
360       conn.connect();
361       int status = conn.getResponseCode();
362       String msg = conn.getResponseMessage();
363       logger.log(Level.INFO, "Kommando {0} mit Status {1} {2} gesendet.", new Object[]{kommando, status, msg});
364     } catch(IOException ex) {
365       logger.log(Level.INFO, ex.getMessage(), ex);
366     }
367   }
368   
5f7e0b 369   private String meldung(String text, int code) {
U 370     setReturnCode(code);
371     return text;
372   }
b56bb3 373 }