!7

static JButton button;
static volatile Capturer cap;
static File wavFile;
static Q recognizerQueue;
static StreamSpeechRecognizer2 recognizer;

p-substance {
  showControls(jCenteredLine(button = jbutton("Record!", f recordOrStop)));
  recognizerQueue = new Q("Recognizer Queue", true);
  recognizerQueue.add(r {
    infoBox("Loading engine...");
    recognizer = new StreamSpeechRecognizer2(makeSphinxConfig());
    infoBox("Engine loaded!");
  });
}

svoid recordOrStop {
  if (cap != null) {
    cap.stop();
    byte[] pcm = cap.getPCM();
    infoMessage("Got " + l(pcm) + " bytes PCM!");
    pcmToWAVE(pcm, cap.format(), wavFile);
    infoBox("Wrote " + f2s(wavFile) + " (" + wavFile.length() + " bytes)");
    cap = null;
    setText(button, "Record!");
    recognizeAudio(wavFile);
  } else {
    AudioLine line = first(allTargetDataLines());
    assertNotNull("Need audio input line!", line);
    DataLine dataLine = cast line.open();
    print("Capturing");
    wavFile = prepareProgramFile(ymd_minus_hms() + ".wav");
    cap = captureAudioFromLine2(dataLine, sphinxAudioFormat());
    setText(button, "Stop");
  }
}

svoid recognizeAudio(final File wavFile) {
  recognizerQueue.add(r {
    loading {
      recognizer.startRecognition(new FileInputStream(wavFile));
      SpeechResult result;
      print("Recognizing audio...");
      S line = null;
      while ((result = recognizer.getResult()) != null) {
        line = result.getHypothesis();
        print("  Hypothesis: " + line);
      }
      print("Done recognizing");
      infoBox("You said: " + line);
      recognizer.stopRecognition();
    }
  });
}