!7

// TODO: better cleanup

set flag Android. set flag NoAWT.

import android.media.*;

import android.content.*;

static int bufferSize = 8192;

static int maxAudioQueueSize = 50;

// raspi home, X20

static LS ips = ll("192.168.2.165", "192.168.43.244");

static AudioManager am;

static AudioRecord recorder;

static new L<StefansOS_ConnectToServer> senders;

static new L<Q> qSendAudio;

static new Q qVoiceOut;

static bool connected;

p {

  am = (AudioManager) androidContext().getSystemService(Context.AUDIO_SERVICE);

  printStreamInfos();

  androidSay_keepEngine = true;

  //set androidSay_keepEngine_verbose;

  set androidSay_keepEngine_inCall;

  for (S ip : ips) {

    print("Connecting to " + ip);

    new StefansOS_ConnectToServer sender;

    sender.server = ip;

    sender.onLine = voidfunc(S s) {

      final new Matches m;

      if (startsWith_trim(s, "voiceOutput:", m))

        say(m.rest());

    };

    sender.tryToConnect = () -> !connectToServer_anyConnected(senders);

    sender.startWithSubs("voiceOutput");

    senders.add(sender);

    qSendAudio.add(new Q);

  }

  BroadcastReceiver brr = new {

    @Override

    public void onReceive(Context context, Intent intent) {

      int state = intent.getIntExtra(AudioManager.EXTRA_SCO_AUDIO_STATE,-1);

      print(+state);

      if (AudioManager.SCO_AUDIO_STATE_CONNECTED == state) {

        print("Bluetooth Connected");

        androidContext().unregisterReceiver(this);

        printStreamInfos();

        thread { startRecording(); }

      }

    }

  };

  androidContext().registerReceiver(brr, new IntentFilter(AudioManager.ACTION_SCO_AUDIO_STATE_UPDATED));

  print("Starting Bluetooth");

  //am.setStreamSolo(AudioManager.MODE_IN_CALL, true);

  am.setBluetoothScoOn(true);

  //am.setMode(AudioManager.MODE_IN_CALL);

  am.startBluetoothSco();

  print("Can BT record from mic? " + am.isBluetoothScoAvailableOffCall());

}

svoid startRecording {

  print("Making recorder");

  recorder = new AudioRecord.Builder()

    .setAudioSource(

      //MediaRecorder.AudioSource.VOICE_COMMUNICATION

      MediaRecorder.AudioSource.MIC

    )

    .setAudioFormat(new AudioFormat.Builder()

      .setEncoding(AudioFormat.ENCODING_PCM_16BIT)

      .setSampleRate(16000)

      .setChannelMask(AudioFormat.CHANNEL_IN_MONO)

      .build())

   .setBufferSizeInBytes(bufferSize)

   .build();

  print("Made recorder");

  recorder.startRecording();

  print("Started recording");

  byte[] buf = new[bufferSize];

  while licensed {

    int n = recorder.read(buf, 0, l(buf), AudioRecord.READ_BLOCKING);

    //printWithTime("Read bytes: " + n);

    fS line = "audio: " + base64(buf);

    for i over qSendAudio: {

      final Q q = qSendAudio.get(i);

      final StefansOS_ConnectToServer sender = senders.get(i);

      if (!sender.connected()) continue;

      addToQWithMaxSize(maxAudioQueueSize, q, r {

        sender.sendLine(line)

      });

    }

    if (connectToServer_anyConnected(senders) != connected) {

      connected = !connected;

      say(connected ? "Connected" : "Lost connection");

    }

  }

  /*recorder.release();

  print("Released recorder");*/

}

svoid cleanMeUp {

  if (recorder != null) recorder.release();

  dispose senders;

}

svoid printStreamInfos {

  print("Stream muted: " + am.isStreamMute(AudioManager.STREAM_MUSIC) + ", vol: " + am.getStreamVolume(AudioManager.STREAM_MUSIC));

}

svoid say(S s) {

  print("> " + s);

  addToQWithMaxSize_verbose(5, +qVoiceOut, r { androidSayInEnglish(s); });

}