!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; }
}