!7

import javax.sound.sampled.*;

cmodule AudioInputFromPhone > DynPrintLog {
  switchable int sampleRate = 16000;
  switchable int channels = 1;
  switchable int bufSize = 8192;
  switchable bool sendOutClonedData; // makes things easier for clients
  switchable bool verbose;
  transient AudioInputDispatcher loop;
  transient SimpleLiveValue<Float> lvVolume = floatLiveValue(); // in percent
  transient L<VF1<short[]>> audioListeners = synchroList();
  
  visual centerAndSouthWithMargins(super.visualize(),
    jCenteredLine(jLiveValueLabel(mapLiveValue(func(float volume) -> S { "Volume: " + iround(volume) + " %" }, S, lvVolume))));

  start {
    loop = new AudioInputDispatcher(bufSize);
    loop.audioListeners = audioListeners;
    loop.lvVolume = lvVolume;
    loop.verbose = verbose;
    dm_watchFieldAndNow sendOutClonedData(() -> { loop.cloneDataOnce = sendOutClonedData; });
    dm_vmBus_onMessage oic_gotLine(voidfunc(O module, S line, O socket, O state) enter {
      if (startsWith(line, "audio: ")) {
        //print("Have audio line");
        byte[] data = base64decode(substring(line, l("audio: ")));
        dm_q(r {
          loop.handleData(data);
        });
      }
    });
    dm_registerAs audioInputModule();
    JComponent trayIcon = jMinWidth(16, jVerticalGreenBar(lvVolume, max := 100));
    componentPopupMenuItem(trayIcon, "Audio Input", r { dm_showModule(module()) });
    dm_setTrayIcon(trayIcon);
  }
  
  // hold audio listeners during reload
  
  O _getReloadData() { ret audioListeners; }
  void _setReloadData(L<VF1<short[]>> listeners) { addAll(audioListeners, listeners); }

  // API
  
  void addAudioListener(VF1<short[]> l) { audioListeners.add(l); }
  void removeAudioListener(VF1<short[]> l) { audioListeners.remove(l); }
  
  AudioFormat getAudioFormat() { ret new AudioFormat(AudioFormat.Encoding.PCM_SIGNED, sampleRate, 16, channels, channels*2, sampleRate, false); }
  
  float getVolume() { ret lvVolume!; }
  
  // for debugging
  O currentListener() { ret loop.currentListener; }
}