!7

import static x30_pkg.x30_util.VF1;

module ReceiveAudio > DynPrintLog {
  bool enabled;
  float gain = 0.5f;
  transient L<short[]> chunks = synchroLinkedList();
  transient int minChunksToPlay = 2;

  start {
    vmBus_onMessage('gotFromPrivateChat, voidfunc(S sender, S msg) {
      if (enabled && startsWith(msg, "audio:"))
        chunks.add(shortArrayFromBytes_littleEndian(base64decode(substring(msg, 6))));
    });

    dm_addSoundSource(new VF1<double[]>() {
      int sampleIndex;
      short[] samples;
      
      public void get(double[] pair) {
        pair[0] = pair[1] = 0;
        if (!enabled) ret;
        if (samples == null) {
          if (l(chunks) < minChunksToPlay) { minChunksToPlay = 2; ret; }
          minChunksToPlay = 1;
          samples = syncPopFirst(chunks);
          sampleIndex = 0;
        }
        pair[0] = samples[sampleIndex]*gain;
        pair[1] = samples[sampleIndex+1]*gain;
        sampleIndex += 2;
        if (sampleIndex >= l(samples)) samples = null;
      }
    });
  }
  
  visualize {
    ret centerAndSouth(super.visualize(),
      centerAndEast(
        withLabel("Volume (0-200%):", liveSliderZeroToOne(gain/2, voidfunc(float f) { setField(gain := f*2) })),
        main.onChange(dm_fieldCheckBox('enabled), r { if (!enabled) chunks.clear() })));
  }
}