commit | author | age
|
b56bb3
|
1 |
/* |
U |
2 |
Mediazentrale - Personal Media Center |
|
3 |
Copyright (C) 2021 Ulrich Hilger |
|
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 |
*/ |
|
18 |
package de.uhilger.mediaz.api; |
|
19 |
|
|
20 |
import com.sun.net.httpserver.HttpExchange; |
|
21 |
import de.uhilger.mediaz.App; |
|
22 |
import de.uhilger.mediaz.Server; |
0e9cd3
|
23 |
import de.uhilger.mediaz.entity.Abspielvorgang; |
b56bb3
|
24 |
import de.uhilger.mediaz.entity.Abspieler; |
U |
25 |
import de.uhilger.mediaz.entity.Abspielliste; |
0e9cd3
|
26 |
import de.uhilger.mediaz.entity.Einstellung; |
b56bb3
|
27 |
import de.uhilger.mediaz.entity.Entity; |
U |
28 |
import de.uhilger.mediaz.entity.Titel; |
|
29 |
import de.uhilger.mediaz.store.FileStorage; |
0e9cd3
|
30 |
import de.uhilger.mediaz.store.Storage; |
005d7a
|
31 |
import java.io.IOException; |
U |
32 |
import java.net.HttpURLConnection; |
|
33 |
import java.net.URL; |
b56bb3
|
34 |
import java.util.HashMap; |
U |
35 |
import java.util.Map; |
0e9cd3
|
36 |
import java.util.logging.Level; |
b56bb3
|
37 |
import java.util.logging.Logger; |
U |
38 |
|
|
39 |
/** |
0e9cd3
|
40 |
* Die MediaSteuerung verarbeitet HTTP-Signale zur Steuerung von Media-Operationen wie z.B. dem |
U |
41 |
* Spielen einer Abspielliste oder dem Starten oder Stoppen eines Videos auf einem entfernten |
|
42 |
* Abspielgeraet. |
|
43 |
* |
|
44 |
* HTTP GET /mz/api/strg/abspieler/play/liste/[name] |
|
45 |
* HTTP GET /mz/api/strg/abspieler/ende |
|
46 |
* |
|
47 |
* HTTP GET /mz/api/strg/abspieler/play/[url] |
|
48 |
* |
589850
|
49 |
* HTTP GET /mz/api/strg/abspieler/pause |
U |
50 |
* HTTP GET /mz/api/strg/abspieler/stop |
|
51 |
* HTTP GET /mz/api/strg/abspieler/weiter |
b56bb3
|
52 |
* |
0e9cd3
|
53 |
* Faustregel: Anzahl Elemente eines URL plus 1 ist die Anzahl der Elemente des |
U |
54 |
* Ergebnisses von String.split. |
|
55 |
* |
|
56 |
* |
b56bb3
|
57 |
* @author Ulrich Hilger |
U |
58 |
* @version 1, 9.4.2021 |
|
59 |
*/ |
|
60 |
public class MediaSteuerung extends AbstractHandler { |
|
61 |
|
|
62 |
private static final Logger logger = Logger.getLogger(MediaSteuerung.class.getName()); |
0e9cd3
|
63 |
|
U |
64 |
public static final String PL_CMD_PLAY = "avd/play"; |
|
65 |
public static final String PL_DEFAULT_PARAMS = "?titel="; |
005d7a
|
66 |
public static final String PL_PARAM_RUECK = "&r="; |
U |
67 |
public static final String PL_API_STRG = "/api/strg/"; |
0e9cd3
|
68 |
public static final String PL_CMD_ENDE = "ende"; |
589850
|
69 |
public static final String PL_CMD_STOP = "stop"; |
U |
70 |
public static final String PL_CMD_PAUSE = "pause"; |
|
71 |
public static final String PL_CMD_PLAYON = "playon"; |
|
72 |
public static final String PL_CMD_AVD_STOP = "avd/stop"; |
|
73 |
public static final String PL_CMD_AVD_PAUSE = "avd/pause"; |
|
74 |
public static final String PL_CMD_AVD_PLAYON = "avd/playon"; |
005d7a
|
75 |
public static final String DEFAULT_HOST = "http://localhost:9090"; |
0e9cd3
|
76 |
|
U |
77 |
private final Map spielt = new HashMap(); |
b56bb3
|
78 |
|
U |
79 |
@Override |
|
80 |
protected String get(HttpExchange e) { |
0e9cd3
|
81 |
String response; |
b56bb3
|
82 |
String path = e.getRequestURI().toString(); |
0e9cd3
|
83 |
String[] elems = path.split(Server.SLASH); |
U |
84 |
FileStorage fs = new FileStorage(App.getInitParameter(App.getRs(App.RB_AP_CONF))); |
589850
|
85 |
logger.fine(path); |
0e9cd3
|
86 |
|
U |
87 |
// Faustregel: Anzahl Elemente eines URL plus 1 ist die Anzahl der Elemente des |
|
88 |
// Ergebnisses von String.split. |
|
89 |
switch (elems.length) { |
|
90 |
case 6: |
|
91 |
if (elems[5].equalsIgnoreCase(PL_CMD_ENDE)) { |
|
92 |
response = naechsterTitel(fs, elems[4]); |
589850
|
93 |
} else if(elems[5].equalsIgnoreCase(PL_CMD_STOP)) { |
U |
94 |
response = kommandoSenden(fs, elems[4], PL_CMD_AVD_STOP); |
|
95 |
} else if(elems[5].equalsIgnoreCase(PL_CMD_PAUSE)) { |
|
96 |
response = kommandoSenden(fs, elems[4], PL_CMD_AVD_PAUSE); |
|
97 |
} else if(elems[5].equalsIgnoreCase(PL_CMD_PLAYON)) { |
|
98 |
response = kommandoSenden(fs, elems[4], PL_CMD_AVD_PLAYON); |
0e9cd3
|
99 |
} else { |
U |
100 |
response = meldung("Ungueltiges Kommando: " + elems[5], AbstractHandler.RTC_NOT_FOUND); |
|
101 |
} |
|
102 |
break; |
b56bb3
|
103 |
case 8: |
5f7e0b
|
104 |
response = ersterTitel(fs, elems[4], elems[7]); |
0e9cd3
|
105 |
break; |
U |
106 |
default: |
|
107 |
response = "Ungueltiger URL"; |
b56bb3
|
108 |
break; |
U |
109 |
} |
|
110 |
return response; |
589850
|
111 |
} |
U |
112 |
|
|
113 |
private String kommandoSenden(Storage s, String aName, String kommando) { |
|
114 |
Entity entity = s.read(FileStorage.ST_ABSPIELER, aName); |
|
115 |
if (entity instanceof Abspieler) { |
|
116 |
Abspieler abspieler = (Abspieler) entity; |
|
117 |
StringBuilder kmd = new StringBuilder(); |
|
118 |
kmd.append(abspieler.getUrl()); |
|
119 |
kmd.append(kommando); |
9e14ef
|
120 |
String signal = kmd.toString(); |
U |
121 |
abspielerKommandoSenden(signal); |
|
122 |
return signal + " gesendet."; |
589850
|
123 |
} else { |
U |
124 |
return meldung("Abspielliste nicht gefunden.", AbstractHandler.RTC_NOT_FOUND); |
|
125 |
} |
b56bb3
|
126 |
} |
U |
127 |
|
5f7e0b
|
128 |
private String ersterTitel(Storage s, String aName, String lName) { |
U |
129 |
String response; |
|
130 |
Entity entity = s.read(FileStorage.ST_ABSPIELLISTE, lName); |
|
131 |
if (entity instanceof Abspielliste) { |
|
132 |
Abspielliste liste = (Abspielliste) entity; |
|
133 |
response = listentitelSpielen(s, aName, liste, 0); |
|
134 |
} else { |
|
135 |
response = meldung("Abspielliste nicht gefunden.", AbstractHandler.RTC_NOT_FOUND); |
|
136 |
} |
|
137 |
return response; |
0e9cd3
|
138 |
} |
U |
139 |
|
|
140 |
private String naechsterTitel(Storage s, String abspielerName) { |
|
141 |
String response; |
|
142 |
Object o = spielt.get(abspielerName); |
|
143 |
if (o instanceof Abspielvorgang) { |
|
144 |
Abspielvorgang av = (Abspielvorgang) o; |
|
145 |
Entity entity = s.read(FileStorage.ST_ABSPIELLISTE, av.getListe()); |
|
146 |
if (entity instanceof Abspielliste) { |
b56bb3
|
147 |
Abspielliste liste = (Abspielliste) entity; |
0e9cd3
|
148 |
int titelNr = av.getTitelNr(); |
U |
149 |
if (liste.getTitel().size() > ++titelNr) { |
005d7a
|
150 |
response = listentitelSpielen(s, abspielerName, liste, titelNr); |
0e9cd3
|
151 |
} else { |
U |
152 |
response = "Liste " + liste.getName() + " ist zuende gespielt."; |
589850
|
153 |
logger.info(response); |
0e9cd3
|
154 |
} |
U |
155 |
} else { |
|
156 |
response = meldung("Abspielliste nicht gefunden.", AbstractHandler.RTC_NOT_FOUND); |
b56bb3
|
157 |
} |
0e9cd3
|
158 |
//response = listenTitelSpielen(e, elems[4]); |
U |
159 |
} else { |
|
160 |
response = meldung("Abspielvorgang fuer Abspieler " + abspielerName, AbstractHandler.RTC_NOT_FOUND); |
b56bb3
|
161 |
} |
U |
162 |
return response; |
|
163 |
} |
0e9cd3
|
164 |
|
005d7a
|
165 |
private String listentitelSpielen(Storage s, String aName, Abspielliste liste, int titelNr) { |
0e9cd3
|
166 |
String response; |
U |
167 |
Entity entity = s.read(FileStorage.ST_ABSPIELER, aName); |
|
168 |
if (entity instanceof Abspieler) { |
|
169 |
Abspieler abspieler = (Abspieler) entity; |
|
170 |
String kommando = kommandoFuerTitel(s, liste, abspieler, titelNr); |
|
171 |
//String kommando = kmd.toString(); |
|
172 |
logger.info(kommando); |
5f7e0b
|
173 |
abspielerKommandoSenden(kommando); |
0e9cd3
|
174 |
response = "Abspielen der Liste " + liste.getName() + " auf Abspieler " + aName + " gestartet."; |
U |
175 |
} else { |
|
176 |
response = meldung("Abspieler nicht gefunden.", AbstractHandler.RTC_NOT_FOUND); |
|
177 |
} |
|
178 |
return response; |
|
179 |
} |
|
180 |
|
|
181 |
/** |
|
182 |
* Das Kommando zum Abspielen fuer den Titel einer Abspielliste und einen bestimmten Abspieler |
|
183 |
* ermitteln. |
|
184 |
* |
|
185 |
* @param s die Ablage, in der Abspieler und Abspiellisten zu finden sind |
|
186 |
* @param liste Name der Liste, die den gewuenschten Titel enthaelt |
|
187 |
* @param abspieler Name des Abspielers, der zum Abspielen dienen soll |
|
188 |
* @param titelNr Nummer des Titels in der Liste |
|
189 |
* @return das Kommando zum Abspielen (ein URL) |
|
190 |
*/ |
|
191 |
private String kommandoFuerTitel(Storage s, Abspielliste liste, Abspieler abspieler, int titelNr) { |
|
192 |
// ersten Titel aus Liste holen |
|
193 |
Titel titel = liste.getTitel().get(titelNr); |
|
194 |
|
|
195 |
// URL des Titels ermitteln |
|
196 |
String titelUrl = titel.getKatalogUrl() + titel.getPfad() + titel.getName(); |
|
197 |
logger.log(Level.INFO, "abspielen von {0} auf {1}", new Object[]{titelUrl, abspieler.getUrl()}); |
|
198 |
|
|
199 |
// Titel als 'spielt' vermerken |
|
200 |
Abspielvorgang vorgang = new Abspielvorgang(); |
|
201 |
vorgang.setAbspieler(abspieler.getName()); |
|
202 |
vorgang.setListe(liste.getName()); |
|
203 |
vorgang.setTitelNr(titelNr); |
|
204 |
spielt.put(abspieler.getName(), vorgang); |
005d7a
|
205 |
|
U |
206 |
String server = getEinstellung(s, App.getRs(App.RB_HOST), DEFAULT_HOST); |
0e9cd3
|
207 |
|
U |
208 |
// Kommando an den Abspieler zusammenbauen |
|
209 |
StringBuilder kmd = new StringBuilder(); |
|
210 |
kmd.append(abspieler.getUrl()); |
|
211 |
kmd.append(PL_CMD_PLAY); |
|
212 |
// Parameter fuer den Abspieler holen |
005d7a
|
213 |
kmd.append(getEinstellung(s, App.getRs(App.RB_PLAYERPARAMS), PL_DEFAULT_PARAMS)); |
U |
214 |
kmd.append(server); |
0e9cd3
|
215 |
kmd.append(titelUrl); |
005d7a
|
216 |
kmd.append(PL_PARAM_RUECK); |
U |
217 |
kmd.append(server); |
|
218 |
kmd.append(PL_API_STRG); |
|
219 |
kmd.append(abspieler.getName()); |
|
220 |
kmd.append("/ende"); |
0e9cd3
|
221 |
|
U |
222 |
return kmd.toString(); |
|
223 |
} |
005d7a
|
224 |
|
U |
225 |
private String getEinstellung(Storage s, String key, String standardWert) { |
|
226 |
Entity entity = s.read(Einstellung.class.getSimpleName(), key); |
|
227 |
if (entity instanceof Einstellung) { |
|
228 |
Einstellung einstellung = (Einstellung) entity; |
|
229 |
Object o = einstellung.getValue(); |
|
230 |
if(o instanceof String) { |
|
231 |
return o.toString(); |
|
232 |
} else { |
|
233 |
return standardWert; |
|
234 |
} |
|
235 |
} else { |
|
236 |
return standardWert; |
|
237 |
} |
|
238 |
} |
|
239 |
|
|
240 |
private void abspielerKommandoSenden(String kommando) { |
|
241 |
/* |
|
242 |
TODO hier evtl. mit mehreren Versuchen ausgleichen, |
|
243 |
dass ein einzelner Versuch nicht 'durchkommt'... |
|
244 |
*/ |
|
245 |
logger.info(kommando); |
|
246 |
try { |
|
247 |
HttpURLConnection conn = (HttpURLConnection) new URL(kommando).openConnection(); |
|
248 |
conn.setRequestMethod("GET"); |
|
249 |
conn.connect(); |
|
250 |
int status = conn.getResponseCode(); |
|
251 |
String msg = conn.getResponseMessage(); |
|
252 |
logger.log(Level.INFO, "Kommando {0} mit Status {1} {2} gesendet.", new Object[]{kommando, status, msg}); |
|
253 |
} catch(IOException ex) { |
|
254 |
logger.log(Level.INFO, ex.getMessage(), ex); |
|
255 |
} |
|
256 |
} |
|
257 |
|
5f7e0b
|
258 |
private String meldung(String text, int code) { |
U |
259 |
setReturnCode(code); |
|
260 |
return text; |
|
261 |
} |
|
262 |
|
b56bb3
|
263 |
// rpi4-az:9090/avd/play?titel=/Filme/S/sound_city.m4v&th=60&ti=60&o=local |
U |
264 |
// aUrl http://rpi4-wz:9090/ |
|
265 |
// titelUrl /media/test/A/The-Alan-Parsons-Project/I-Robot/02-I-Wouldnt-Want-to-Be-Like-You.mp3 |
|
266 |
} |