!7

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 {

  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);

  }

  doEvery(1.0,r {

    if (connectToServer_anyConnected(senders) != connected) {

      connected = !connected;

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

    }

  });

}

svoid cleanMeUp {

  dispose senders;

}

svoid say(S s) {

  print("> " + s);

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

}