/* Mediazentrale - Personal Media Center Copyright (C) 2021 Ulrich Hilger This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details. You should have received a copy of the GNU Affero General Public License along with this program. If not, see . */ package de.uhilger.mediaz.api; import com.sun.net.httpserver.HttpExchange; import de.uhilger.mediaz.App; import de.uhilger.mediaz.Server; import de.uhilger.mediaz.entity.Abspielvorgang; import de.uhilger.mediaz.entity.Abspieler; import de.uhilger.mediaz.entity.Abspielliste; import de.uhilger.mediaz.entity.Einstellung; import de.uhilger.mediaz.entity.Entity; import de.uhilger.mediaz.entity.Titel; import de.uhilger.mediaz.store.FileStorage; import de.uhilger.mediaz.store.Storage; import java.util.HashMap; import java.util.Map; import java.util.logging.Level; import java.util.logging.Logger; /** * Die MediaSteuerung verarbeitet HTTP-Signale zur Steuerung von Media-Operationen wie z.B. dem * Spielen einer Abspielliste oder dem Starten oder Stoppen eines Videos auf einem entfernten * Abspielgeraet. * * 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 GET /mz/api/strg/abspieler/pause HTTP GET /mz/api/strg/abspieler/stop HTTP GET * /mz/api/strg/abspieler/weiter * * Faustregel: Anzahl Elemente eines URL plus 1 ist die Anzahl der Elemente des * Ergebnisses von String.split. * * * @author Ulrich Hilger * @version 1, 9.4.2021 */ public class MediaSteuerung extends AbstractHandler { private static final Logger logger = Logger.getLogger(MediaSteuerung.class.getName()); public static final String PL_CMD_PLAY = "avd/play"; public static final String PL_DEFAULT_PARAMS = "?titel="; public static final String PL_CMD_ENDE = "ende"; private final Map spielt = new HashMap(); @Override protected String get(HttpExchange e) { String response; String path = e.getRequestURI().toString(); String[] elems = path.split(Server.SLASH); FileStorage fs = new FileStorage(App.getInitParameter(App.getRs(App.RB_AP_CONF))); // Faustregel: Anzahl Elemente eines URL plus 1 ist die Anzahl der Elemente des // Ergebnisses von String.split. switch (elems.length) { case 6: if (elems[5].equalsIgnoreCase(PL_CMD_ENDE)) { response = naechsterTitel(fs, elems[4]); } else { response = meldung("Ungueltiges Kommando: " + elems[5], AbstractHandler.RTC_NOT_FOUND); } break; case 8: response = listenTitelSpielen(fs, elems[4], elems[7]); break; default: response = "Ungueltiger URL"; break; } return response; } private String meldung(String text, int code) { setReturnCode(code); return text; } private String naechsterTitel(Storage s, String abspielerName) { String response; Object o = spielt.get(abspielerName); if (o instanceof Abspielvorgang) { Abspielvorgang av = (Abspielvorgang) o; Entity entity = s.read(FileStorage.ST_ABSPIELLISTE, av.getListe()); if (entity instanceof Abspielliste) { Abspielliste liste = (Abspielliste) entity; int titelNr = av.getTitelNr(); if (liste.getTitel().size() > ++titelNr) { response = listenTitelSpielen(s, abspielerName, liste, titelNr); } else { response = "Liste " + liste.getName() + " ist zuende gespielt."; } } else { response = meldung("Abspielliste nicht gefunden.", AbstractHandler.RTC_NOT_FOUND); } //response = listenTitelSpielen(e, elems[4]); } else { response = meldung("Abspielvorgang fuer Abspieler " + abspielerName, AbstractHandler.RTC_NOT_FOUND); } return response; } private String listenTitelSpielen(Storage s, String aName, String lName) { String response; Entity entity = s.read(FileStorage.ST_ABSPIELLISTE, lName); if (entity instanceof Abspielliste) { Abspielliste liste = (Abspielliste) entity; response = listenTitelSpielen(s, aName, liste, 0); } else { response = meldung("Abspielliste nicht gefunden.", AbstractHandler.RTC_NOT_FOUND); } return response; } private String listenTitelSpielen(Storage s, String aName, Abspielliste liste, int titelNr) { String response; Entity entity = s.read(FileStorage.ST_ABSPIELER, aName); if (entity instanceof Abspieler) { Abspieler abspieler = (Abspieler) entity; String kommando = kommandoFuerTitel(s, liste, abspieler, titelNr); //String kommando = kmd.toString(); logger.info(kommando); response = "Abspielen der Liste " + liste.getName() + " auf Abspieler " + aName + " gestartet."; } else { response = meldung("Abspieler nicht gefunden.", AbstractHandler.RTC_NOT_FOUND); } return response; } /** * Das Kommando zum Abspielen fuer den Titel einer Abspielliste und einen bestimmten Abspieler * ermitteln. * * @param s die Ablage, in der Abspieler und Abspiellisten zu finden sind * @param liste Name der Liste, die den gewuenschten Titel enthaelt * @param abspieler Name des Abspielers, der zum Abspielen dienen soll * @param titelNr Nummer des Titels in der Liste * @return das Kommando zum Abspielen (ein URL) */ private String kommandoFuerTitel(Storage s, Abspielliste liste, Abspieler abspieler, int titelNr) { // ersten Titel aus Liste holen Titel titel = liste.getTitel().get(titelNr); // URL des Titels ermitteln String titelUrl = titel.getKatalogUrl() + titel.getPfad() + titel.getName(); logger.log(Level.INFO, "abspielen von {0} auf {1}", new Object[]{titelUrl, abspieler.getUrl()}); // Titel als 'spielt' vermerken Abspielvorgang vorgang = new Abspielvorgang(); vorgang.setAbspieler(abspieler.getName()); vorgang.setListe(liste.getName()); vorgang.setTitelNr(titelNr); spielt.put(abspieler.getName(), vorgang); // Kommando an den Abspieler zusammenbauen StringBuilder kmd = new StringBuilder(); kmd.append(abspieler.getUrl()); kmd.append(PL_CMD_PLAY); // Parameter fuer den Abspieler holen Entity entity = s.read(Einstellung.class.getSimpleName(), App.getRs(App.RB_PLAYERPARAMS)); if (entity instanceof Einstellung) { Einstellung einstellung = (Einstellung) entity; kmd.append(einstellung.getValue()); } else { kmd.append(PL_DEFAULT_PARAMS); } kmd.append(titelUrl); // hier noch Rueckmeldung anfuegen return kmd.toString(); } // rpi4-az:9090/avd/play?titel=/Filme/S/sound_city.m4v&th=60&ti=60&o=local // aUrl http://rpi4-wz:9090/ // titelUrl /media/test/A/The-Alan-Parsons-Project/I-Robot/02-I-Wouldnt-Want-to-Be-Like-You.mp3 }