!7

cmodule RunVectorSDK > DynPrintLogAndEnabled {
  transient Process process;
  transient PrintStream out;
  S toSay;
  
  start-thread {
    dm_reloadOnFieldChange enabled();
    if (!enabled) ret;
    //File script = userDir("vector-sdk/cam-stream-to-stdout.py");
    File script = userDir("vector-sdk/control-from-java.py");
    assertFileExists(script);
    makeExecutable(script);

    print("Calling " + script);
    process = Runtime.getRuntime().exec(platformQuoteOpt(script));
    print("SDK process started");
    print("PID: " + getOpt(process, "pid"));
  
    drainErrorStreamToConsole(process, line -> enabled, lambda0 enter);
    out = new PrintStream(process.getOutputStream());
    
    DataInputStream in = new(process.getInputStream());
    S line;
    while ((line = in.readLine()) != null) {
      if (enabled)
        print("Got line: " + takeFirst(100, line));
    }
  }

  void cleanMeUp_process {
    if (process != null) {
      print("Stopping SDK process");
      process.destroy/*Forcibly*/();
      print("Stopped SDK process, hopefully");
    }
  }
  
  visual centerAndSouthWithMargin(super, withMargin(
    dm_textFieldAndSubmit_q toSay(r { say(toSay) }, buttonText := "Say")));

  // API

  // returns true if (probably) successful
  bool say(S s) {
    if (out == null) false;
    s = newLinesToSpaces_trim(s);
    if (empty(s)) true;
    print("Making Vector say: " + s);
    out.println(s);
    out.flush();
    true;
  }
}