!7

import static x30_pkg.x30_util.VF1;

module LiveVAD > DynPrintLog {

  volatile bool enabled = true;

  transient double windowSize = 1.0; // seconds

  transient Q q;

  transient new L<short[]> buffer;

  transient int bufferSize, neededSamples;

  transient VAD_1 vad;

  visualize {

    ret centerAndSouthWithMargins(super.visualize(),

      jrightalignedline(dm_fieldCheckBox('enabled)));

  }

  start {

    vad = filled_VAD_1();

    neededSamples = iround(windowSize*44100);

    q = dm_startQ();

    dm_addAudioListener(voidfunc(short[] data) {

      if (!enabled) ret;

      buffer.add(mixStereoShortArrayToMono(data));

      bufferSize += l(data)/2;

      if (bufferSize >= neededSamples) {

        bufferSize -= neededSamples;

        final L<short[]> salvaged = cloneList(buffer);

        buffer.clear();

        if (bufferSize > 0) {

          buffer.add(lastNShorts(bufferSize, last(salvaged)));

          replaceLastElement(salvaged, dropLastNShorts(bufferSize, last(salvaged)));

        }

        q.add(r {

          MultiShortArrayInputStream_resettable stream = new(salvaged);

          stream.bigEndian = true;

          Clip clip = spectro_clipFromMonoInputStream(stream);

          BWImage img = clipToFrequencyImage(clip);

          quickShowZoomedImage(img);

          print("VAD: " + callF(vad, img));

        });

      }

    });

  }  

}