!7

cmodule ConcurrentMP3 > DynPrintLogAndEnabled {
  transient StreamingMP3Encoder encoder;
  switchable int bitRate = 64;

  start {
    dm_vmBus_onMessage_q startedRecording((IVF1<File>) lambda1 started);
    dm_vmBus_onMessage_q recordedChunk((IVF1<short[]>) lambda1 gotChunk);
    dm_vmBus_onMessage_q doneRecording(r done);
  }
  
  void cleanMeUp { dispose encoder; }
  
  void started(File wavFileBeingMade) {
    if (!enabled) ret;
    File mp3 = changeExtension(wavFileBeingMade, ".live.mp3");
    float sampleRate = dm_audioInputSampleRate();
    int channels = dm_audioInputChannels();
    print("started MP3 encoding: " + mp3 + " at " + sampleRate + " Hz" + " (" + nChannels(channels) + ")");
    encoder = new StreamingMP3Encoder;
    encoder.mp3 = mp3;
    encoder.format = javaSound_pcmSignedLittleEndian(sampleRate, channels);
    encoder.bitRate = bitRate;
    encoder.init();
    vmBus_send startedRecordingMP3(mp3);
    encoder.onBytesWritten = (array, i, j) -> vmBus_send wroteMP3Chunk(mp3, array, i, j);
  }
  
  void gotChunk(short[] samples) {
    //print("got " + nSamples(samples));
    if (enabled && encoder != null) encoder.addData(samples);
  }
  
  void done {
    if (encoder == null) ret;
    File mp3 = encoder.mp3;
    dispose encoder;
    vmBus_send newMP3Recording(mp3);
    print("Wrote " + fileInfo(mp3));
  }
}