// 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 JTable lastRunTable;

static ReliableSingleThread thread_lastRun;

static S menuSnippet = "#1000880";

static S menuScript;

static int searchDelay = 100;

static int maxResults = 100;

static int autoResearchInterval = 30000; // 30 secs

static boolean useFastNohup = true; // use pre-spun VMs if available

static int topTenLookBack = 100; // look at last 100 program runs

static L<S> actionHistory = synchroList();

!include #1000839 // PopupMenuHelper

p-awt {

  becomeBotVMIfFirst();

  //mistAqua();

  //magellan();

  //gemini();

  //emeraldDusk();

  //mistSilver();

  //substanceLAF("Raven");

  //substanceLAF("OfficeSilver2007");

  //substanceLAF("OfficeBlue2007");

  //substanceLAF("OfficeBlack2007");

  substanceLAF("Sahara");

  try {

    frame = showFrame();

  } catch (HeadlessException e) {

    System.out.println("We're headless...");

    // TODO: Something useful.

    System.exit(0);

  }

  updateTitle();

  makeAndroid3("JavaX Starter.");

  setFrameIconLater(frame, "#1003596");

  // Show the rays

  disposeWindowOnClick(showAnimation("#1003828", 3.5));

  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+4 < tok.size(); i += 2)

          if (tok.get(i+2).equals("=")) {

            final S snip = unquote(tok.get(i+4));

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

  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.run() });

  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 = sexyTable();

  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(f updateLastRun);

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

  trayIcon = installTrayIcon("JavaX!", "#1003596", popupItems());

  thread "Updating Menu every 10 minutes" {

    sleepMinutes(10);

    while (licensed()) {

      pcall {

        print("Updating menu.");

        updateMenu();

      }

      sleepMinutes(10);

    }

  }

  hideConsole();

  search(false);

}

svoid updateTitle {

  S title = "JavaX Starter v3";

  if (isOfflineMode()) title += " [OFFLINE MODE]";

  setFrameTitle(frame, title);

}

svoid updateMenu {

  updateTitle();

  trayIcon.setPopupMenu(makePopupMenu(dropFirst(popupItems())));

}

static O[] popupItems() {

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

    }

  }

  ret flattenArray(

    r { bringUpFrame(); }, // on left click

    toObjectArray(topTenItems),

    "***",

    menuItem("Show Runner", r { bringUpFrame(); }),

    menuItem("Show Console", r { showConsole(); }),

    menuItem("Restart Runner", r { restart(); }),

    menuItem("Show Talk Program [Eleutheria]", r { talkProgram(); }),

    //menuItem("Hide Console", r { hideConsole(); }),

    isOfflineMode()

      ? menuItem("Switch to online mode", r { goOnlineMode(); updateMenu(); })

      : menuItem("Switch to offline mode", r { goOfflineMode(); updateMenu(); }),

    menuItem("Exit", r { System.exit(0); }));

}

static S getInput() {

  ret tfCmd.getText().trim();

}

static void search(String cmd, final boolean requestFocus) ctex {

  searching = true;

  try {

    status("Searching " + quote(cmd) + "...");

    if (empty(cmd)) cmd = "_";

    if (cbPrograms.isSelected())

      cmd += " type:runnable";

    S page = loadPage("http://tinybrain.de:8080/tb/search.php?q=" + urlencode(cmd) + "&limit=" + maxResults + "&sort=modified&quick=1" + standardCredentials());

    Matcher m = Pattern.compile(">(#\\d+)</a> - (.*?)<br>").matcher(page);

    final new DefaultListModel model;

    while (m.find()) {

      String title = m.group(2);

      title = join(dropAllTags(htmlcoarsetok(title)));

      model.addElement(htmldecode(m.group(1) + " - " + title));

    }

    awt {

      list.setModel(model);

      status("Found " + model.size() + (model.size() == maxResults ? "+" : "") + (cbPrograms.isSelected() ? " runnable(s)." : " snippet(s)."));

      if (requestFocus)

        tfCmd.requestFocus();

    }

  } 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

    if (useFastNohup)

      fastNohupJavax(cmd);

    else

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

}

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

}

static void run() {

  S item = cast list.getModel().getElementAt(list.getSelectedIndex());

  runCustom("", item);

}

static void bringUpFrame() {

  makeFrameVisible(frame);

}

svoid updateLastRun {

  print("Updating last run list...");

  new L<Map> l;

  for (S s : uniquifyList(reversedList(scanRunLog(programID())))) {

    S progID = s;

    int i = s.indexOf(' ');

    if (i >= 0) {

      progID = substring(s, 0, i);

      s = trim(substring(s, i+1));

    } else

      s = ""; // no arguments

    //S title = getSnippetTitle_cached(progID);

    l.add(litorderedmap("Program ID" := fsI(progID),

      "Title" := "?", "Arguments" := s));

  }

  addProgramTitles(l);

  dataToTable_uneditable(l, lastRunTable);

}

svoid addProgramTitles(L<Map> l) {

  new HashSet<S> needed;

  for (Map m : l) {

    if (eq(m.get("Title"), "?")) {

      S id = getString(m, "Program ID");

      S title = getSnippetTitle_cached_probe(id);

      if (title != null)

        m.put("Title", title);

      else

        needed.add(id);

    }

  }

  print("Need " + n(needed, "snippet titles") + ": " + struct(needed));

  if (empty(needed)) ret;

  getSnippetTitles_verbose = true;

  SS titles = getSnippetTitles(needed);

  print("Done!");

  for (Map m : l) {

    S id = getString(m, "Program ID");

    if (eq(m.get("Title"), "?") && titles.containsKey(id)) {

      S title = titles.get(id);

      getSnippetTitle_cached_put(id, title);

      m.put("Title", title);

    }

  }

}