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