// The Runner!

!7

static JFrame frame;
static JList list;
static JTextField tfCmd;
static JLabel status;
static JButton btnReload, btnRun, btnClear;
static S submittedInput;
static JCheckBox cbPrograms;
static TrayIcon trayIcon;
static volatile boolean searching;
static long lastSearch; // time of last search
static bool first; // first of its kind

static JTable lastRunTable;
static ReliableSingleThread thread_lastRun;

static S menuSnippet = #1000880;
static S menuScript;
//sS bigIcon = #1101166, smallIcon = #1101181; // the cat
//sS bigIcon = #1101182, smallIcon = #1101184; // cupid/dizzy cat
  // #1101168 // sitting cat
  // #1003596
sS bigIcon = #1101246, smallIcon = #1101184;

static int searchDelay = 100;
static int maxResults = 100;
static int autoResearchInterval = 30000; // 30 secs
static int topTenLookBack = 100; // look at last 100 program runs

static L<S> actionHistory = synchroList();

!include #1001372 // direct nohupJavax

p {
  try {
    new JFrame().dispose();
  } catch {
    System.out.println("We're headless...");
    // TODO: Something useful.
    System.exit(0);
  }

  awtMain();
}

svoid awtMain {
  becomeBotVMIfFirst();
  autoRestart10Mins();
  //mistAqua();
  //magellan();
  //gemini();
  //emeraldDusk();
  //mistSilver();
  //substanceLAF("Raven");
  //substanceLAF("OfficeSilver2007");
  //substanceLAF("OfficeBlue2007");
  //substanceLAF("OfficeBlack2007");
  substanceLAF("Sahara");
  
  print("First-check.");
  first = empty(sendToAll("JavaX Starter.", "activate"));
  print("  ==> " + first);
    
  swing {
    frame = showFrame();
    moveFrameAround(frame);
  }
  
  updateTitle();
  makeAndroid3("JavaX Starter.");
  
  setFrameIconLater(frame, bigIcon); 
  
  // Show the rays
  // disposeWindowOnClick(showAnimation("#1003828", 3.5));
  
  swing {
    list = new JList;
  
    new PopupMenuHelper {
      void fillMenu() {
        try {
          if (menuScript == null)
            menuScript = loadSnippet(menuSnippet);
            
          JMenuItem mi;
          int idx = list.locationToIndex(point);
          final String item = cast list.getModel().getElementAt(idx);
          list.setSelectedIndex(idx);
          
          L<S> tok = javaTok(menuScript);
          for (int i = 1; i+6 < tok.size(); i += 2)
            if (tok.get(i+2).equals("=") && tok.get(i+4).equals("#")) {
              final S snip = unquote(tok.get(i+6));
              S text = unquote(tok.get(i));
              mi = new JMenuItem(text);
              mi.addActionListener(actionListener {
                runCustom(snip, item);
              });
              menu.add(mi);
            }
        } catch (Throwable e) {
          popup(e);
        }
      }
    }.install(list);
  
    // install double click listener on list    
    onDoubleClick(list, voidfunc(S item) {
      if (nempty(item))
        runCustom("", item);
    });
    
    // install enter key listener on list
    
    onEnter(list, f runSelected);
  
    final ActionListener go = actionListener {
      tfCmd.selectAll();
      search(true);
    };
   
    btnReload = new JButton(isWindows() ? "Reload" : "\u27F3");
    btnReload.setToolTipText("Search again (if our " + autoResearchInterval/1000 + "s update interval is not enough for you)");
    btnReload.addActionListener(go);
  
    btnClear = new JButton("X");
    btnClear.setToolTipText("Show latest");
    btnClear.addActionListener(actionListener { tfCmd.setText(""); });
  
    tfCmd = new JTextField;
    
    cbPrograms = new JCheckBox("Programs", true);
    cbPrograms.setToolTipText("Show only runnable programs (not random text snippets)");
    cbPrograms.addActionListener(go);
    
    JPanel controls = jflow(btnClear, cbPrograms, btnReload);
  
    JPanel north = centerAndEast(
       withLabel("Search term:", tfCmd),
       controls);
    
    btnRun = jbutton("Run", r { main.runSelected() });
    listDependButton(list, btnRun);
    
    status = new JLabel(" ");
    JPanel searchPanel = northCenterAndSouth(north, list,
      centerAndEast(status, btnRun));
  
    tfCmd.addActionListener(go);
    
    frame.addWindowListener(new WindowAdapter() {
      public void windowOpened(WindowEvent e) {
        tfCmd.requestFocus();
      }
      
      public void windowClosing(WindowEvent e) {
        frame.setVisible(false);
      }
      
      public void windowActivated(WindowEvent e) {
        search(false);
      }
    }); 
    
    installTimer(tfCmd, new Runnable() {
      String lastContents;
      boolean autoSearchOn = true;
      
      public void run() {
        updateTitle();
        String text = getInput();
        if (text.equals(lastContents)) {
          if (
            isFocusedWindow(frame) && now() > lastSearch + autoResearchInterval
            
          || (!text.equals(submittedInput) && autoSearchOn && !searching))
            search(false);
        } else
          lastContents = text;
      }
    }, searchDelay);
    
    lastRunTable = sexyTableWithoutDrag();
    onDoubleClickOrEnter(lastRunTable, voidfunc(Int row) {
      Map map = getTableLineAsMap(lastRunTable, row);
      S id = getString(map, "Program ID");
      S args = getString(map, "Arguments");
      runCustom("", id + " " + args);
    });
    
    thread_lastRun = new ReliableSingleThread(r { lastRunTable_update(lastRunTable) });
    thread_lastRun.go();
    
    JTable injectionsTable = jInjectionsTable();
    
    frame.add(jRightTabs("Search", searchPanel, "Last Run Programs", tableWithSearcher(lastRunTable), "Running", injectionsTable));
    frame.setBounds(100, 100, 500, 400);
    frame.setVisible(true);
    frame.setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);
    hideFrameOnMinimize(frame);
    
    addMenu(frame, "Starter",
      "Show Talk Program [Eleutheria]", r { talkProgram() },
      "Your Computer ID: " + computerID(), r {},
      "Update JavaX", r { nohupJavax(#1001639) },
      "Log in", r { nohupJavax(#1000896) },
      "Exit", r-thread { cleanKill() });
      
    thread { addAISuiteMenu(frame, "AI"); }
    
    if (first)
      trayIcon = installTrayIcon("JavaX!", smallIcon, trayPopupMenuItems());
    
    thread "Updating Menu every 10 minutes" {
      sleepMinutes(10);
      while (licensed()) {
        pcall {
          print("Updating menu.");
          updateMenu();
        }
        sleepMinutes(10);
      }
    }
  
    onUserUtterance(voidfunc(S s) { setTextSelectAll(tfCmd, s); search(false); });
    
    if (myVMPort() == 5000)
      /*if (isStefanReichsPC()) // isMultiCore()
        thread "Warming Up Java" {
          loading "Warming Up Java" { warmUpJavaCompiler(20); }
        }*/
    
    hideConsole();
    
    thread "Start Bots" {
      startInternetTrafficCountBot();
      startVMLister_onChange = r {
        L<startVMLister_Data> hidden = startVMLister_hiddenVMs();
        trayIcon.setToolTip("JavaX: " 
          + n(startVMLister_numVMs(), "VM")
          + (empty(hidden) ? "" : " (" + l(hidden) + " hidden)"));
        updateMenu();
      };
      
      if (startVMLister())
        doEvery(60000, f startVMLister_scan);
        
      startBotHere("Compiler Bot", #1007916);
      
      // TODO: restart these bots if multiple runners are started
      // and exited in unfortunate order
    }
  } // swing
  
  search(false);
}

svoid updateTitle {
  S title = "JavaX Starter v3";
  if (isOfflineMode()) title += " [OFFLINE MODE]";
  setFrameTitle(frame, title);
}

svoid updateMenu {
  updateTitle();
  trayIcon.setPopupMenu(makePopupMenu(dropFirst(trayPopupMenuItems())));
}

static O[] trayPopupMenuItems() {
  new L topTenItems;
  pcall {
    L<S> calls = programTopTenWithArgs(topTenLookBack).getTopTen();
    new HashSet<S> ids;
    for (S s : calls)
      ids.add(onlyUntilSpace(s));
    Map<S, S> titles = getSnippetTitles(asList(ids));
    
    for (final S call : calls) {
      S id = onlyUntilSpace(call);
      topTenItems.add(menuItem(id + " [" + lookupSnippetID(titles, id) + "]" + (eq(id, call) ? "" : " " + trim(dropPrefix(id, call))),
        r { runProgram(call); }));
    }
  }
  
  //Menu catMenu = new Menu("Cat (Personal Voice Assistant)");
  //catMenu.add(menuItem("Start Listening", f cat_startListening));
  //catMenu.add(menuItem("Stop Listening", f cat_stopListening));
  
  new L hiddenVMItems;
  L<startVMLister_Data> hiddenVMs = startVMLister_hiddenVMs();
  if (nempty(hiddenVMs)) {
    hiddenVMItems.add("***");
    int i = 0;
    for (final startVMLister_Data vm : hiddenVMs) {
      Menu subMenu = new("Hidden VM " + ++i);
      addMenuItem(subMenu, "Kill", r { killVM(vm.port) }); // TODO: use VM ID
      addMenuItem(subMenu, "Restart", r { restartVM(vm.port) });
      addMenuItem(subMenu, "Show Console", r { send(vm.port, "show console") });
      hiddenVMItems.add(subMenu);
    }
  }
    
  ret flattenArray(
    r { bringUpFrame(); }, // on left click
    toObjectArray(topTenItems),
    toObjectArray(hiddenVMItems),
    "***",
    menuItem("Start Listening", f cat_startListening),
    menuItem("Stop Listening", f cat_stopListening),
    menuItem("Show JavaX Starter", f bringUpFrame),
    menuItem("Show Console", f showConsole),
    menuItem("Show All Consoles", f showAllConsoles),
    menuItem("Restart JavaX Starter", f restart),
    menuItem("Show Talk Program [Eleutheria]", f talkProgram),
    //menuItem("Hide Console", f hideConsole),
    isOfflineMode()
      ? menuItem("Switch to online mode", r { goOnlineMode(); updateMenu(); })
      : menuItem("Switch to offline mode", r { goOfflineMode(); updateMenu(); }),
    menuItem("Update JavaX", r { nohupJavax(#1001639) }),
    menuItem("Exit", r { System.exit(0); }));
}

static S getInput() {
  ret tfCmd.getText().trim();
}

static void search(S cmd, final boolean requestFocus) ctex {
  searching = true;
  try {
    status("Searching " + quote(cmd) + "...");
    if (empty(cmd)) cmd = "_";
    if (cbPrograms.isSelected())
      cmd += " type:runnable-desktop";
    fL<Snippet> snippets = tbSearch_url(tb_mainServer() + "/tb/search.php?q=" + urlencode(cmd) + "&limit=" + maxResults + "&sort=modified&quick=1" + standardCredentials());

    final new DefaultListModel model;
    for (Snippet s : snippets)
      model.addElement(fsI(s.id) + " - " + s.title);

    fS _cmd = cmd;

    awt {
      list.setModel(model);
      status("Found " + model.size() + (model.size() == maxResults ? "+" : "") + (cbPrograms.isSelected() ? " runnable(s)." : " snippet(s)."));
      if (requestFocus)
        tfCmd.requestFocus();
      saveTextFile(programFile("search-results.txt"), struct(litmap(date := now(), query := _cmd, results := snippets)));
    }
  } finally {
    searching = false;
  }
}

static void status(final S s) {
  awt { status.setText(s); }
}

static void runProgram(final S cmd) {
  print("Running " + cmd);
  S msg = format3("*: Running *", now(), cmd);
  actionHistory.add(msg);
  logQuoted("run.log", msg);
  awtLater(1000, r { thread_lastRun.go() });
  
  thread { // new thread so we can see progress messages, e.g. for loading the JavaX jar
    nohupJavax(cmd);
  }
}

static void runHotwired(final S worker, final long id) {
  print("Hotwiring " + worker + " on " + id);
  S msg = format3("*: Hotwiring * on *", now(), worker, id);
  actionHistory.add(msg);
  logQuoted("run.log", msg);
  
  thread {
    _run(worker, new S[] {str(id)}); // TODO: cache code?
  }
}

static void runCustom(S worker, S item) {
  if (item == null) ret;
  int i = item.indexOf(' ');
  if (i >= 0) item = item.substring(0, i);
  long id = parseSnippetID(item);
  print("runCustom: " + id + " [" + worker + "]");
  if (empty(worker))
    runProgram(str(id));
  else
    runHotwired(worker, id);
  minimizeFrame(frame);
}

static void runWithArguments(S item) {
  // TODO: run a dialog for that
}

static void search(final boolean requestFocus) {
  submittedInput = getInput();
  lastSearch = now();
  final String cmd = submittedInput;
  actionHistory.add(format3("*: Searching *", now(), cmd));
  thread {
    search(cmd, requestFocus);
  }  
}

answer {
  if "very quick java *"
    ret format("ok *", structure(callCalc(veryQuickJava(m.unq(0)))));
  if "restart" { restart(); ret "OK"; }
  if "activate" { activateFrame(frame); ret "OK"; }
}

static void runSelected() {
  S item = cast list.getModel().getElementAt(list.getSelectedIndex());
  runCustom("", item);
}

static void bringUpFrame() {
  makeFrameVisible(frame);
}

Began life as a copy of #1000794