--- /dev/null
+/**
+ * Copyright (c) 2010-2023 Contributors to the openHAB project
+ *
+ * See the NOTICE file(s) distributed with this work for additional
+ * information.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License 2.0 which is available at
+ * http://www.eclipse.org/legal/epl-2.0
+ *
+ * SPDX-License-Identifier: EPL-2.0
+ */
+package org.openhab.voice.mimic.internal;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.ArrayList;
+import java.util.List;
+
+import org.eclipse.jdt.annotation.NonNullByDefault;
+import org.openhab.core.audio.AudioException;
+import org.openhab.core.audio.AudioFormat;
+import org.openhab.core.audio.FileAudioStream;
+
+/**
+ * A FileAudioStream that autodelete after it and its clone are closed
+ * Useful to not congest temporary directory
+ *
+ * @author Gwendal Roulleau - Initial contribution
+ */
+@NonNullByDefault
+public class AutoDeleteFileAudioStream extends FileAudioStream {
+
+ private final File file;
+ private final AudioFormat audioFormat;
+ private final List<ClonedFileInputStream> clonedAudioStreams = new ArrayList<>(1);
+ private boolean isOpen = true;
+
+ public AutoDeleteFileAudioStream(File file, AudioFormat format) throws AudioException {
+ super(file, format);
+ this.file = file;
+ this.audioFormat = format;
+ }
+
+ @Override
+ public void close() throws IOException {
+ super.close();
+ this.isOpen = false;
+ deleteIfPossible();
+ }
+
+ protected void deleteIfPossible() {
+ boolean aClonedStreamIsOpen = clonedAudioStreams.stream().anyMatch(as -> as.isOpen);
+ if (!isOpen && !aClonedStreamIsOpen) {
+ file.delete();
+ }
+ }
+
+ @Override
+ public InputStream getClonedStream() throws AudioException {
+ ClonedFileInputStream clonedInputStream = new ClonedFileInputStream(this, file, audioFormat);
+ clonedAudioStreams.add(clonedInputStream);
+ return clonedInputStream;
+ }
+
+ private static class ClonedFileInputStream extends FileAudioStream {
+ protected boolean isOpen = true;
+ private final AutoDeleteFileAudioStream parent;
+
+ public ClonedFileInputStream(AutoDeleteFileAudioStream parent, File file, AudioFormat audioFormat)
+ throws AudioException {
+ super(file, audioFormat);
+ this.parent = parent;
+ }
+
+ @Override
+ public void close() throws IOException {
+ super.close();
+ this.isOpen = false;
+ parent.deleteIfPossible();
+ }
+ }
+}
*/
package org.openhab.voice.mimic.internal;
+import java.io.File;
import java.io.IOException;
+import java.io.InputStream;
+import java.io.UnsupportedEncodingException;
+import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
+import java.nio.file.Files;
+import java.nio.file.StandardCopyOption;
import java.util.HashSet;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.Set;
+import java.util.UUID;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import org.eclipse.jetty.client.util.StringContentProvider;
import org.eclipse.jetty.http.HttpHeader;
import org.eclipse.jetty.http.HttpStatus;
+import org.openhab.core.OpenHAB;
+import org.openhab.core.audio.AudioException;
import org.openhab.core.audio.AudioFormat;
import org.openhab.core.audio.AudioStream;
import org.openhab.core.config.core.ConfigurableService;
* Configuration parameters
*/
private static final String PARAM_URL = "url";
+ private static final String PARAM_WORKAROUNDSERVLETSINK = "workaroundServletSink";
private static final String PARAM_SPEAKINGRATE = "speakingRate";
private static final String PARAM_AUDIOVOLATITLITY = "audioVolatility";
private static final String PARAM_PHONEMEVOLATITLITY = "phonemeVolatility";
config.url = param.toString();
}
+ // workaround
+ param = newConfig.get(PARAM_WORKAROUNDSERVLETSINK);
+ if (param != null) {
+ config.workaroundServletSink = Boolean.parseBoolean(param.toString());
+ }
+
// audio volatility
try {
param = newConfig.get(PARAM_AUDIOVOLATITLITY);
throw new TTSException("The passed AudioFormat is unsupported");
}
- String ssml = "";
- if (text.startsWith("<speak>")) {
- ssml = "&ssml=true";
+ String encodedVoice;
+ try {
+ encodedVoice = URLEncoder.encode(((MimicVoice) voice).getTechnicalName(),
+ StandardCharsets.UTF_8.toString());
+ } catch (UnsupportedEncodingException e) {
+ throw new IllegalArgumentException("Cannot encode voice in URL " + ((MimicVoice) voice).getTechnicalName());
}
// create the url for given locale, format
- String urlTTS = config.url + SYNTHETIZE_URL + "?voice=" + ((MimicVoice) voice).getTechnicalName() + ssml
- + "&noiseScale=" + config.audioVolatility + "&noiseW=" + config.phonemeVolatility + "&lengthScale="
- + config.speakingRate + "&audioTarget=client";
+ String urlTTS = config.url + SYNTHETIZE_URL + "?voice=" + encodedVoice + "&noiseScale=" + config.audioVolatility
+ + "&noiseW=" + config.phonemeVolatility + "&lengthScale=" + config.speakingRate + "&audioTarget=client";
logger.debug("Querying mimic with URL {}", urlTTS);
// prepare the response as an inputstream
InputStreamResponseListener inputStreamResponseListener = new InputStreamResponseListener();
// we will use a POST method for the text
StringContentProvider textContentProvider = new StringContentProvider(text, StandardCharsets.UTF_8);
- httpClient.POST(urlTTS).content(textContentProvider).accept("audio/wav").send(inputStreamResponseListener);
+ if (text.startsWith("<speak>")) {
+ httpClient.POST(urlTTS).header("Content-Type", "application/ssml+xml").content(textContentProvider)
+ .accept("audio/wav").send(inputStreamResponseListener);
+ } else {
+ httpClient.POST(urlTTS).content(textContentProvider).accept("audio/wav").send(inputStreamResponseListener);
+ }
// compute the estimated timeout using a "stupid" method based on text length, as the response time depends on
// the requested text. Average speaker speed estimated to 10/second.
"Cannot get Content-Length header from mimic response. Are you sure to query a mimic TTS server at "
+ urlTTS + " ?");
}
- return new InputStreamAudioStream(inputStreamResponseListener.getInputStream(), AUDIO_FORMAT, length);
+
+ InputStream inputStreamFromMimic = inputStreamResponseListener.getInputStream();
+ try {
+ if (!config.workaroundServletSink) {
+ return new InputStreamAudioStream(inputStreamFromMimic, AUDIO_FORMAT, length);
+ } else {
+ // Some audio sinks use the openHAB servlet to get audio. This servlet require the
+ // getClonedStream()
+ // method
+ // So we cache the file on disk, thus implementing the method thanks to FileAudioStream.
+ return createTemporaryFile(inputStreamFromMimic, AUDIO_FORMAT);
+ }
+ } catch (TTSException e) {
+ try {
+ inputStreamFromMimic.close();
+ } catch (IOException e1) {
+ }
+ throw e;
+ }
+
} else {
String errorMessage = "Cannot get wav from mimic url " + urlTTS + " with HTTP response code "
+ response.getStatus() + " for reason " + response.getReason();
throw new TTSException(errorMessage, e);
}
}
+
+ private AudioStream createTemporaryFile(InputStream inputStream, AudioFormat audioFormat) throws TTSException {
+ File mimicDirectory = new File(OpenHAB.getUserDataFolder(), "mimic");
+ mimicDirectory.mkdir();
+ try {
+ File tempFile = File.createTempFile(UUID.randomUUID().toString(), ".wav", mimicDirectory);
+ tempFile.deleteOnExit();
+ Files.copy(inputStream, tempFile.toPath(), StandardCopyOption.REPLACE_EXISTING);
+ return new AutoDeleteFileAudioStream(tempFile, audioFormat);
+ } catch (AudioException | IOException e) {
+ throw new TTSException("Cannot create temporary audio file", e);
+ }
+ }
}
projects / openhab-addons.git / commitdiff