!7

import static x30_pkg.x30_util.VF1;

cmodule AudioOutput > DynPrintLog {

  switchable int bufSize = 40960;

  switchable float gain = 1;

  switchable bool registerService;

  transient playAudioFromSampleMakingFunction_AudioLoop loop;

  transient L<VF1<double[]>> sources = notifyingList(r setNumSources);

  transient SimpleLiveValue<Int> numSources = new(Int, 0);

  visualize {

    ret centerAndSouth(super.visualize(),

      withLeftAndRightMargin(vstackWithSpacing(

        withLabel("Volume (0-200%):", liveSliderZeroToOne(gain/2, voidfunc(float f) { setField(gain := f*2) })),

        jrightalignedline(withLabel("Sound sources:", jLiveValueLabel(numSources)))

      )));

  }

  start {

    final VF1<VF1<double[]>> vfRemoveSource = voidfunc(VF1<double[]> source) {

      removeSource(source)

    };

    ownTimer(loop = playAudioFromSampleMakingFunction(bufSize, voidfunc(double[] pair) {

      audio_makeSampleFromSources(sources, pair, gain, vfRemoveSource)

    }));

    dm_registerAs audioOutputModule();

    if (registerService)

      dm_registerService('playWAVAndWait, func(S method, O[] args) -> bool {

        temp enter();

        callMC(f dm_playWAV, args);

        true;

      });

  }

  void setNumSources { numSources.set(l(sources)); }

  // hold audio sources during reload

  O _getReloadData() { ret sources; }

  void _setReloadData(L<VF1<double[]>> sources) { addAll(this.sources, sources); }

  // API

  void addSource(VF1<double[]> source) {

    sources.add(source);

    print("Audio source added.");

  }

  void removeSource(VF1<double[]> source) {

    sources.remove(source);

    print("Audio source removed.");

  }

  AudioFormat getAudioFormat() { ret loop.quality; }

  long samplesPlayed() { ret loop.samplesPlayed; }

}