package ca.bc.webarts.tools;
//import com.sun.speech.freetts.util.Utilities;

import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStreamReader;

import java.util.Calendar;
import java.util.GregorianCalendar;
import java.util.Locale;

import javax.speech.Central;
import javax.speech.Engine;
import javax.speech.EngineList;
import javax.speech.EngineException;
import javax.speech.synthesis.Synthesizer;
import javax.speech.synthesis.SynthesizerModeDesc;
import javax.speech.synthesis.SynthesizerProperties;
import javax.speech.synthesis.Voice;
//import com.sun.speech.freetts.util.Utilities;

import ca.bc.webarts.widgets.Util;


/**
 *  Simple program showing how to use the Limited Domain (time) FreeTTS
 *  synthesizer.
 *
 * @author    TGutwin
 */
public class JVoice implements Runnable
{

  private Synthesizer synthesizer;
  private boolean initialized_ = false;
  private static  boolean activeThread_ = false;
  private static JVoice singletonInstance= null;
  private static String [] textToRead_ = {""};
  private static boolean verboseOutput_ = true;


  /**
   *  Construct a default JVoice object. It creates the Limited Domain
   *  synthesizer.
   */
  private JVoice()
  {
    try
    {
      // Create a new SynthesizerModeDesc that will match the FreeTTS
      // Synthesizer.
      /*SynthesizerModeDesc desc = new SynthesizerModeDesc
          ("Limited domain FreeTTS Speech Synthesizer from Sun Labs",
           null,
           Locale.US,
           Boolean.FALSE,
           null);*/
      SynthesizerModeDesc desc = new SynthesizerModeDesc(
                null,          // engine name
                "general",     // mode name
                Locale.US,     // locale
                null,          // running
                null);         // voice
      synthesizer = Central.createSynthesizer(desc);

      if (synthesizer == null)
      {
        String message = "Can't find synthesizer.\n" +
            "Make sure that there is a \"speech.properties\" file " +
            "at either of these locations: \n";
        message += "user.home    : " +
            System.getProperty("user.home") + "\n";
        message += "java.home/lib: " + System.getProperty("java.home")
             + File.separator + "lib\n";

        System.err.println(message);
        initialized_ = false;
      }
      else
      {

        // create the voice
        String systemVoiceName = System.getProperty("voiceName", "kevin16");

        Voice systemVoice = new Voice(systemVoiceName, Voice.GENDER_DONT_CARE, Voice.AGE_DONT_CARE, null);

        // here are some other ones....
        Voice voiceLQ = new Voice("kevin", Voice.GENDER_DONT_CARE, Voice.AGE_DONT_CARE, null);
        Voice voiceHQ = new Voice("kevin16", Voice.GENDER_DONT_CARE, Voice.AGE_DONT_CARE, null);
        Voice voiceAlan = new Voice("alan", Voice.GENDER_DONT_CARE, Voice.AGE_DONT_CARE, null);

        // get it ready to speak
        synthesizer.allocate();
        synthesizer.waitEngineState(Synthesizer.ALLOCATED);
        synthesizer.resume();
        synthesizer.getSynthesizerProperties().setVoice(systemVoice);
        initialized_ = true;
      }
    }
    catch (Exception e)
    {
      e.printStackTrace();
    }
  }


  /** Gets the singleton for this class **/
  public static JVoice getInstance()
  {
    JVoice retVal = null;
    if (singletonInstance != null && singletonInstance.isInitialized())
      retVal = singletonInstance;
    else
    {
      // create a new one
      retVal = new JVoice();
    }
    return retVal;
  }


  /* Implements the Runnable by override run() method in interface */
  public void run()
  {
    activeThread_ = true;
    //System.out.println("JVoice Thread: run()");
    readText();
    activeThread_ = false;
  }


  /* waits until the read thread is done before returning */
  public void blockUntilDoneVoicing()
  {
    while (activeThread_)
      Util.sleep(500);
  }


  public void setTextToRead(String textToRead)
  {
    String [] txt = {textToRead};
    setTextToRead(txt);
  }


  public void setTextToRead(String[] textToRead)
  {
    textToRead_ = textToRead;
  }


  /* a simple helper to inform if this class singleton has been init. */
  public boolean isInitialized(){return initialized_;}


    /**
     * Example of how to list all the known voices for a specific
     * mode using just JSAPI.  FreeTTS maps the domain name to the
     * JSAPI mode name.  The currently supported domains are
     * "general," which means general purpose synthesis for tasks
     * such as reading e-mail, and "time" which means a domain that's
     * only good for speaking the time of day.
     */
    public static void listAllVoices(String modeName)
    {
        System.out.println();
        System.out.print(
            "All " + modeName + " Mode JSAPI Synthesizers and Voices ");

        /* Create a template that tells JSAPI what kind of speech
         * synthesizer we are interested in.  In this case, we're
         * just looking for a general domain synthesizer for US
         * English.
         */
        SynthesizerModeDesc required = new SynthesizerModeDesc(
            null,      // engine name
            modeName,  // mode name
            Locale.US, // locale
            null,      // running
            null);     // voices

        /* Contact the primary entry point for JSAPI, which is
         * the Central class, to discover what synthesizers are
         * available that match the template we defined above.
         */
        EngineList engineList = Central.availableSynthesizers(required);
        if(engineList!=null) System.out.println(" [" + engineList.size()  + "]");
        for (int i = 0; i < engineList.size(); i++) {

            SynthesizerModeDesc desc = (SynthesizerModeDesc) engineList.get(i);
            System.out.println("    " + desc.getEngineName()
                               + " (mode=" + desc.getModeName()
                               + ", locale=" + desc.getLocale() + "):");
            Voice[] voices = desc.getVoices();
            for (int j = 0; j < voices.length; j++) {
                System.out.println("        " + voices[j].getName());
            }
        }
    }


  /** some simple test routines. **/
  private static void runTests(String[] argv)
  {
    listAllVoices("general");
    if (argv!= null && argv.length >1)
    {
      try
      {
        String sentence = "";
        JVoice jVoice = JVoice.getInstance();

        for (int i=1; i <argv.length; i++)
          sentence += argv[i]+" ";
        if (jVoice.isInitialized())
        {
          jVoice.readText("J-Voice Test 1:");
          jVoice.readText(sentence);
          //jVoice.close();
        }
        jVoice = JVoice.getInstance();
        if (jVoice.isInitialized())
        {
          jVoice.readText("J-Voice Test 2:");
          jVoice.readText(sentence);
          //jVoice.close();
        }
        jVoice.close();
      }
      catch (Exception e)
      {
        e.printStackTrace();
      }
    }
  }

  /**
   *  The main program for the JVoice class
   *
   * @param  argv  The command line arguments
   */
  public static void main(String[] argv)
  {
    if (argv!= null && argv.length >0 && argv[0].equals("test"))
    {
      // Run Some tests
      System.out.println("JVoice: Test Mode.");
      JVoice jVoice = JVoice.getInstance();
      jVoice.runTests(argv);
    }
    else
    {
      try
      {
        if (verboseOutput_)
          System.out.println("JVoice: Voicing a Sentence.");
        String sentence = "";
        for (int i=0; i <argv.length; i++)
          sentence += argv[i]+" ";
        JVoice jVoice = JVoice.getInstance();
        if (jVoice.isInitialized())
        {
          try
          {
            if (verboseOutput_)
              System.out.println("JVoice: Start " + sentence);
            jVoice.setTextToRead(argv);
            (new Thread(jVoice)).start();
            jVoice.activeThread_ = true;
            while (jVoice.activeThread_)
              Util.sleep(500);
            //jVoice.readText(sentence);
            jVoice.close();
          }
          catch (Exception ex)
          {
            if (jVoice != null)
              jVoice.close();
            ex.printStackTrace();
          }
        }
        else
          System.out.println("JVoice: Can't Initialize Speech Engine");
        jVoice = null;
      }
      catch (Exception e)
      {
        e.printStackTrace();
      }
    }

    System.exit(0);
  }


  /**
   *  Reads the text in this class's textToRead_ field.
   *
   */
  synchronized public void readText()
  {
    if (textToRead_ != null && textToRead_.length > 0)
    {
      String sentence = "";
      for (int i=0; i <textToRead_.length; i++)
        sentence += textToRead_[i]+" ";
      readText(sentence);
    }
  }


  /**
   *  Reads an array of Strings.
   *
   * @param  theTextArray  An Array of Strings to read.
   */
  synchronized public void readText(String [] theTextArray)
  {
    if (theTextArray != null && theTextArray.length > 0)
    {
       textToRead_ = theTextArray;
       readText();
    }
  }


  /**
   *  Reads text from the console and gives it to the synthesizer to speak.
   *
   * @param  theText  Description of the Parameter
   */
  synchronized public void readText(String theText)
  {
    if (synthesizer != null && initialized_)
    {
      if (verboseOutput_)
        System.out.println("JVoice: Attempting to read the following sentence:");

      if (theText != null && !(theText.equals("")))
      {
        if (verboseOutput_)
          System.out.print("   "+ theText);
        synthesizer.speakPlainText(theText, null);
        if (verboseOutput_)
          System.out.println("   !");
      }

      try
      {
        // wait 'till speaking is done
        //System.out.println("JVoice: Waiting for the QUEUE to empty before proceeding");
        synthesizer.waitEngineState(Synthesizer.QUEUE_EMPTY);
        //System.out.println("! Done");
      }
      catch (java.lang.InterruptedException ie)
      {
        System.out.println("JVoice: readText(String): Interupted: " + ie);
      }
    }
    else
    {
      System.out.println("JVoice: NOT Initialized");
    }
  }


  /**  Closes things down  */
  public void close()
  {
    //System.out.println("JVoice: close(): synthesizer==null ->"+ (synthesizer==null));
    if (synthesizer != null)
    {
      try
      {
        try
        {
          // wait till speaking is done
          synthesizer.waitEngineState(Synthesizer.QUEUE_EMPTY);
        }
        catch (java.lang.InterruptedException ie)
        {
          System.out.println("JVoice: close(): Interupted: " + ie);
        }
        synthesizer.deallocate();
        synthesizer = null;
        this.initialized_ = false;
      }
      catch (EngineException ee)
      {
        System.out.println("JVoice: close(): Trouble deallocating synthesizer: " + ee);
      }
      catch (Exception e)
      {
        e.printStackTrace();
      }
    }
  }
}