// speech libraries!
lib 1000722
lib 1000723
lib 1000724
lib 1000730
lib 1000731
lib 1000732
lib 1000726
lib 1000727

import javax.speech.*;
import javax.speech.synthesis.*;

static Lock kevin_lock = fairLock();

sbool kevin_debug, kevin_disable, kevin_verbose;
static Synthesizer kevin_synth;

static float kevin_volume = 1f;
static Float kevin_pitch, kevin_pitchRange, kevin_speakingRate;

public static S kevin(String text) ctex {
  kevin_lock.lock();
  if (kevin_verbose) print("Kevin: " + text);
  try {
    if (kevin_disable || kevin_synth != null && empty(trim(text))) return text;
    
    if (kevin_synth == null) {
      String voiceName = "kevin16";
    
      System.setProperty("FreeTTSSynthEngineCentral", "com.sun.speech.freetts.jsapi.FreeTTSEngineCentral");
      System.setProperty("freetts.voices", "com.sun.speech.freetts.en.us.cmu_us_kal.KevinVoiceDirectory");
      Central.registerEngineCentral("com.sun.speech.freetts.jsapi.FreeTTSEngineCentral");
  
      SynthesizerModeDesc desc = new SynthesizerModeDesc(null, "general", Locale.US, null, null);
  
      if (kevin_debug) print("Creating synth");
      Synthesizer synth = kevin_synth = Central.createSynthesizer(desc);
      synth.allocate();
      desc = (SynthesizerModeDesc) synth.getEngineModeDesc();
      Voice[] voices = desc.getVoices();
      Voice voice = null;
      for (Voice entry : voices) {
          if(entry.getName().equals(voiceName)) {
              voice = entry;
              break;
          }
      }
      if (kevin_debug) print("Voice: " + voice);
      synth.getSynthesizerProperties().setVoice(voice);
      synth.resume();
    }
    
    SynthesizerProperties props = kevin_synth.getSynthesizerProperties();
    props.setVolume(kevin_volume);
    if (kevin_pitch != null) props.setPitch(kevin_pitch);
    if (kevin_pitchRange != null) props.setPitchRange(kevin_pitchRange);
    if (kevin_speakingRate != null) props.setSpeakingRate(kevin_speakingRate);
    
    if (kevin_debug) print("Speaking...");
    logStructureWithDate(cereprocLog(), litorderedmap(action := "Begin talking", voice := "Kevin", +text));
    kevin_synth.speakPlainText(text, null);
    if (kevin_debug) print("Waiting");
    // TODO: We wait later anyway
    long state;
    int n = 0;
    while (((state = kevin_synth.getEngineState()) & Synthesizer.QUEUE_EMPTY) != 0) {
      sleep(50);
      if (++n >= 10000/50) {
        print("Engine state: " + state + ", aborting");
        break;
      }
    }
    
    //kevin_synth.waitEngineState(Synthesizer.QUEUE_EMPTY);
    if (kevin_debug) print("Done");
    logStructureWithDate(cereprocLog(), litorderedmap(action := "End talking", voice := "Kevin", +text));
    
    // keep synth for next time
    //kevin_synth.deallocate();
    
    ret text;
  } finally {
    kevin_lock.unlock();
  }
}

static void kevin_init() {
  kevin("");
}