!747

m {
  static new Flag done;
  static new Flag success;
  static int myPort, vmPort;
  
  static long lastRun;
  static boolean lastResult;

  static boolean keepVMAlive = false; // keep VM alive after test (set to false for production!)
  
  static S vmProgram = "#1001317";

  !include #1000915 // Flag
  
  p {
    myPort = makeAndroid3("Test Case Master Bot.").port;
    
    // Start Dependent VM
    nohupJavax(vmProgram.substring(1) + " " + myPort);
    sleep();
  }
  
  static void startTest() {
    thread {
      try {
        DialogIO io = talkTo("localhost", vmPort);
        print(io.readLine());
        
        io.sendLine("What is your process id?");
        S s = io.readLine();
        print("VM said: " + s);
        int pid = parseInt(s);
        print("PID: " + pid);
        
        if (!(pid != 0 && processIDExists("" + pid)))
          fail(s);
          
        io.sendLine("What is the main program id?");
        s = io.readLine();
        if (parseSnippetID(s) != parseSnippetID(vmProgram))
          fail(s);
        
        success.raise();
      } catch (Throwable e) {
        e.printStackTrace();
      }
      
      done.raise(); // so dependent VM exits
      
      lastRun = now(); saveLocally("lastRun");
      lastResult = success.isUp(); saveLocally("lastResult");
      print(success.isUp() ? "TEST SUCCESS" : "TEST FAILURE");
      
      sendTestResult(success.isUp());
    }
  }
  
  static synchronized S answer(S s, L<S> history) {
    new Matches m;
    
    if (match3("Master: My VM port is *", s, m)) {
      if (vmPort == 0) {
        vmPort = parseInt(unquote(m.m[0]));
        startTest();
      }
      return "OK";
    } if (match3("Master: Should I stay alive?", s))
      return !keepVMAlive && done.isUp() ? "No." : "Yes.";
    return null;
  }
}