!759

!include #1003797 // Thinker

static JTable table;

static JTextArea chat;

static JTextField input;

static File logFile;

static new L<S> log;

static L<S> recommendations;

static int listDelay = 2000;

static Bool thinking;

static bool updateOnce = true;

static new Thinker thinker;

static S systemPrefix = "[system]";

p-awt {

  //substanceLAF("EmeraldDusk"); // Too dark!

  substanceLAF("ChallengerDeep");

  loadLog();

  thinker.startUp(log);

  table = tableWithTooltips();

  chat = autoScroll(wordWrapTextArea());

  chat.setText(joinLines(log));

  input = new JTextField;

  JFrame frame = showFrame(vgrid(centerAndSouth(chat, input), table));

  //setFrameIconLater(frame, "#1003593");

  onEnter(input, r {

    post();

  });

  onDoubleClick(table, voidfunc(int row) {

    chooseSuggestion(row);

  });

  for (int i = 1; i <= 12; i++) {

    final int _i = i;

    registerFunctionKey(frame, i, r {

      chooseSuggestion(_i-1);

    });

  }

  fillList();

  input.requestFocus();

}

static S getInput() {

  ret joinLines(" # ", input.getText().trim());

}

static void post() {

  S i = getInput();

  if (inputAllowedByUser(i))

    post(i);

}

svoid chooseSuggestion(int row) {

  L<S> line = getTableLine(table, row);

  if (line == null) ret;

  S s = line.get(0);

  if (empty(s)) ret;

  input.setText(s);

  post();

}

static bool inputAllowedByUser(S i) {

  ret !swic(i, systemPrefix);

}

static void postSystemMessage(S msg) {

  post(systemPrefix + " " + msg);

}

static void post(S i) {

  S s = i + "\n";

  chat.append(s);

  appendToFile(logFile, "[" + chatTime() + "] " + s);

  synchronized(mc()) {

    log.add(i);

  }

  input.selectAll();

  updateOnce = true;

  try {

    action(i);

  } catch e {

    printStackTrace(e);

    postSystemMessage(exceptionToStringShort(e));

  }

}

static void action(S s) {

  s = dropBracketPrefix(s); // e.g. "[bot]"

  if (!s.startsWith("!")) ret;

  s = dropPrefix("!", s);

  new Matches m;

  // SYSTEM COMMANDS

  if "start program *" {

    S progID = m.fsi(0);

    S title = getSnippetTitle(progID);

    // TODO: Show author!

    S msg = "Run program " + progID + " - " + title + "?";

    if (confirmOKCancel(chat, msg)) {

      postSystemMessage("Starting program " + progID + " - " + quote(title));

      nohupJavax(progID);

    } else

      postSystemMessage("Program start cancelled by user (was: " + progID + ")");

  }

  if "hotwire * with argument *" {

    S progID = m.fsi(0), arg = m.unq(1);

    S title = getSnippetTitle(progID);

    S msg = "Hotwire & run program " + progID + " - " + quote(title) + " with argument " + quote(arg) + "?";

    if (confirmOKCancel(chat, msg)) {

      postSystemMessage("Hotwiring & running program " + progID + " - " + quote(title) + " with argument " + quote(arg));

      run(progID, arg);

    } else

      postSystemMessage("Program start cancelled by user (was: " + progID + ")");

  }

}

static void fillList() {

  bool t = shouldUpdateList() || updateOnce;

  updateOnce = false;

  if (neq(t, thinking)) {

    thinking = t;

    setFrameIcon(table, t ? "#1003603" : "#1003593");

  }

  if (!t)

    againl8r();

  else thread "Fill List" {

    final new L<S> data;

    thinker.makeListData(cloneList(log), data);

    dataToTable_uneditable(table, data);

    againl8r();

  }

}

static void againl8r() {

  swingAfter(table, listDelay, r { fillList(); });

}

static bool shouldUpdateList() {

  ret getFrame(table).isFocused()

    && !mouseInComponent(table);

}

// also called from outside

static L<S> loadLog() {

  if (logFile == null)

    logFile = getProgramFile("log.txt");

  for (S s : toLines(loadTextFile(logFile))) pcall {

    log.add(substring(s, s.indexOf(']')+1).trim());

  }

  ret log;

}

// CREATIVE PART!

// put func {}'s returning a string in there

static void makeGenerators(L<Gen> l, final L<S> log) {

  gen(l, "hello random", func { "Hello " + randomID(10) });

  gen(l, quine(func { last(log) }));

  gen(l, quine(func { oneOf(log) }));

  gen(l, "1 assoc", oneAssoc(log));

  gen(l, "most popular", mostPopular(log));

  addLoadedSolvers(l);

}

svoid addLoadedSolvers(L<Gen> l) {

  if (recommendations == null) { 

    recommendations = new L;

    for (S s : scanLog("recommendations.txt"))

      if (isSnippetID(s))

        recommendations.add(s);

  }

  for (final S solverID : recommendations)

    gen(l, solverID, func {

      O c = hotwireCached(solverID);

      ret call(c, "calc", log);

    });

}

static O oneAssoc(final L<S> log) {

  ret func {

    for (int i = l(log)-2; i >= 0; i--)

      if (eqic(log.get(i), last(log)))

        ret log.get(i+1);

    null;

  };

}

static O mostPopular(final L<S> log) {

  ret func {

    ret new MultiHashSet<S>(log).getMostPopularEntry();

  };

}

synchronized static L<S> getLastFromLog(int n) {

  ret cloneList(getLast(log, n));

}