lib 1400149 // java-lame
static LS _stickyLibs_StreamingMP3Encoder = ll(#1400149);

import net.sourceforge.lame.lowlevel.*;
import net.sourceforge.lame.mp3.MPEGMode;

sclass StreamingMP3Encoder implements AutoCloseable {
  File mp3;
  OutputStream out;
  byte[] outBuffer;
  LameEncoder encoder;
  IVF3<byte[], Int, Int> onBytesWritten;
  AudioFormat format;
  int bitRate = 128;
  int quality = LameEncoder.DEFAULT_QUALITY;
  bool vbr;
  
  *() {}
  
  *(File mp3, float sampleRate) {
    this(mp3, javaSound_pcmSignedLittleEndianMono(sampleRate));
  }

  *(File *mp3, AudioFormat *format) {
    init();
  }
  
  void init ctex {
    MPEGMode channelMode = format.getChannels() == 1 ? MPEGMode.MONO : MPEGMode.JOINT_STEREO;
    encoder = new LameEncoder(format,
      bitRate,
      channelMode, quality, vbr);
    outBuffer = new byte[encoder.getPCMBufferSize()];
    out = newFileOutputStream(mp3);
  }
  
  public void close { encoder.close(); dispose out; }
  
  void addData(short[] samples) ctex {
    byte[] pcm = byteArrayFromShorts_littleEndian(samples);
    int bytesToTransfer = min(l(outBuffer), l(pcm)), bytesWritten;
    int iPCM = 0;
    while (0 < (bytesWritten = encoder.encodeBuffer(pcm, iPCM, bytesToTransfer, outBuffer))) {
      iPCM += bytesToTransfer;
      bytesToTransfer = min(l(outBuffer), l(pcm) - iPCM);
      callF(onBytesWritten, outBuffer, 0, bytesWritten);
      out.write(outBuffer, 0, bytesWritten);
    }
  }
}