TextToSpeech.java

Go to the documentation of this file.

package com.neuronrobotics.bowlerstudio;
 
import java.io.IOException;
import java.util.Collection;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.stream.Collectors;
import java.util.stream.StreamSupport;
 
import javax.sound.sampled.AudioInputStream;
 
import marytts.LocalMaryInterface;
import marytts.MaryInterface;
import marytts.exceptions.MaryConfigurationException;
import marytts.exceptions.SynthesisException;
import marytts.modules.synthesis.Voice;
import marytts.signalproc.effects.AudioEffect;
import marytts.signalproc.effects.AudioEffects;
 
public class TextToSpeech implements ITTSEngine{
    
    private AudioPlayer tts;
    private MaryInterface marytts;
 
    public TextToSpeech() {
        try {
            marytts = new LocalMaryInterface();
            
        } catch (MaryConfigurationException ex) {
            Logger.getLogger(getClass().getName()).log(Level.SEVERE, null, ex);
        }
    }
    
    //----------------------GENERAL METHODS---------------------------------------------------//
    
    public int speak(String text , float gainValue , boolean daemon , boolean join, ISpeakingProgress progress) {
        // Stop the previous player
        stopSpeaking();
        
        
        try (AudioInputStream audio = marytts.generateAudio(text)) {
            
            // Player is a thread(threads can only run one time) so it can be
            // used has to be initiated every time
            tts = new AudioPlayer(text);
            tts.setAudio(audio);
            tts.setGain(gainValue);
            tts.setDaemon(daemon);
            if(progress!=null)
                tts.setSpeakProgress(progress);
            tts.start();
            if (join)
                tts.join();
            return 0;
        } catch (SynthesisException ex) {
            Logger.getLogger(getClass().getName()).log(Level.WARNING, "Error saying phrase.", ex);
        } catch (IOException ex) {
            Logger.getLogger(getClass().getName()).log(Level.WARNING, "IO Exception", ex);
        } catch (InterruptedException ex) {
            Logger.getLogger(getClass().getName()).log(Level.WARNING, "Interrupted ", ex);
            System.out.println("Speaking clean exit");
            tts.cancel();
            tts.interrupt();
            return 1;
        }
        return 2;
    }
    
    public void stopSpeaking() {
        // Stop the previous player
        if (tts != null)
            tts.cancel();
    }
    
    //----------------------GETTERS---------------------------------------------------//
    
    public Collection<Voice> getAvailableVoices() {
        return Voice.getAvailableVoices();
    }
    
    public MaryInterface getMarytts() {
        return marytts;
    }
    
    public List<AudioEffect> getAudioEffects() {
        return StreamSupport.stream(AudioEffects.getEffects().spliterator(), false).collect(Collectors.toList());
    }
    
    //----------------------SETTERS---------------------------------------------------//
    
    public void setVoice(String voice) {
        marytts.setVoice(voice);
    }
    
}